从C++编程入手设计模式——观察者模式
观察者模式简直就是字如其名，观察观察，观察到了告诉别人。观察手的作用如此，观察者模式的工作机制也是如此。这个模式的核心思路是：一个对象的状态发生变化时，自动通知依赖它的其他对象，让它们自行更新。
主要的组成部分
一是被观察者，也叫主题（Subject），它负责记录观察者并在自身状态发生变化时通知它们；换而言之，Subject作为信息的生成端，生成信息。
二是观察者（Observer），它主动注册到被观察者中，等待被通知，一旦收到消息就立即采取行动。这里生成端会使用远程的方式通知我们的被观察者投送信息。
你可以把观察者模式想象成“订阅报纸”。报社就是主题，它维护一个订阅者名单（观察者列表）。每当有新一期的报纸（数据更新）出版时，它就向所有订阅者投递（通知）。每位订阅者收到报纸后根据自己的需要决定怎么处理，是直接阅读、剪报存档还是转发朋友。这种发布-订阅机制就是观察者模式的最基本形式。
在 C++ 中怎么写？
观察者模式的代码实现非常自然。我们会先定义一个抽象的观察者接口（通常叫 Observer 或者 Sender），让不同的具体观察者实现它；再定义一个主题类（通常叫 Subject 或 Notifier），它包含一个观察者列表，并负责注册、移除和通知观察者。每当主题内部数据变化（比如温度、湿度更新），它就会遍历观察者列表，挨个调用它们的“更新方法”。观察者模式的重点不在于通知的“数据内容”本身，而在于自动通知的机制。
选择观察者模式？
在简单的程序中，我们可能会直接调用某些对象来执行逻辑。但如果程序复杂起来，比如某个数据更新后要引发十几种操作，硬编码这些调用就会让系统结构僵硬，维护困难。
观察者模式将“变化的主体”和“依赖的反应者”解耦。被观察者不用关心观察者是谁，它只管发出通知。观察者自己决定是否接收通知、如何响应。这让系统的扩展性和灵活性大大提高。
比如天气系统中新加一个“语音播报设备”，只要实现观察者接口并注册进去，其他部分代码几乎无需改动。
观察者模式的几个关键词
- 低耦合：主题和观察者之间不互相依赖，只通过接口通信。
- 自动同步：当主题数据变化时，所有观察者自动得到通知。
- 一对多：一个主题可以对应多个观察者。
- 注册/注销机制：观察者可以自由加入或离开通知流程。
Example
可以直接看一个代码框架来解决问题
#include <iostream>
#include <vector>
#include <memory>
#include <string>
#include <algorithm>
// 观察者接口
class Observer {
public:
virtual void update(const std::string& message) = 0;
virtual ~Observer() = default;
};
// 具体观察者
class ConcreteObserver : public Observer {
private:
std::string name;
public:
explicit ConcreteObserver(std::string n) : name(std::move(n)) {}
void update(const std::string& message) override {
std::cout << "Observer [" << name << "] received: " << message << '\n';
}
};
// 主题接口
class Subject {
public:
virtual void attach(std::shared_ptr<Observer> observer) = 0;
virtual void detach(std::shared_ptr<Observer> observer) = 0;
virtual void notify(const std::string& message) = 0;
virtual ~Subject() = default;
};
// 具体主题
class ConcreteSubject : public Subject {
private:
std::vector<std::shared_ptr<Observer>> observers;
public:
void attach(std::shared_ptr<Observer> observer) override {
observers.push_back(std::move(observer));
}
void detach(std::shared_ptr<Observer> observer) override {
observers.erase(std::remove(observers.begin(), observers.end(), observer), observers.end());
}
void notify(const std::string& message) override {
for (const auto& observer : observers) {
observer->update(message);
}
}
};
int main() {
auto subject = std::make_shared<ConcreteSubject>();
auto obs1 = std::make_shared<ConcreteObserver>("Observer1");
auto obs2 = std::make_shared<ConcreteObserver>("Observer2");
subject->attach(obs1);
subject->attach(obs2);
subject->notify("Event 1 occurred");
subject->detach(obs1);
subject->notify("Event 2 occurred");
return 0;
}
你可以使用这样的方式来作为事件驱动框架的一个根基。
练习题
天气站系统
要求：设计一个天气数据发布系统，天气站（WeatherStation）是“主题”，可通知多个“观察者”显示设备（如手机、网页等）。
功能要求：
- 观察者可以注册/注销。
- 当温度或湿度变化时，所有注册观察者会收到更新并打印数据。（注：这个部分笔者的参考代码没有实现，您自己酌情思考）
提示：
- 使用接口
IObserver表示观察者，定义如update(float temperature, float humidity)； - 主题接口
ISubject需要支持registerObserver()、removeObserver()、notifyObservers()； - 可以实现两个观察者类
PhoneDisplay和WebDisplay。