C++设计模式——Observer观察者模式

2024-09-04 09:52
文章标签 c++ 设计模式 模式 观察者 observer

本文主要是介绍C++设计模式——Observer观察者模式，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一，观察者模式的定义

观察者模式是一种行为型设计模式，又被称为"发布-订阅"模式，它定义了对象之间的一对多的依赖关系，当一个对象的状态发生变化时，所有依赖于它的对象都会收到通知并自动更新。

观察者模式的关注点是对象之间的通信以及被观察对象的状态。

观察者模式在现实生活中的抽象实例：

报纸订阅：报纸的内容发生变化时，订阅了该报纸的读者们都会收到通知并阅读最新的内容。

股票投资：股票的价格发生波动时，投资者们会根据最新价格修改相应的投资决策。

天气预报：当天气发生变化时，订阅了该服务的用户们会收到通知。

网络论坛：当论坛中有新的帖子或回复出现时，论坛的用户们会收到通知并可以参与讨论。

二，观察者模式的结构

观察者模式主要包含以下组件：

1.被观察者(Subject)：

被观察的对象，它的内部包含了观察者对象的集合，并提供了添加、通知和删除观察者对象的统一接口。

2.观察者(Observer)：

接收Subject通知的对象，它订阅了Subject的状态，并提供了更新操作的统一接口。

3.具体的被观察者(ConcreteSubject)：

包含Subject类接口的具体实现，维护了观察者的列表，自身状态发生变化时通知所有的观察者。

4.具体的观察者(ConcreteObserver)：

包含Observer类接口的具体实现，提供了更新操作的具体实现细节，一旦收到Subject的通知便进行更新操作。

组件之间的工作步骤如下：

1.被观察者维护一个观察者的列表，并提供了管理和通知观察者的方法。

2.观察者与被观察者绑定(attach)，并将自己添加到观察者列表中。

3.当被观察者的状态发生变化时，开始通知观察者，通知的方式一般是遍历观察者列表，遍历时会调用每个观察者的更新方法。

4.观察者完成具体的更新操作。

对应UML类图：

三，观察者模式代码样例

Demo1：subject只完成通知

#include <iostream>
#include <vector>class Observer {
public:virtual void update() = 0;
};class ConcreteObserver : public Observer {
public:ConcreteObserver(std::string name){observer_name = name;}void update() {std::cout << observer_name <<  " received notify." << std::endl;}
private:std::string observer_name = "";
};class Subject {
private://观察者集合std::vector<Observer*> observers;
public://添加观察者void attach(Observer* observer) {observers.push_back(observer);}//移除观察者void detach(Observer* observer) {for (auto it = observers.begin(); it != observers.end(); ++it) {if (*it == observer) {observers.erase(it);break;}}}//通知观察者void notify() {for (auto observer : observers) {observer->update();}}
};int main() {Subject subject;ConcreteObserver observer1("observer_1");ConcreteObserver observer2("observer_2");subject.attach(&observer1);subject.attach(&observer2);subject.notify();subject.detach(&observer2);subject.notify();return 0;
}

运行结果：

observer_1 received notify.
observer_2 received notify.
observer_1 received notify.

Demo2：subject完成通知并传参

#include <iostream>
#include <vector>class Observer {
public:virtual void update(int data) = 0;
};class ConcreteObserver : public Observer {
public:ConcreteObserver(std::string name){observer_name = name;}void update(int data) override {std::cout << observer_name << " received data: " << data << std::endl;}
private:std::string observer_name = "";
};class Subject {
public:virtual void attach(Observer* observer) = 0;virtual void detach(Observer* observer) = 0;virtual void notify(int data) = 0;
};class ConcreteSubject : public Subject {
private:std::vector<Observer*> observers;
public:void attach(Observer* observer) override {observers.push_back(observer);}void detach(Observer* observer) override {for (auto it = observers.begin(); it != observers.end(); ++it) {if (*it == observer) {observers.erase(it);break;}}}void notify(int data) override {for (auto observer : observers) {observer->update(data);}}
};int main() {ConcreteSubject subject;ConcreteObserver observer1("observer_1");ConcreteObserver observer2("observer_2");ConcreteObserver observer3("observer_3");subject.attach(&observer1);subject.attach(&observer2);subject.attach(&observer3);subject.notify(30);subject.detach(&observer1);subject.detach(&observer2);subject.notify(40);return 0;
}

运行结果：

observer_1 received data: 30
observer_2 received data: 30
observer_3 received data: 30
observer_3 received data: 40

四，观察者模式的应用场景

