Java案例中的观察者模式怎么用？

wen java案例 2026-06-18 6

Java案例中的观察者模式怎么用？从理论到实战的完整解析

📖 目录导读

观察者模式核心概念 – 什么是观察者模式？它的设计意图与适用场景。
Java内置实现 vs 自定义实现 – 两种方式的优缺点对比。
实战案例：天气预报系统 – 一步步搭建可运行的观察者模式代码。
常见问题与问答 – 开发者最关心的5个观察者模式问题。
性能与SEO优化建议 – 如何让代码更高效,文章更易被搜索引擎收录。

观察者模式核心概念

观察者模式（Observer Pattern）是Java中行为型设计模式之一，定义了对象之间的一对多依赖关系，当“主题”（Subject）对象的状态发生变化时，所有依赖于它的“观察者”（Observer）对象都会自动收到通知并更新。

Java案例中的观察者模式怎么用？

设计意图：实现松耦合的通信机制,让主题和观察者可以独立扩展。

适用场景：

当一个对象的改变需要同时改变其他对象,且不知道具体有多少对象需要改变时。
事件驱动架构（如GUI按钮点击、消息队列）。
实时数据推送（如股票行情、物联网传感器数据）。

关键角色：

Subject（主题）：维护观察者列表，提供注册、移除和通知方法。

Observer（观察者）：定义一个更新接口,接收主题的通知。

ConcreteSubject（具体主题）：存储感兴趣的状态,状态变化时通知观察者。

ConcreteObserver（具体观察者）：实现更新接口,根据主题的状态做出响应。

Java内置实现 vs 自定义实现

1 Java内置观察者模式（JDK 9之前）

Java在java.util包中提供了Observable类和Observer接口，但自JDK 9起，这两个类已被标注为弃用，原因是它们的设计存在缺陷（如Observable是一个类而非接口，限制了灵活性；且无法实现事件传播的细粒度控制）。

2 自定义观察者模式（推荐方式）

现代Java开发中，更推荐手动编写观察者模式接口和实现,这样可以：

使用接口而非抽象类，支持多继承（通过接口）。
灵活控制通知的同步/异步机制。
避免遗留API的线程安全问题。

代码结构示例：

// 主题接口
interface Subject {
    void registerObserver(Observer o);
    void removeObserver(Observer o);
    void notifyObservers();
}
// 观察者接口
interface Observer {
    void update(float temperature, float humidity, float pressure);
}

实战案例：天气预报系统

假设我们要开发一个气象站系统，当天气数据（温度、湿度、气压）更新时，需要自动刷新多个显示面板（当前状态显示、统计显示、预报显示）。

步骤1：定义主题接口和具体主题

import java.util.ArrayList;
import java.util.List;
class WeatherData implements Subject {
    private List<Observer> observers;
    private float temperature;
    private float humidity;
    private float pressure;
    public WeatherData() {
        observers = new ArrayList<>();
    }
    @Override
    public void registerObserver(Observer o) {
        observers.add(o);
    }
    @Override
    public void removeObserver(Observer o) {
        observers.remove(o);
    }
    @Override
    public void notifyObservers() {
        for (Observer observer : observers) {
            observer.update(temperature, humidity, pressure);
        }
    }
    // 当气象站更新数据时调用此方法
    public void setMeasurements(float temperature, float humidity, float pressure) {
        this.temperature = temperature;
        this.humidity = humidity;
        this.pressure = pressure;
        measurementsChanged();
    }
    private void measurementsChanged() {
        notifyObservers();
    }
}

步骤2：定义观察者接口和具体观察者

// 当前状态显示面板
class CurrentConditionsDisplay implements Observer {
    private float temperature;
    private float humidity;
    @Override
    public void update(float temperature, float humidity, float pressure) {
        this.temperature = temperature;
        this.humidity = humidity;
        display();
    }
    public void display() {
        System.out.println("当前状态: " + temperature + "°C, 湿度 " + humidity + "%");
    }
}
// 统计显示面板（模拟）
class StatisticsDisplay implements Observer {
    private float maxTemp = 0.0f;
    private float minTemp = 200;
    private float tempSum = 0.0f;
    private int numReadings;
    @Override
    public void update(float temperature, float humidity, float pressure) {
        tempSum += temperature;
        numReadings++;
        if (temperature > maxTemp) maxTemp = temperature;
        if (temperature < minTemp) minTemp = temperature;
        display();
    }
    public void display() {
        System.out.println("温度统计: 平均 " + (tempSum / numReadings) + "°C, 最高 " + maxTemp + "°C, 最低 " + minTemp + "°C");
    }
}

步骤3：运行测试

public class WeatherStation {
    public static void main(String[] args) {
        WeatherData weatherData = new WeatherData();
        CurrentConditionsDisplay currentDisplay = new CurrentConditionsDisplay();
        StatisticsDisplay statisticsDisplay = new StatisticsDisplay();
        weatherData.registerObserver(currentDisplay);
        weatherData.registerObserver(statisticsDisplay);
        System.out.println("--- 第一次天气更新 ---");
        weatherData.setMeasurements(25.5f, 65, 1013.1f);
        System.out.println("\n--- 第二次天气更新 ---");
        weatherData.setMeasurements(27.8f, 70, 1011.5f);
        // 移除一个观察者
        weatherData.removeObserver(currentDisplay);
        System.out.println("\n--- 移除当前显示面板后，第三次更新 ---");
        weatherData.setMeasurements(22.3f, 80, 1015.2f);
    }
}

输出结果：

--- 第一次天气更新 ---
当前状态: 25.5°C, 湿度 65%
温度统计: 平均 25.5°C, 最高 25.5°C, 最低 25.5°C
--- 第二次天气更新 ---
当前状态: 27.8°C, 湿度 70%
温度统计: 平均 26.65°C, 最高 27.8°C, 最低 25.5°C
--- 移除当前显示面板后，第三次更新 ---
温度统计: 平均 25.23°C, 最高 27.8°C, 最低 22.3°C