设计模式教程：观察者模式（Observer Pattern）

伯灵

发布于 2026-01-21 09:25:23

1080

一、模式概述

观察者模式（Observer Pattern）是一种行为型设计模式，它定义了一种一对多的依赖关系。一个对象（称为主题）状态发生变化时，所有依赖于它的对象（称为观察者）都会自动得到通知并更新。这样，观察者与主题之间是松耦合的，观察者只关心是否需要接收通知，而不需要关心主题的具体实现。

观察者模式常见的应用场景包括事件处理系统、消息推送系统、订阅/发布系统等。

二、模式角色和类图

观察者模式的主要角色包括：

Subject（主题）: 主题角色，维护一系列的观察者，并提供附加和删除观察者的功能。主题在状态发生变化时，通知所有注册的观察者。
Observer（观察者）: 观察者角色，定义一个更新接口，在主题发生变化时，自动执行更新操作。
ConcreteSubject（具体主题）: 实现了主题接口，维护主题的状态，并在其状态变化时通知所有注册的观察者。
ConcreteObserver（具体观察者）: 实现观察者接口，在主题状态发生变化时，执行具体的更新操作。

类图

+-----------------------+            +----------------------+
|      Subject          |<--------+   |      Observer        |
|-----------------------|         |   |----------------------|
| - observers           |         |   | + update()           |
| + attach(observer)    |         |   +----------------------+
| + detach(observer)    |         |
| + notify()            |         |
+-----------------------+         |
       |                           |
       v                           v
+-------------------------+   +----------------------------+
| ConcreteSubject         |   | ConcreteObserver           |
|-------------------------|   |----------------------------|
| - state                 |   | - observerState            |
| + getState()            |   | + update()                 |
| + setState(state)       |   |                            |
+-------------------------+   +----------------------------+

三、观察者模式的关键概念

主题（Subject）: 提供一个接口，让观察者可以注册、注销自己，同时当主题的状态发生变化时，通知所有的观察者。
观察者（Observer）: 观察者对象需要实现一个 update() 方法，用来在主题状态变化时执行更新操作。
具体主题（ConcreteSubject）: 是 Subject 的具体实现，维护状态并提供接口修改状态。每当状态发生变化时，它会通知所有注册的观察者。
具体观察者（ConcreteObserver）: 是 Observer 的具体实现，负责接收状态更新并执行具体的操作。

四、代码实现

我们通过一个实际的例子来展示如何实现观察者模式。假设我们有一个天气监测系统，主题是天气，观察者是显示设备（例如温度显示器、湿度显示器等）。

// 观察者接口
interface Observer {
    void update(String temperature, String humidity);
}

// 主题接口
interface Subject {
    void attach(Observer observer);
    void detach(Observer observer);
    void notifyObservers();
}

// 具体观察者：温度显示器
class TemperatureDisplay implements Observer {
    private String temperature;

    @Override
    public void update(String temperature, String humidity) {
        this.temperature = temperature;
        display();
    }

    public void display() {
        System.out.println("Temperature Display: " + temperature);
    }
}

// 具体观察者：湿度显示器
class HumidityDisplay implements Observer {
    private String humidity;

    @Override
    public void update(String temperature, String humidity) {
        this.humidity = humidity;
        display();
    }

    public void display() {
        System.out.println("Humidity Display: " + humidity);
    }
}

// 具体主题：天气站
class WeatherStation implements Subject {
    private String temperature;
    private String humidity;
    private List<Observer> observers = new ArrayList<>();

    public void setWeatherData(String temperature, String humidity) {
        this.temperature = temperature;
        this.humidity = humidity;
        notifyObservers(); // 状态变化，通知所有观察者
    }

    @Override
    public void attach(Observer observer) {
        observers.add(observer);
    }

    @Override
    public void detach(Observer observer) {
        observers.remove(observer);
    }

    @Override
    public void notifyObservers() {
        for (Observer observer : observers) {
            observer.update(temperature, humidity);
        }
    }
}