事件驱动编程：GUI界面开发时，监听用户在界面的各种操作，如按钮点击、窗口关闭等。
监控服务开发：当系统状态发生变化时（例如磁盘空间不足），工具会收到通知。
消息队列开发：基于"消费者-生产者"模式进行通信，当消息队列中有新的消息时，消费者会收到通知。

五，观察者模式的优缺点

观察者模式的优点：
符合"开闭原则"的要求。
支持广播的通信方式。
支持事件驱动编程。
可以动态添加观察者，代码扩展性好。
观察者模式的缺点：
每次状态变化都要遍历所有观察者，性能开销大。
每次状态变化都要通知所有的观察者，通信时间变长。
观察者数量过多会使代码的可读性变差。
当有多个客户端操作观察者的删除时，会带来数据安全问题。

六，代码实战

Demo1：基于观察者模式实现的模拟时钟定时 
#include <iostream>
#include <vector>class Subject;class Observer
{
public:virtual ~Observer() = default;virtual void Update(Subject&) = 0;
};class Subject
{
public:virtual ~Subject() = default;void Attach(Observer& o) { observers.push_back(&o); }void Detach(Observer& o){observers.erase(std::remove(observers.begin(), observers.end(), &o));}void Notify(){for (auto* o : observers) {o->Update(*this);}}
private:std::vector<Observer*> observers;
};class ClockTimer : public Subject
{
public:void SetTime(int hour, int minute, int second){this->hour = hour;this->minute = minute;this->second = second;Notify();}int GetHour() const { return hour; }int GetMinute() const { return minute; }int GetSecond() const { return second; }
private:int hour;int minute;int second;
};class DigitalClock : public Observer
{
public:explicit DigitalClock(ClockTimer& s) : subject(s) { subject.Attach(*this); }~DigitalClock() { subject.Detach(*this); }void Update(Subject& theChangedSubject) override{if (&theChangedSubject == &subject) {Draw();}}void Draw(){int hour = subject.GetHour();int minute = subject.GetMinute();int second = subject.GetSecond();std::cout << "Digital time is " << hour << ":"<< minute << ":"<< second << std::endl;}
private:ClockTimer& subject;
};class AnalogClock : public Observer
{
public:explicit AnalogClock(ClockTimer& s) : subject(s) { subject.Attach(*this); }~AnalogClock() { subject.Detach(*this); }void Update(Subject& theChangedSubject) override{if (&theChangedSubject == &subject) {Draw();}}void Draw(){int hour = subject.GetHour();int minute = subject.GetMinute();int second = subject.GetSecond();std::cout << "Analog time is " << hour << ":"<< minute << ":"<< second << std::endl;}
private:ClockTimer& subject;
};int main()
{ClockTimer timer;DigitalClock digitalClock(timer);AnalogClock analogClock(timer);timer.SetTime(14, 41, 36);timer.SetTime(18, 00, 00);
}

运行结果：

Digital time is 14:41:36
Analog time is 14:41:36
Digital time is 18:0:0
Analog time is 18:0:0

Demo2：基于观察者模式实现的模拟天气预报

#include <iostream>
#include <vector>class Observer {
public:virtual void update(float temperature, float humidity, float pressure) = 0;
};class WeatherStation {
private:float temperature;float humidity;float pressure;std::vector<Observer*> observers;
public:void registerObserver(Observer* observer) {observers.push_back(observer);}void removeObserver(Observer* observer) {}void notifyObservers() {for (Observer* observer : observers) {observer->update(temperature, humidity, pressure);}}void setMeasurements(float temp, float hum, float press) {temperature = temp;humidity = hum;pressure = press;notifyObservers();}
};class Display : public Observer {
public:void update(float temperature, float humidity, float pressure) {std::cout<< " Display: Temperature = " << temperature<< " °C, Humidity = " << humidity<< " %, Pressure = " << pressure << " hPa"<< std::endl;}
};int main() {WeatherStation weatherStation;Display display1;Display display2;weatherStation.registerObserver(&display1);weatherStation.registerObserver(&display2);weatherStation.setMeasurements(25.5, 60, 1013.2);weatherStation.setMeasurements(24.8, 58, 1014.5);return 0;
}

运行结果：

Display: Temperature = 25.5 °C, Humidity = 60 %, Pressure = 1013.2 hPa
Display: Temperature = 25.5 °C, Humidity = 60 %, Pressure = 1013.2 hPa
Display: Temperature = 24.8 °C, Humidity = 58 %, Pressure = 1014.5 hPa
Display: Temperature = 24.8 °C, Humidity = 58 %, Pressure = 1014.5 hPa

七，参考阅读

