首页 关于我们 成功案例 网络营销 电商设计 新闻中心 联系方式
QQ联系
电话联系
手机联系

C++如何实现观察者设计模式_C++中实现对象间发布-订阅的经典模式

发布时间:2025-11-23 17:49
发布者:网络
浏览次数:
观察者模式通过定义一对多依赖实现对象间松耦合通信,当被观察者状态变化时自动通知所有观察者。示例中TemperatureSensor作为Subject维护Observer列表并触发notify,Display和Logger作为具体观察者重写update响应温度变化,主函数注册监听并模拟数据更新,验证了事件广播机制的正确性与动态解绑功能。

c++如何实现观察者设计模式_c++中实现对象间发布-订阅的经典模式

观察者模式是一种行为设计模式,用于在对象之间定义一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都会自动收到通知。这种模式广泛应用于事件处理系统、GUI组件、消息订阅机制等场景。在C++中,可以通过抽象基类与指针(或智能指针)结合的方式优雅地实现发布-订阅机制。

定义观察者与被观察者接口

为了实现松耦合,首先需要定义两个核心角色:观察者(Observer)和被观察者(Subject)。观察者通过继承统一接口,实现更新方法;被观察者维护观察者列表,并在状态变化时通知它们。

示例代码:

Observer.h

class Subject;
<p>class Observer {
public:
virtual ~Observer() = default;
virtual void update() = 0;  // 当被观察者状态改变时调用
};</p>

Subject.h

#include <vector>
#include <algorithm>
#include "Observer.h"
<p>class Subject {
private:
std::vector<Observer*> observers;</p><p>public:
void attach(Observer* obs) {
observers.push_back(obs);
}</p><pre class='brush:php;toolbar:false;'>void detach(Observer* obs) {
    observers.erase(
        std::remove(observers.begin(), observers.end(), obs),
        observers.end()
    );
}

void notify() {
    for (auto* obs : observers) {
        obs->update();
    }
}

};

实现具体观察者与被观察者

接下来创建具体的被观察者类(如TemperatureSensor)和多个具体观察者(如Display、Logger),它们根据通知执行各自逻辑。

示例代码:

TemperatureSensor.h

#include "Subject.h"
<p>class TemperatureSensor : public Subject {
private:
double temperature;</p><p>public:
void setTemperature(double temp) {
temperature = temp;
notify();  // 状态改变,通知所有观察者
}</p><pre class='brush:php;toolbar:false;'>double getTemperature() const {
    return temperature;
}

};

Display.h

PictoGraphic PictoGraphic

AI驱动的矢量插图库和插图生成平台

PictoGraphic 133 查看详情 PictoGraphic
#include "Observer.h"
#include "TemperatureSensor.h"
#include <iostream>
<p>class Display : public Observer {
private:
TemperatureSensor* sensor;</p><p>public:
explicit Display(TemperatureSensor* s) : sensor(s) {}</p><pre class='brush:php;toolbar:false;'>void update() override {
    std::cout << "Display: Current temperature is " 
              << sensor->getTemperature() << "°C\n";
}

};

Logger.h

#include "Observer.h"
#include "TemperatureSensor.h"
#include <iostream>
<p>class Logger : public Observer {
private:
TemperatureSensor* sensor;</p><p>public:
explicit Logger(TemperatureSensor* s) : sensor(s) {}</p><pre class='brush:php;toolbar:false;'>void update() override {
    std::cout << "Log: Temperature updated to " 
              << sensor->getTemperature() << "°C at " 
              << /* 模拟时间戳 */ "12:00:00" << "\n";
}

};

使用示例与注意事项

在主程序中注册观察者,模拟数据变化,验证通知机制是否正常工作。

main.cpp

#include "TemperatureSensor.h"
#include "Display.h"
#include "Logger.h"
<p>int main() {
TemperatureSensor sensor;
Display display(&sensor);
Logger logger(&sensor);</p><pre class='brush:php;toolbar:false;'>sensor.attach(&display);
sensor.attach(&logger);

sensor.setTemperature(25.5);  // 触发通知
sensor.setTemperature(27.0);  // 再次通知

sensor.detach(&display);      // 移除某个观察者
sensor.setTemperature(29.5);  // 只有Logger收到通知

return 0;

}

输出结果:

Display: Current temperature is 25.5°C
Log: Temperature updated to 25.5°C at 12:00:00
Display: Current temperature is 27.0°C
Log: Temperature updated to 27.0°C at 12:00:00
Log: Temperature updated to 29.5°C at 12:00:00

注意点:

  • 被观察者持有观察者的原始指针,需确保观察者生命周期长于被观察者,避免悬空指针。
  • 可改用 std::weak_ptr 配合 std::shared_ptr 管理生命周期,更安全。
  • notify() 过程中若允许动态增删观察者,应考虑线程安全或使用副本遍历。
  • update() 接口可根据需求扩展参数,例如传递具体变化的数据,而非强制查询。

基本上就这些。这个模式在C++中虽无语言级支持,但通过面向对象设计能清晰表达发布-订阅逻辑,适合中小型系统解耦。

以上就是C++如何实现观察者设计模式_C++中实现对象间发布-订阅的经典模式的详细内容,更多请关注其它相关文章!


# go  # ai  # c++  # ios  # stream  # red  # 如何实现  # 都是  # 面向对象  # 何为  # 管理机制  # 多路  # 复用  # 是一种  # 多个  # 主程序  # 曲靖网站推广外包  # 抖音如何创建营销推广  # 热点数据类网站排名优化  # 南宁推广网站推荐  # 烧饼营销推广方案  # 微推广营销方案案例分享  # 张家界市网站seo优化排名  # 广州网站制作公司优化  # 安达医院网站建设  # 网站建设新闻文案怎么写