技术笔记项目：深入理解观察者模式（Observer Pattern）

2025-06-06 15:18:11作者：胡易黎Nicole

什么是观察者模式？

观察者模式是一种行为设计模式，它定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。当主题对象状态发生变化时，它会自动通知所有观察者对象，使它们能够自动更新自己。

想象一下报纸订阅的场景：报社（主题）负责发布新闻，而订阅者（观察者）则会在新闻发布时自动收到更新。观察者模式正是这种机制的软件实现。

观察者模式的核心组件

1. 主题（Subject）接口

定义三个核心操作：

attach()：添加观察者
detach()：移除观察者
notifyObservers()：通知所有观察者

2. 具体主题（ConcreteSubject）

维护观察者列表和状态数据，当状态改变时调用通知方法。

3. 观察者（Observer）接口

定义update()方法，供主题在状态变化时调用。

4. 具体观察者（ConcreteObserver）

实现update()方法，定义收到通知后的具体行为。

观察者模式的两种实现方式

推模型（Push Model）

主题主动将变化的数据推送给观察者：

void update(int temperature, int humidity);

拉模型（Pull Model）

主题仅通知观察者状态已改变，观察者自行获取所需数据：

void update(Subject subject);

推模型更直接但不够灵活，拉模型更灵活但需要观察者主动获取数据。实际开发中可根据需求选择或混合使用。

多语言实现示例

Java实现

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

// 具体主题：气象站
class WeatherStation implements Subject {
    private List<Observer> observers = new ArrayList<>();
    private float temperature;
    
    public void setTemperature(float temp) {
        this.temperature = temp;
        notifyObservers();
    }
    
    // 实现接口方法...
}

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

// 具体观察者：显示设备
class DisplayDevice implements Observer {
    public void update(float temp) {
        System.out.println("温度更新：" + temp);
    }
}

JavaScript实现

class NewsPublisher {
    constructor() {
        this.subscribers = [];
    }
    
    subscribe(subscriber) {
        this.subscribers.push(subscriber);
    }
    
    publish(news) {
        this.subscribers.forEach(sub => sub.update(news));
    }
}

class Subscriber {
    update(news) {
        console.log(`收到新闻：${news}`);
    }
}

Python实现

class StockMarket:
    def __init__(self):
        self._investors = []
        self._stock_price = None
    
    def attach(self, investor):
        self._investors.append(investor)
    
    def price_change(self, new_price):
        self._stock_price = new_price
        self._notify()
    
    def _notify(self):
        for investor in self._investors:
            investor.update(self._stock_price)