public class ObserverPatternDemo {
    public static void main(String[] args) {
        // 创建具体主题
        WeatherStation weatherStation = new WeatherStation();
        
        // 创建具体观察者
        TemperatureDisplay tempDisplay = new TemperatureDisplay();
        HumidityDisplay humidityDisplay = new HumidityDisplay();
        
        // 注册观察者
        weatherStation.attach(tempDisplay);
        weatherStation.attach(humidityDisplay);
        
        // 设置天气数据，所有观察者会收到通知
        weatherStation.setWeatherData("30°C", "60%");
        weatherStation.setWeatherData("25°C", "50%");
    }
}

五、代码解释

Observer接口: 定义了一个 update() 方法，所有的具体观察者都必须实现该方法，以便在主题发生变化时，能够接收到更新信息。
Subject接口: 主要包含 attach()、detach() 和 notifyObservers() 方法。attach() 方法用来注册观察者，detach() 用来注销观察者，notifyObservers() 在主题状态变化时通知所有观察者。
WeatherStation（具体主题）: 作为 Subject 的具体实现，维护温度和湿度两个状态，并在状态变化时通知所有注册的观察者。
TemperatureDisplay 和 HumidityDisplay（具体观察者）: 作为 Observer 的实现，它们通过 update() 方法接收主题的状态变化，并执行更新操作（例如显示新温度或湿度）。
主函数: 在 ObserverPatternDemo 中，我们创建了一个 WeatherStation 对象，注册了两个观察者（温度显示器和湿度显示器），并模拟了天气数据的变化。

六、输出

Temperature Display: 30°C
Humidity Display: 60%
Temperature Display: 25°C
Humidity Display: 50%

七、适用场景

观察者模式在许多实际应用中都非常有用，尤其是那些需要实现"一对多"依赖关系的场景。以下是一些常见的应用场景：

GUI系统中的事件监听器: 在图形用户界面（GUI）应用程序中，按钮点击、鼠标移动等事件可以通过观察者模式来实现，多个组件可以订阅按钮事件，按钮被点击时，所有订阅者都会接收到通知并执行相应的动作。
消息推送系统: 在新闻、股票、天气等应用中，用户可以订阅某些消息。当这些消息发生变化时，所有订阅该消息的用户都会收到通知。
分布式系统中的数据同步: 在分布式系统中，多个系统可能依赖于同一数据源，当数据源发生变化时，所有相关系统都需要同步更新数据，观察者模式可以有效地实现这一功能。
日志系统: 观察者模式可以用于日志记录，每个模块可以作为观察者，接收来自系统中其他模块的日志更新。

八、优缺点

优点

松耦合: 观察者模式的最大优势是它提供了松耦合的机制，观察者和主题之间通过接口进行通信，不会相互依赖，便于维护和扩展。
支持广播通信: 主题只需要通知所有已注册的观察者，观察者会根据需要执行更新操作。它非常适合于广播通信。
灵活性: 观察者模式支持动态的注册和注销观察者，允许在运行时添加或删除观察者，而不影响其他对象。

缺点

可能引起性能问题: 如果观察者数量非常多，或者观察者的更新操作很复杂，频繁的状态变化可能导致性能问题。
可能产生过多的更新: 如果观察者数量非常多，状态变化时每个观察者都需要被通知，可能会导致重复的操作或者不必要的更新。
循环依赖: 在一些复杂的应用中，如果观察者和主题之间存在复杂的依赖关系，可能会导致无限循环的通知。

九、总结

观察者模式是一个非常实用的设计模式，特别适用于那些需要实时通知相关对象的场景，如事件驱动的程序、实时数据推送、GUI事件监听等。通过观察者模式，系统中的各个组件之间能够保持松耦合，方便扩展和维护。然而，使用时要注意其带来的性能开销，特别是在观察者数量非常多或更新频繁的情况下。为了避免性能问题和复杂性，通常需要做好合理的优化和管理策略。通过观察者模式，我们可以实现高效的事件处理和状态同步，使得对象间的交互更加清晰、灵活且易于管理。