首页 > 编程笔记 > C++笔记 阅读：8

观察者模式详解（附带C++实例）

观察者模式是一种发布－订阅的模式，允许多个观察者对象同时监听某一个主题对象，这个主题对象在状态变化时会通知所有观察者对象。

观察者模式通过定义清晰的角色和职责，极大地简化了复杂交互的管理，使得系统更加灵活和易于扩展。接下来，我们将介绍观察者模式中的关键角色，以及它们在模式中承担的具体职责。

观察者模式中的角色定义

观察者模式主要涉及两种类型的角色：主题和观察者。每种角色都有其独特的职责，它们共同协作，确保状态变化能够被有效传达和处理。

1) 主题

主题在观察者模式中扮演着信息源的角色，通常包含一些核心业务逻辑，一旦其状态发生变化，就需要通知所有注册的观察者。

主题的职责如下：
在我们的股票价格更新示例中，StockPrice 类实现了主题接口，当价格更新时，它负责通知所有关注价格变动的观察者。

2) 观察者

观察者是主题状态变化的响应者。每个观察者需要注册到感兴趣的主题上，以便在主题状态改变时接收到通知。

观察者的职责如下：
在示例中，DashboardDisplay 和 RiskManagement 类分别实现了观察者接口。它们根据股票价格的变化更新显示或触发风险警报。

通过这些角色的定义和配合，观察者模式为多组件系统中的交互提供了一种优雅且解耦的方式。这不仅增强了系统的可维护性，也提升了可扩展性和灵活性。在任何需要多个组件相互协作响应同一事件的场景中，观察者模式都是一种非常适合的设计选择。

观察者模式的设计规则

在实现观察者模式时，为了确保模式的正确性和效率，开发者应遵循一些设计规则。这些规则有助于保持系统的灵活性、可维护性和可扩展性，同时避免常见的陷阱。

以下是实现观察者模式时应考虑的关键规则：

1) 保持主题与观察者之间的松耦合

原则：主题不应该知道观察者的具体类，只需知道观察者实现了更新接口。这种松耦合设计使得观察者可以自由地添加或移除，而不影响主题的核心功能。

实践：在主题中使用观察者接口的引用或指针，而不是具体类的引用或指针。

2) 及时且安全的通知传递

原则：当主题的状态变化时，所有注册的观察者都应该及时且安全地得到通知。

实践：在主题的状态更新函数中，如有任何状态改变，立即调用通知方法。使用互斥锁或其他同步机制来保护观察者列表的修改及通知调用的整个过程，避免在通知过程中修改观察者列表，出现迭代错误。

3) 管理好观察者的注册与注销

原则：提供清晰的方法来管理观察者的订阅和取消订阅，避免内存泄漏或无效引用。

实践：在主题中维护观察者列表，并确保添加和移除观察者的操作是安全的。使用智能指针等机制管理资源，以自动处理生命周期问题。

4) 优化通知过程中的性能与异常处理

原则：观察者在接收通知并执行更新操作时，应避免执行耗时长或复杂度高的操作，同时允许观察者处理更新过程中可能遇到的异常。

实践：观察者的更新方法中主要进行状态同步或轻量级处理，如果需要执行复杂操作，应考虑异步处理或将任务推送到工作队列。在更新方法中添加异常处理逻辑，确保异常不会传播回主题。

遵循这些规则可以帮助开发者有效地实现观察者模式，同时确保模式的应用可以为系统带来预期的设计益处。接下来，将探讨一些具体的应用场景，以及如何根据不同的需求调整观察者模式的实现策略。

观察者模式的应用场景

在 C++ 的实际应用中，观察者模式有许多具体的实例，其中一个非常著名且使用广泛的是 Qt 框架中的信号槽机制。此外，我们还可以看看其他领域中观察者模式的应用，比如事件处理系统和数据绑定。

1) Qt信号槽机制

Qt 框架是一个跨平台的 C++ 图形用户界面应用程序开发框架，广泛用于开发 GUI 应用程序。Qt 中的信号槽机制是观察者模式的一个具体实现，用于对象间的通信。
【示例展示】 
#include <QCoreApplication>
#include <QObject>
#include <QDebug>

class Button : public QObject {
    Q_OBJECT

public:
    Button() {}

signals:
    void clicked(); // 定义一个信号

public slots:
    void onClick() { // 定义响应信号的槽
        emit clicked(); // 发射信号
    }
};

class Application : public QObject {
    Q_OBJECT

public slots:
    void onButtonClicked() { // 定义用来响应按钮被单击的槽
        qDebug() << "Button was clicked!";
    }
};

int main(int argc, char *argv[]) {
    QCoreApplication app(argc, argv);

    Button button;
    Application application;
    QObject::connect(&button, &Button::clicked, &application, &Application::onButtonClicked);
    button.onClick(); // 模拟按钮被单击
    return app.exec(); // 启动事件循环
}

#include "main.moc" // moc 文件的包含（用于包含元对象代码）
在这个示例中，当按钮被单击时，它发出一个 clicked 信号，应用程序中的 onButtonClicked 槽会被调用以响应这个信号，从而实现了主题和观察者之间的解耦。

2) 事件处理系统

在很多现代 C++ 应用程序中，特别是在游戏开发和实时系统中，使用观察者模式来处理事件，如用户输入、文件更改通知或网络消息。

【示例展示】 
#include <map>
#include <string>
#include <vector>
#include <functional>
#include <iostream>

class EventManager {
    std::map<std::string, std::vector<std::function<void()>>> listeners;

public:
    void subscribe(const std::string& event, std::function<void()> callback) {
        listeners[event].push_back(callback);
    }

    void emit(const std::string& event) {
        for (auto& listener : listeners[event]) {
           listener(); // 通知所有监听者
       }
    }
};

void onKeyPressed() {
    std::cout << "Key Pressed Event Triggered!" << std::endl;
}

int main() {
    EventManager manager;
    manager.subscribe("keyPressed", onKeyPressed);
    manager.emit("keyPressed");
    return 0;
}
这个简单的事件处理系统允许用户注册事件监听器，并在事件发生时调用所有注册的回调函数。

上述两个例子展示了观察者模式在 C++ 中的灵活应用，帮助开发者构建可维护和可扩展的应用程序。通过这种模式，可以有效地将事件源（主题）与事件响应者（观察者）解耦，增强系统的整体设计。

相关文章