Java如何用Consumer接口优雅重构传统的观察者设计模式-java教程-PHP中文网

consumer更适合做观察者逻辑，因其天然契合“消费一个值、不返回结果”的update语义，可复用jdk接口、消除模板代码、支持lambda与组合操作。

java如何用consumer接口优雅重构传统的观察者设计模式

Java 8 的 Consumer<t></t> 接口可以大幅简化观察者模式的实现，把原本需要定义接口、抽象类、多个具体观察者类的繁重结构，压缩为一行 lambda 或方法引用。核心思路是：用 Consumer 替代自定义的 Observer 接口，用函数式表达“收到通知后做什么”，从而消除模板代码和继承层级。

为什么 Consumer 更适合做观察者逻辑

Consumer<t></t> 天然契合观察者行为的本质——它只关心“消费一个值”，不返回结果，正对应 update(T data) 的语义。相比传统 Observer 接口：

无需声明新接口，直接复用 JDK 标准函数式接口
避免空实现类或匿名内部类的样板代码
支持 lambda 表达式，让注册观察者像写一句“收到就打印”一样直观
天然支持组合（andThen）、判空防护（Consumer<t>.accept</t> 可配合 Objects.requireNonNull）

重构步骤：从传统写法到 Consumer 版本

假设原主题类维护 List<observer></observer> 并调用 observer.update(data)。重构只需三步：

将主题内部的观察者集合从 List<observer></observer> 改为 List<consumer>></consumer>（类型按实际通知数据调整）
删除所有自定义 Observer 接口及其实现类
注册时传入 Consumer<string></string> 实例，例如 system.addSubscriber(s -> log.info("收到: {}", s))

完整示例：气象站通知消费者

传统方式要写 Observer 接口、PhoneDisplay、WebDisplay 等多个类；Consumer 版本只需：

java-enterprise

Java企业开发专家，专注于Spring Boot、微服务架构和JVM优化。适用于：Java语言掌握、

下载

主题类（精简后）：

public class WeatherStation {
    private final List<consumer>> subscribers = new ArrayList();
    private float temperature;

    public void register(Consumer<float> subscriber) {
        subscribers.add(subscriber);
    }

    public void setTemperature(float temp) {
        this.temperature = temp;
        subscribers.forEach(consumer -> consumer.accept(temp));
    }
}</float></consumer>

使用时直接传行为：

WeatherStation station = new WeatherStation();

// 手机端：打印温度
station.register(temp -> System.out.println("? 手机显示：" + temp + "℃"));

// 后台告警：温度超阈值发邮件
station.register(temp -> {
    if (temp > 40) {
        sendAlertEmail("高温预警：" + temp);
    }
});

station.setTemperature(38.5f); // 自动触发所有 Consumer