C++如何实现观察者模式多事件通知

使用事件枚举与回调映射实现多事件通知，通过EventType区分事件类型，IObserver接口的onEvent方法根据类型处理，EventDispatcher管理订阅与分发，支持灵活注册和通知。

在C++中实现支持多事件通知的观察者模式，核心是让观察者能根据不同的事件类型选择性地接收和处理通知。传统的观察者模式通常只处理单一事件，但通过引入事件类型区分机制，可以轻松扩展为支持多种事件。

使用事件枚举与回调映射

定义清晰的事件类型，是实现多事件通知的第一步。可以使用枚举来表示不同的事件：

enum class EventType {
    USER_LOGIN,
    USER_LOGOUT,
    DATA_UPDATED,
    SYSTEM_ERROR
};

观察者接口不再只有一个update方法，而是可以根据事件类型做出不同响应：

class IObserver {
public:
    virtual ~IObserver() = default;
    virtual void onEvent(EventType type, const std::any& data) = 0;
};

说明： 使用std::any可以传递任意类型的数据，增强灵活性。每个观察者在onEvent中判断事件类型并执行对应逻辑。

立即学习“C++免费学习笔记（深入）”；

事件分发器的设计

创建一个事件中心或主题类，管理观察者注册和事件分发：

class EventDispatcher {
private:
    std::map> observers;
public:
void subscribe(EventType type, IObserver* observer) {
observers[type].push_back(observer);
}
void unsubscribe(EventType type, IObserver* observer) {
    auto& list = observers[type];
    list.erase(std::remove(list.begin(), list.end(), observer), list.end());
}

void notify(EventType type, const std::any& data) {
    for (auto* obs : observers[type]) {
        obs->onEvent(type, data);
    }
}
};

							

								
								

									SuperDesign
									
开源的UI设计AI智能体
								
								下载 
							
						
建议： 若需全局访问，可将EventDispatcher实现为单例；若需更细粒度控制，可为不同模块创建多个实例。
实际使用示例
定义具体观察者，比如日志记录器只关心登录登出，数据同步器关注数据更新：
class Logger : public IObserver {
public:
    void onEvent(EventType type, const std::any& data) override {
        if (type == EventType::USER_LOGIN || type == EventType::USER_LOGOUT) {
            std::string user = std::any_cast(data);
            std::cout << "Log: User event - " << 
                (type == EventType::USER_LOGIN ? "Login" : "Logout") << 
                " by " << user << "\n";
        }
    }
};
class DataSync : public IObserver {
public:
void onEvent(EventType type, const std::any& data) override {
if (type == EventType::DATA_UPDATED) {
auto changes = std::any_cast>(data);
std::cout << "Sync: " << changes.size() << " items updated\n";
}
}
};
使用时注册对应事件：
EventDispatcher dispatcher;
Logger logger;
DataSync sync;
dispatcher.subscribe(EventType::USER_LOGIN, &logger);
dispatcher.subscribe(EventType::USER_LOGOUT, &logger);
dispatcher.subscribe(EventType::DATA_UPDATED, &sync);
// 触发事件
dispatcher.notify(EventType::USER_LOGIN, std::string("Alice"));
dispatcher.notify(EventType::DATA_UPDATED, std::vector{"file1", "file2"});
线程安全与性能考虑
若在多线程环境下使用，需对observer容器加锁：
std::mutex mtx;
void subscribe(EventType type, IObserver* observer) {
std::lock_guard lock(mtx);
observers[type].push_back(observer);
}
对于高频事件，可考虑异步队列+工作线程处理，避免阻塞主逻辑。
基本上就这些。关键是把事件分类清楚，用统一入口分发，各观察者按需响应。结构清晰，扩展方便。不复杂但容易忽略细节，比如内存管理和类型安全。