C++如何实现观察者模式多事件通知-C++-PHP中文网

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

P粉602998670

发布： 2025-09-13 11:32:01

原创

553人浏览过

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

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

在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;
};
</font>

登录后复制

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

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

事件分发器的设计

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

class EventDispatcher {
private:
    std::map<EventType, std::vector<IObserver*>> observers;
<p>public:
void subscribe(EventType type, IObserver* observer) {
observers[type].push_back(observer);
}</p><pre class='brush:php;toolbar:false;'>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);
    }
}

登录后复制

};

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

建议： 若需全局访问，可将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<std::string>(data);
            std::cout << "Log: User event - " << 
                (type == EventType::USER_LOGIN ? "Login" : "Logout") << 
                " by " << user << "\n";
        }
    }
};
<p>class DataSync : public IObserver {
public:
void onEvent(EventType type, const std::any& data) override {
if (type == EventType::DATA_UPDATED) {
auto changes = std::any_cast<std::vector<std::string>>(data);
std::cout << "Sync: " << changes.size() << " items updated\n";
}
}
};</p>

登录后复制

使用时注册对应事件：

EventDispatcher dispatcher;
Logger logger;
DataSync sync;
<p>dispatcher.subscribe(EventType::USER_LOGIN, &logger);
dispatcher.subscribe(EventType::USER_LOGOUT, &logger);
dispatcher.subscribe(EventType::DATA_UPDATED, &sync);</p><p>// 触发事件
dispatcher.notify(EventType::USER_LOGIN, std::string("Alice"));
dispatcher.notify(EventType::DATA_UPDATED, std::vector<std::string>{"file1", "file2"});</p>

登录后复制

线程安全与性能考虑

若在多线程环境下使用，需对observer容器加锁：

std::mutex mtx;
<p>void subscribe(EventType type, IObserver* observer) {
std::lock_guard<std::mutex> lock(mtx);
observers[type].push_back(observer);
}</p>

登录后复制

对于高频事件，可考虑异步队列+工作线程处理，避免阻塞主逻辑。

基本上就这些。关键是把事件分类清楚，用统一入口分发，各观察者按需响应。结构清晰，扩展方便。不复杂但容易忽略细节，比如内存管理和类型安全。

以上就是C++如何实现观察者模式多事件通知的详细内容，更多请关注php中文网其它相关文章！