观察者模式属于行为型设计模式，核心逻辑是定义对象间的一对多依赖关系，当一个对象状态发生改变时，所有依赖它的对象都会收到通知并自动更新。在C++中实现该模式通常需要抽象被观察者、抽象观察者以及具体实现类，结合事件回调机制可以让通知逻辑更灵活。
观察者模式核心组成
实现观察者模式需要明确几个核心角色：
- 抽象被观察者：定义添加观察者、移除观察者、通知观察者的接口
- 具体被观察者：实现抽象被观察者的接口，维护观察者列表，状态变化时触发通知
- 抽象观察者：定义接收通知的更新接口
- 具体观察者：实现抽象观察者的更新接口，处理接收到的通知逻辑
- 事件回调：被观察者通知时携带的事件数据，用于传递状态变化信息
基础实现示例
首先定义事件回调的数据结构，用于传递被观察者的状态变化信息：
#include <iostream>
#include <vector>
#include <memory>
#include <algorithm>
// 事件回调数据结构，携带状态变化信息
struct EventData {
int event_type; // 事件类型
std::string event_msg; // 事件描述
};
抽象观察者定义
抽象观察者只需要定义统一的更新接口，具体逻辑由子类实现：
// 抽象观察者类
class Observer {
public:
virtual ~Observer() = default;
// 接收通知的更新接口，event为事件回调数据
virtual void update(const EventData& event) = 0;
};
抽象被观察者定义
抽象被观察者维护观察者列表，提供添加、移除和通知的接口：
// 抽象被观察者类
class Subject {
public:
virtual ~Subject() = default;
// 添加观察者
virtual void attach(std::shared_ptr<Observer> observer) = 0;
// 移除观察者
virtual void detach(std::shared_ptr<Observer> observer) = 0;
// 通知所有观察者
virtual void notify(const EventData& event) = 0;
protected:
std::vector<std::shared_ptr<Observer>> observer_list; // 观察者列表
};
具体实现类
具体被观察者实现状态更新和通知逻辑，具体观察者实现各自的更新处理：
// 具体被观察者类
class ConcreteSubject : public Subject {
public:
void attach(std::shared_ptr<Observer> observer) override {
observer_list.push_back(observer);
}
void detach(std::shared_ptr<Observer> observer) override {
auto it = std::find(observer_list.begin(), observer_list.end(), observer);
if (it != observer_list.end()) {
observer_list.erase(it);
}
}
void notify(const EventData& event) override {
for (auto& observer : observer_list) {
observer->update(event);
}
}
// 状态变化接口，触发通知
void change_state(int new_state) {
current_state = new_state;
EventData event;
event.event_type = new_state;
event.event_msg = "状态更新为: " + std::to_string(new_state);
notify(event);
}
private:
int current_state = 0;
};
// 具体观察者A
class ConcreteObserverA : public Observer {
public:
void update(const EventData& event) override {
std::cout << "观察者A收到通知: 事件类型" << event.event_type
<< ", 描述: " << event.event_msg << std::endl;
}
};
// 具体观察者B
class ConcreteObserverB : public Observer {
public:
void update(const EventData& event) override {
std::cout << "观察者B收到通知: 事件类型" << event.event_type
<< ", 描述: " << event.event_msg << std::endl;
}
};
测试代码
编写测试逻辑验证观察者模式的运行效果：
int main() {
// 创建被观察者
auto subject = std::make_shared<ConcreteSubject>();
// 创建观察者
auto observer_a = std::make_shared<ConcreteObserverA>();
auto observer_b = std::make_shared<ConcreteObserverB>();
// 添加观察者
subject->attach(observer_a);
subject->attach(observer_b);
// 被观察者状态变化，触发通知
std::cout << "第一次状态更新:" << std::endl;
subject->change_state(1);
// 移除观察者A
subject->detach(observer_a);
std::cout << "第二次状态更新（移除A后）:" << std::endl;
subject->change_state(2);
return 0;
}
实现注意事项
在C++中实现观察者模式需要注意几个问题：
- 观察者管理建议使用智能指针，避免裸指针导致的悬空引用问题
- 通知过程中如果需要修改观察者列表，要注意迭代器失效的问题，可以先拷贝列表再遍历通知
- 事件回调数据设计要通用，尽量覆盖不同场景的状态传递需求
- 如果观察者更新逻辑较重，可以考虑将通知逻辑放到单独的线程中执行，避免阻塞被观察者的状态更新流程
上述示例完整展示了C++中观察者模式的实现方式，结合事件回调机制可以灵活传递状态变化信息，适配大多数需要一对多通知的场景。