【C++ | 设计模式】观察者模式的详解与实现

2024-09-02 03:36

本文主要是介绍【C++ | 设计模式】观察者模式的详解与实现,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1.概念

观察者模式(Observer Pattern)是一种行为型设计模式,它的核心思想是定义对象间的一对多依赖关系,当一个对象的状态发生变化时,所有依赖于它的对象都会收到通知并自动更新。这个模式在现实生活中非常常见,比如新闻订阅、社交媒体的推送通知等。

举个简单的例子想象一下,你订阅了一个YouTube频道。当这个频道发布新视频时,你就会收到通知。这就是观察者模式的一个实际应用。YouTube频道相当于“被观察者”,你作为订阅者则是“观察者”。

2. 模式结构

UML结构图:

6c93ad72c2884daba9f1ec5bfb0cab29.png

  • Subject(被观察者/主题):持有对观察者的引用,可以增加、删除、通知观察者。当它的状态发生变化时,会主动通知所有的观察者。
  • Observer(观察者):定义一个接口,用于接收被观察者的通知并更新自身。当被观察者的状态变化时,观察者会接收到通知并执行相关操作。
  • ConcreteSubject(具体的被观察者):具体的被观察者对象,通常包含一些重要的数据,当数据发生变化时,会通知观察者。
  • ConcreteObserver(具体的观察者):具体的观察者对象,负责实现观察者接口,并在被观察者状态变化时作出响应。

工作流程

  1. 订阅/注册:观察者向被观察者注册自己,表示对其状态变化感兴趣。
  2. 状态改变:当被观察者的状态发生变化时,它会调用 notify() 方法,通知所有已注册的观察者。
  3. 通知/更新:观察者在接收到通知后,调用 update() 方法,从而获取被观察者的最新状态并更新自己的状态。

观察者模式的优点

  • 解耦:观察者和被观察者之间的依赖性很低,它们之间通过接口进行通信,可以轻松地添加、移除观察者,系统的可扩展性强。
  • 灵活性:可以在运行时动态地增加或移除观察者,观察者模式使得观察者的数量、种类都可以变化。
  • 一致性:被观察者可以保证所有观察者的状态和它自身的状态是一致的。

观察者模式的缺点

  • 性能开销:如果观察者数量众多,或者被观察者的状态更新频繁,通知所有观察者可能会带来较大的性能开销。
  • 通知顺序问题:在多个观察者的情况下,通知的顺序可能会影响程序的行为,而观察者模式通常不会对通知顺序做出严格规定。
  • 循环依赖风险:如果被观察者和观察者之间存在复杂的依赖关系,可能会导致循环更新或通知,从而引发问题。

适用场景

  • 状态变化的事件通知:当一个对象的状态变化需要通知其他对象时,例如用户界面的数据绑定。
  • 多级联动更新:多个对象之间需要保持一致性,例如在MVC架构中,模型数据变化需要通知视图更新。
  • 发布-订阅系统:例如消息推送系统,发布者发布消息后,所有订阅者都会收到通知。

现实生活中的例子

  • 新闻订阅:用户订阅某个新闻类别,当有新文章发布时,用户会收到通知。
  • 社交媒体:用户关注某个社交媒体账号,当该账号发布新内容时,用户会收到推送通知。
  • 气象站:气象站采集到新数据后,会通知所有的显示设备更新天气信息。

3.案例代码分析:

案例描述

假设我们有一个天气预报系统,系统有一个气象站(WeatherStation),它可以实时检测温度和湿度。用户可以通过不同的显示设备(如手机App、桌面小部件、电子看板等)查看天气信息。

当气象站检测到天气数据变化时,它会通知所有已注册的显示设备更新显示信息。这就是典型的观察者模式场景:气象站是“被观察者”,而显示设备是“观察者”。

代码实现

下面是使用C++实现的天气预报系统的观察者模式代码,包括详细注释。

