设计要点：从抽象到实现的路径
观察者模式的核心角色
观察者模式强调对象之间的低耦合，其核心在于将变化的通知从发出者解耦到多个接收者。通过这种设计，事件通知机制变得可扩展且可维护。在C++实践中，通常会出现三个角色：Subject（可观测对象）、Observer（观察者接口）以及具体的Observing对象。通过这些角色，系统能够在状态变化时触发一系列回调，完成通知链路的构建。
在实现中，最重要的是定义一组稳定的通知契约，使得观察者可以在不依赖具体实现细节的情况下接收信息。这种契约通常表现为一个纯虚函数接口，其参数既要表达事件的类型，也要携带必要的上下文数据。
事件通知机制的传递策略
事件通知机制中，推送与拉取两种模式各有场景，决定了实现的复杂度和性能。推送模式由Subject主动将事件和数据推送给观察者，适合事件数据较为丰富、观察者数量相对稳定的场景；而<正>拉取模式则由观察者在通知后自行从Subject获取所需信息，便于降低每次通知时的数据复制成本。
在C++实现里，常见的设计是Subject维护一个观察者集合，通知时通过回调逐个触达Observer对象；为避免悬空指针，通常采用智能指针（shared_ptr/weak_ptr）组合来管理对象生命周期，并在通知过程中剔除已被销毁的观察者。
C++实现要点与代码示例
接口设计：Subject 与 Observer
明确的接口设计是实现观察者模式的起点。Observer作为一个纯虚接口，定义了统一的回调方法；Subject提供订阅、退订和通知的能力。通过这种分离，增加新的观察者类型只需要实现接口，不需要改动Subject的实现。
下面给出一个简化的接口设计示例，展示了如何在C++中以最小的开销实现观察者模式的核心契约。
// Observer interface
class IObserver {
public:virtual void onNotify(int eventId, const std::string& payload) = 0;virtual ~IObserver() = default;
};// Subject shoulders the responsibility of subscription and notification
class Subject {std::vector> observers;
public:void attach(std::shared_ptr obs) {observers.push_back(obs);}void detach(std::shared_ptr obs) {observers.erase(std::remove_if(observers.begin(), observers.end(),[&](const std::weak_ptr& w){auto sp = w.lock();return !sp || sp == obs;}), observers.end());}void notify(int eventId, const std::string& payload) {for (auto it = observers.begin(); it != observers.end();) {if (auto sp = it->lock()) {sp->onNotify(eventId, payload);++it;} else {it = observers.erase(it);}}}
}; 内存管理与生命周期
在一个长期运行的系统里，生命周期管理极其关键。直接使用裸指针容易引发悬空访问，而使用强引用（std::shared_ptr）又可能造成循环引用。最佳实践是让Subject拥有观察者的弱引用（std::weak_ptr），在通知前先升级为强引用以确保对象仍然有效。
此外，退订机制应在观察者析构时自动生效，避免显式调用离开导致的错配。通过在通知阶段清理失效的弱引用，可以保证通知环路的健壮性与性能。
实战演练：一个简易的事件通知系统
场景与需求
在一个简化的GUI或控制系统中，按钮点击、鼠标悬停等事件需要被不同模块监听。这些模块可能包括日志记录、UI更新、状态统计等。通过一个统一的事件发布者（Publisher），各观察者（Observer）仅对感兴趣的事件做出响应，从而实现松耦合与可扩展性。
设计目标包括：1) 统一的事件类型定义；2) 安全的订阅/退订机制；3) 高效的通知流程，同时避免悬空指针与内存泄漏。
核心实现与代码解读
以下实现展示了一个简单的事件发布-订阅系统，Observer 接口和 Publisher 的协作方式。通过在通知阶段先缓存存活的观察者，在遍历时避免对已销毁对象的访问，这一模式在高并发场景中尤为重要。
#include <iostream>
#include <vector>
#include <memory>
#include <algorithm>enum class EventType { Click, Hover, Resize };class IObserver {
public:virtual void onNotify(EventType type, const std::string& payload) = 0;virtual ~IObserver() = default;
};class EventPublisher {std::vector<std::weak_ptr<IObserver>> observers;
public:void subscribe(std::shared_ptr<IObserver> obs) {observers.push_back(obs);}void unsubscribe(std::shared_ptr<IObserver> obs) {observers.erase(std::remove_if(observers.begin(), observers.end(),[&](const std::weak_ptr<IObserver>& w){auto sp = w.lock();return !sp || sp == obs;}), observers.end());}void publish(EventType type, const std::string& payload) {// 先收集存活的观察者，避免在回调中产生副作用std::vector<std::shared_ptr<IObserver>> alive;for (auto &w : observers) {if (auto sp = w.lock()) alive.push_back(sp);}for (auto &obs : alive) obs->onNotify(type, payload);}
};class ConsoleLogger : public IObserver {
public:void onNotify(EventType type, const std::string& payload) override {std::cout << "[LOG] " << static_cast<int>(type) << ": " << payload << std::endl;}
};int main() {auto publisher = std::make_shared<EventPublisher>();auto logger = std::make_shared<ConsoleLogger>();publisher->subscribe(logger);publisher->publish(EventType::Click, "Button clicked");publisher->publish(EventType::Hover, "Mouse over button");return 0;
}扩展与进阶：异步通知与线程安全
同步通知的挑战
在高并发环境中，同步通知可能成为瓶颈，因为通知会阻塞发布者的继续执行。设计上应考虑将通知的处理与主工作分离，确保发送端的吞吐量不被观察者的执行时间拖慢。
常见做法是为通知引入最小化的保护区，例如在发送端仅将事件放入一个队列，由专门的工作线程或线程池消费并分发给观察者。
异步通知的实现模式
通过引入异步队列和工作线程，可以实现真正的事件驱动架构。消息队列、线程池与工作窃取等技术能够提升系统响应性，并降低观测者对主线程的依赖。
#include <queue>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <vector>
#include <memory>
#include <functional>class AsyncEventPublisher {std::vector<std::weak_ptr<IObserver>> observers;std::queue<std::pair<EventType, std::string>> eventQueue;std::mutex mtx;std::condition_variable cv;bool stop = false;std::thread worker;void workerLoop() {while (true) {std::unique_lock<std::mutex> lk(mtx);cv.wait(lk, [&]{ return stop || !eventQueue.empty(); });if (stop && eventQueue.empty()) return;auto item = eventQueue.front(); eventQueue.pop();lk.unlock();// 收集存活观察者后异步通知std::vector<std::shared_ptr<IObserver>> alive;{std::lock_guard<std::mutex> lock(mtx);for (auto &w : observers) if (auto sp = w.lock()) alive.push_back(sp);}for (auto &obs : alive) obs->onNotify(item.first, item.second);}}public:AsyncEventPublisher() : worker(&AsyncEventPublisher::workerLoop, this) {}~AsyncEventPublisher() {{std::lock_guard<std::mutex> lock(mtx);stop = true;}cv.notify_all();if (worker.joinable()) worker.join();}void subscribe(std::shared_ptr<IObserver> obs) {std::lock_guard<std::mutex> lock(mtx);observers.push_back(obs);}void publish(EventType type, const std::string& payload) {std::lock_guard<std::mutex> lock(mtx);eventQueue.emplace(type, payload);cv.notify_one();}
};