https://sourcemaking.com/design_patterns/observer
https://www.modernescpp.com/index.php/the-observer-pattern/
https://www.geeksforgeeks.org/observer-pattern-c-design-patterns/
https://refactoringguru.cn/design-patterns/observer

这篇关于C++设计模式——Observer观察者模式的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1135689。

相关文章

C++中RAII资源获取即初始化

C++中RAII资源获取即初始化

《C++中RAII资源获取即初始化》RAII通过构造/析构自动管理资源生命周期,确保安全释放,本文就来介绍一下C++中的RAII技术及其应用,具有一定的参考价值,感兴趣的可以了解一下... 目录一、核心原理与机制二、标准库中的RAII实现三、自定义RAII类设计原则四、常见应用场景1. 内存管理2. 文件操
阅读更多...
C++中零拷贝的多种实现方式

C++中零拷贝的多种实现方式

《C++中零拷贝的多种实现方式》本文主要介绍了C++中零拷贝的实现示例,旨在在减少数据在内存中的不必要复制,从而提高程序性能、降低内存使用并减少CPU消耗,零拷贝技术通过多种方式实现,下面就来了解一下... 目录一、C++中零拷贝技术的核心概念二、std::string_view 简介三、std::stri
阅读更多...
C++高效内存池实现减少动态分配开销的解决方案

C++高效内存池实现减少动态分配开销的解决方案

《C++高效内存池实现减少动态分配开销的解决方案》C++动态内存分配存在系统调用开销、碎片化和锁竞争等性能问题,内存池通过预分配、分块管理和缓存复用解决这些问题,下面就来了解一下... 目录一、C++内存分配的性能挑战二、内存池技术的核心原理三、主流内存池实现：TCMalloc与Jemalloc1. TCM
阅读更多...
Redis Cluster模式配置

Redis Cluster模式配置

《RedisCluster模式配置》：本文主要介绍RedisCluster模式配置,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录分片 一、分片的本质与核心价值二、分片实现方案对比 ‌三、分片算法详解1. ‌范围分片（顺序分片）‌2. ‌哈希分片3. ‌虚
阅读更多...
C++ 函数 strftime 和时间格式示例详解

C++ 函数 strftime 和时间格式示例详解

《C++函数strftime和时间格式示例详解》strftime是C/C++标准库中用于格式化日期和时间的函数,定义在ctime头文件中,它将tm结构体中的时间信息转换为指定格式的字符串,是处理... 目录C++ 函数 strftipythonme 详解一、函数原型二、功能描述三、格式字符串说明四、返回值五
阅读更多...
C++作用域和标识符查找规则详解

C++作用域和标识符查找规则详解

《C++作用域和标识符查找规则详解》在C++中,作用域（Scope）和标识符查找（IdentifierLookup）是理解代码行为的重要概念,本文将详细介绍这些规则,并通过实例来说明它们的工作原理,需... 目录作用域标识符查找规则1. 普通查找（Ordinary Lookup）2. 限定查找（Qualif
阅读更多...
C/C++ chrono简单使用场景示例详解

C/C++ chrono简单使用场景示例详解

《C/C++chrono简单使用场景示例详解》：本文主要介绍C/C++chrono简单使用场景示例详解,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友... 目录chrono使用场景举例1 输出格式化字符串chrono使用场景China编程举例1 输出格式化字符串示
阅读更多...
C++/类与对象/默认成员函数@构造函数的用法

C++/类与对象/默认成员函数@构造函数的用法

《C++/类与对象/默认成员函数@构造函数的用法》：本文主要介绍C++/类与对象/默认成员函数@构造函数的用法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录名词概念默认成员函数构造函数概念函数特征显示构造函数隐式构造函数总结名词概念默认构造函数：不用传参就可以
阅读更多...
C++类和对象之默认成员函数的使用解读

C++类和对象之默认成员函数的使用解读

《C++类和对象之默认成员函数的使用解读》：本文主要介绍C++类和对象之默认成员函数的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、默认成员函数有哪些二、各默认成员函数详解默认构造函数析构函数拷贝构造函数拷贝赋值运算符三、默认成员函数的注意事项总结一
阅读更多...
RabbitMQ工作模式中的RPC通信模式详解

RabbitMQ工作模式中的RPC通信模式详解

《RabbitMQ工作模式中的RPC通信模式详解》在RabbitMQ中,RPC模式通过消息队列实现远程调用功能,这篇文章给大家介绍RabbitMQ工作模式之RPC通信模式,感兴趣的朋友一起看看吧... 目录RPC通信模式概述工作流程代码案例引入依赖常量类编写客户端代码编写服务端代码RPC通信模式概述在R
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2