#include <iostream>
#include <vector>
#include <algorithm>// 观察者接口:定义更新接口,用于接收通知
class Observer {
public:virtual void update(float temperature, float humidity) = 0;  // 更新函数,接收温度和湿度
};// 被观察者接口:定义注册、移除、通知观察者的方法
class Subject {
public:virtual void registerObserver(Observer* o) = 0;  // 注册观察者virtual void removeObserver(Observer* o) = 0;    // 移除观察者virtual void notifyObservers() = 0;              // 通知所有观察者
};// 具体的被观察者:气象站
class WeatherStation : public Subject {
private:std::vector<Observer*> observers;  // 观察者列表float temperature;                 // 当前温度float humidity;                    // 当前湿度public:// 注册观察者void registerObserver(Observer* o) override {observers.push_back(o);}// 移除观察者void removeObserver(Observer* o) override {observers.erase(std::remove(observers.begin(), observers.end(), o), observers.end());}// 通知所有观察者void notifyObservers() override {for (Observer* observer : observers) {observer->update(temperature, humidity);  // 通知每个观察者更新}}// 模拟天气数据的更新void setMeasurements(float temp, float hum) {temperature = temp;humidity = hum;notifyObservers();  // 数据更新后通知观察者}
};// 具体的观察者1:手机App显示器
class PhoneDisplay : public Observer {
public:void update(float temperature, float humidity) override {std::cout << "Phone Display - Temperature: " << temperature << "°C, Humidity: " << humidity << "%\n";}
};// 具体的观察者2:桌面小部件
class DesktopWidget : public Observer {
public:void update(float temperature, float humidity) override {std::cout << "Desktop Widget - Temperature: " << temperature << "°C, Humidity: " << humidity << "%\n";}
};// 具体的观察者3:电子看板
class ElectronicBillboard : public Observer {
public:void update(float temperature, float humidity) override {std::cout << "Electronic Billboard - Temperature: " << temperature << "°C, Humidity: " << humidity << "%\n";}
};int main() {WeatherStation weatherStation;  // 创建气象站对象PhoneDisplay phoneDisplay;      // 创建观察者对象:手机App显示器DesktopWidget desktopWidget;    // 创建观察者对象:桌面小部件ElectronicBillboard billboard;  // 创建观察者对象:电子看板weatherStation.registerObserver(&phoneDisplay);   // 注册观察者到气象站weatherStation.registerObserver(&desktopWidget);weatherStation.registerObserver(&billboard);// 模拟天气数据的更新weatherStation.setMeasurements(25.0f, 65.0f);weatherStation.setMeasurements(30.5f, 70.0f);// 移除一个观察者,模拟观察者取消订阅的情况weatherStation.removeObserver(&desktopWidget);// 再次更新天气数据,观察剩余观察者的反应weatherStation.setMeasurements(28.0f, 55.0f);return 0;
}

 

 

这篇关于【C++ | 设计模式】观察者模式的详解与实现的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1128882

相关文章

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配

PHP轻松处理千万行数据的方法详解

《PHP轻松处理千万行数据的方法详解》说到处理大数据集,PHP通常不是第一个想到的语言,但如果你曾经需要处理数百万行数据而不让服务器崩溃或内存耗尽,你就会知道PHP用对了工具有多强大,下面小编就... 目录问题的本质php 中的数据流处理:为什么必不可少生成器:内存高效的迭代方式流量控制:避免系统过载一次性

Python的Darts库实现时间序列预测

《Python的Darts库实现时间序列预测》Darts一个集统计、机器学习与深度学习模型于一体的Python时间序列预测库,本文主要介绍了Python的Darts库实现时间序列预测,感兴趣的可以了解... 目录目录一、什么是 Darts?二、安装与基本配置安装 Darts导入基础模块三、时间序列数据结构与

C++右移运算符的一个小坑及解决

《C++右移运算符的一个小坑及解决》文章指出右移运算符处理负数时左侧补1导致死循环,与除法行为不同,强调需注意补码机制以正确统计二进制1的个数... 目录我遇到了这么一个www.chinasem.cn函数由此可以看到也很好理解总结我遇到了这么一个函数template<typename T>unsigned

Python使用FastAPI实现大文件分片上传与断点续传功能

《Python使用FastAPI实现大文件分片上传与断点续传功能》大文件直传常遇到超时、网络抖动失败、失败后只能重传的问题,分片上传+断点续传可以把大文件拆成若干小块逐个上传,并在中断后从已完成分片继... 目录一、接口设计二、服务端实现(FastAPI)2.1 运行环境2.2 目录结构建议2.3 serv

C#实现千万数据秒级导入的代码

《C#实现千万数据秒级导入的代码》在实际开发中excel导入很常见,现代社会中很容易遇到大数据处理业务,所以本文我就给大家分享一下千万数据秒级导入怎么实现,文中有详细的代码示例供大家参考,需要的朋友可... 目录前言一、数据存储二、处理逻辑优化前代码处理逻辑优化后的代码总结前言在实际开发中excel导入很

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot?二、环境准备与部署2.1 安装 RustF

Nginx部署HTTP/3的实现步骤

《Nginx部署HTTP/3的实现步骤》本文介绍了在Nginx中部署HTTP/3的详细步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学... 目录前提条件第一步:安装必要的依赖库第二步:获取并构建 BoringSSL第三步:获取 Nginx

MySQL的JDBC编程详解

《MySQL的JDBC编程详解》:本文主要介绍MySQL的JDBC编程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言一、前置知识1. 引入依赖2. 认识 url二、JDBC 操作流程1. JDBC 的写操作2. JDBC 的读操作总结前言本文介绍了mysq

MyBatis Plus实现时间字段自动填充的完整方案

《MyBatisPlus实现时间字段自动填充的完整方案》在日常开发中,我们经常需要记录数据的创建时间和更新时间,传统的做法是在每次插入或更新操作时手动设置这些时间字段,这种方式不仅繁琐,还容易遗漏,... 目录前言解决目标技术栈实现步骤1. 实体类注解配置2. 创建元数据处理器3. 服务层代码优化填充机制详