重温设计模式--观察者模式

文章目录

  • 观察者模式(Observer Pattern)概述
  • 观察者模式UML图
  • 作用:
    • 实现对象间的解耦
    • 支持一对多的依赖关系
    • 易于维护和扩展
  • 观察者模式的结构
    • 抽象主题(Subject):
    • 具体主题(Concrete Subject):
    • 抽象观察者(Observer):
    • 具体观察者(Concrete Observer):
  • C++ 代码示例1
  • C++代码示例2

观察者模式(Observer Pattern)概述

定义:
观察者模式又被称作发布 - 订阅模式,它是一种行为型设计模式。在这种模式中,存在一个被观察的对象(主题,Subject)以及多个对该主题状态变化感兴趣的观察者(Observer)对象。当主题的状态发生改变时,它会主动通知所有已注册的观察者,观察者们可以根据收到的通知做出相应的响应,从而实现对象之间的一种松耦合的交互关系。

观察者模式:定义了一种一对多的依赖关系,让多个观察者对象同时监听同一主题对象,当这个主题对象发生变化时,能够通知到所有观察者,使他们能够自动更新自己

观察者模式UML图

在这里插入图片描述

作用:

实现对象间的解耦

主题对象和观察者对象之间相互依赖的关系比较松散,主题只负责在自身状态改变时通知观察者,而不用关心观察者具体会做什么操作;观察者也只需要关注主题的通知,不用了解主题内部状态变化的具体实现细节,这样使得它们可以独立地进行修改和扩展,降低了代码的耦合度。

支持一对多的依赖关系

一个主题可以有多个观察者关注它的状态变化,当主题状态更新时,能同时通知到所有相关的观察者,方便实现一些需要多方响应的业务场景,比如在一个股票交易系统中,当某支股票价格变化(主题状态改变),多个关注该股票的股民客户端(观察者)都能及时收到通知并做出相应决策。

易于维护和扩展

如果要新增观察者或者改变主题的通知逻辑等,相对来说比较容易实现,对其他部分的代码影响较小,能够灵活应对业务需求的变化。

观察者模式的结构

抽象主题(Subject):

它定义了注册、移除观察者以及通知观察者等方法的接口,维护了一个观察者列表,用于记录所有注册的观察者对象,当自身状态改变时,通过调用通知方法来告知所有观察者。

具体主题(Concrete Subject):

实现了抽象主题中定义的接口,具体管理观察者的注册和移除操作,并且在自身内部状态发生变化时,按照约定的通知机制去通知所有已注册的观察者。它持有自身实际的业务数据和状态信息。

抽象观察者(Observer):

定义了一个更新(update)方法的接口,当接收到主题的通知时,具体的观察者实现类会通过这个方法来执行相应的业务逻辑,以对主题状态变化做出响应。

具体观察者(Concrete Observer):

实现了抽象观察者中定义的更新方法,在该方法中编写具体的业务逻辑,明确在收到主题通知后自身要进行的操作,比如更新界面显示、进行数据记录等操作。

C++ 代码示例1

以下是一个简单的基于观察者模式的示例代码,模拟一个气象站发布天气数据,多个客户端(观察者)接收并处理天气信息的场景:

#include <iostream>
#include <vector>// 抽象观察者
class Observer
{
public:virtual void update(float temperature, float humidity, float pressure) = 0;
};// 抽象主题
class Subject 
{
public:virtual void registerObserver(Observer* o) = 0;virtual void removeObserver(Observer* o) = 0;virtual void notifyObservers() = 0;
};// 具体主题,气象站数据
class WeatherData : public Subject 
{
private:float temperature;float humidity;float pressure;std::vector<Observer*> observers;
public:void registerObserver(Observer* o) {observers.push_back(o);}void removeObserver(Observer* o){for (std::vector<Observer*>::iterator it = observers.begin(); it!= observers.end(); ++it){if (*it == o){observers.erase(it);break;}}}void notifyObservers(){for (std::vector<Observer*>::iterator it = observers.begin(); it!= observers.end(); ++it){(*it)->update(temperature, humidity, pressure);}}void setMeasurements(float temperature, float humidity, float pressure){this->temperature = temperature;this->humidity = humidity;this->pressure = pressure;notifyObservers();}
};// 具体观察者,例如手机客户端显示天气数据
class MobileApp : public Observer
{
private:float temperature;float humidity;float pressure;
public:void update(float temperature, float humidity, float pressure){this->temperature = temperature;this->humidity = humidity;this->pressure = pressure;display();}void display(){std::cout << "Mobile App: Temperature = " << temperature << "°C, Humidity = " << humidity << "%, Pressure = " << pressure << "hPa" << std::endl;}
};// 另一个具体观察者,网页端显示天气数据
class WebPage : public Observer
{
private:float temperature;float humidity;float pressure;
public:void update(float temperature, float humidity, float pressure){this->temperature = temperature;this->humidity = humidity;this->pressure = pressure;showData();}void showData() {std::cout << "Web Page: Temperature = " << temperature << "°C, Humidity = " << humidity << "%, Pressure = " << pressure << "hPa" << std::endl;}
};int main() 
{WeatherData weatherData;MobileApp mobileApp;WebPage webPage;weatherData.registerObserver(&mobileApp);weatherData.registerObserver(&webPage);weatherData.setMeasurements(25.0, 60.0, 1013.0);weatherData.removeObserver(&mobileApp);weatherData.setMeasurements(26.0, 55.0, 1015.0);return 0;
}

在上述代码中:
Observer是抽象观察者,规定了update方法接口,用于接收主题状态变化的通知并处理。
Subject是抽象主题,定义了注册、移除观察者以及通知观察者等相关接口。
WeatherData作为具体主题,管理着观察者列表,当调用setMeasurements方法改变内部天气数据状态时,会通过notifyObservers方法通知所有已注册的观察者。
MobileApp和WebPage是具体观察者,实现了update方法,在接收到气象站(主题)的通知后,各自通过不同的显示方法(display和showData)来展示更新后的天气数据。在main函数中演示了观察者的注册、主题状态更新通知以及观察者移除等操作流程,体现了观察者模式的基本应用场景。

C++代码示例2

//观察者
#include<iostream>
#include<list>
using namespace std;
//观察者模式(Observer),又叫发布-订阅模式(Publish/Subscribe),定义对象间一种一对多的依赖关系,
//使得每当一个对象改变状态,则所有依赖于它的对象都会得到通知并自动更新class USER
{
public:virtual void Update(){}
};
class USERLI:public USER
{void Update(){cout<<"我是小李,我去看华为博客了"<<endl;}
};class USERWANG:public USER
{void Update(){cout<<"我是小王,我去看华为博客了"<<endl;}
};class BLOG
{
public:list<USER*> m_list;//保存观察者(就是关注我博客的用户)//记录观察者void AddUser(USER *p_user){m_list.push_back(p_user);}void ReMoveUser(USER *p_user){m_list.remove(p_user);}//开始通知所有我的观察者void NotiFy(){list<USER*>::iterator itr = m_list.begin();for(;itr!=m_list.end();++itr){(*itr)->Update();}}
};//华为博客
class BLOG_HUAWEI:public BLOG
{
public:void WriteBlogOk(){NotiFy();}
};int main()
{BLOG_HUAWEI huawei;USERLI *xiaoli = new USERLI();USERWANG *xiaowang =new USERWANG();huawei.AddUser(xiaowang);huawei.AddUser(xiaoli);huawei.WriteBlogOk();//这个时间点触发通知return 0;
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/495804.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【更新】Docker新手入门教程2:在Windows系统通过compose创建多个mysql镜像并配置应用

文章目录 前言一、运行Docker init生成docker配置文件二、修改创建镜像的配置文件1、添加镜像挂载点 三、【拉取镜像】四、生成Docker 镜像查看生成的镜像 五、修改Compose配置文件3、配置Mysql六、生成Docker容器七、检查容器创建状态总结 前言 在window下通过Docker创建mysq…

lxml 解析xml\html

from lxml import etree# XML文档示例 xml_doc """ <root><book><title>Python编程指南</title><author>张三</author></book><book><title>Python高级编程</title><author>李四</autho…

FFmpeg在python里推流被处理过的视频流

链式算法处理视频流 视频源是本地摄像头 # codinggbk # 本地摄像头直接推流到 RTMP 服务器 import cv2 import mediapipe as mp import subprocess as sp# 初始化 Mediapipe mp_drawing mp.solutions.drawing_utils mp_drawing_styles mp.solutions.drawing_styles mp_holis…

从零开始k8s-部署篇(未完待续)

从零开始k8s 1.部署k8s-部署篇 1.部署k8s-部署篇 本次部署完全学习于华子的博客点击此处进入华子主页 K8S中文官网&#xff1a;https://kubernetes.io/zh-cn 笔者从零开始部署的k8s&#xff0c;部署前置条件为 1.需要harbor仓库&#xff0c;存放镜像&#xff0c;拉取镜像&am…

Pytorch | 利用AI-FGTM针对CIFAR10上的ResNet分类器进行对抗攻击

Pytorch | 利用AI-FGTM针对CIFAR10上的ResNet分类器进行对抗攻击 CIFAR数据集AI-FGTM介绍算法流程初始化迭代更新&#xff08; t 0 t 0 t0 到 T − 1 T - 1 T−1&#xff09;迭代完成 AI-FGTM代码实现AI-FGTM算法实现攻击效果 代码汇总aifgtm.pytrain.pyadvtest.py 之前已经…

视频监控平台:Liveweb视频汇聚融合平台智慧安防视频监控应用方案

Liveweb是一款功能强大、灵活部署的安防视频监控平台&#xff0c;支持多种主流标准协议&#xff0c;包括GB28181、RTSP/Onvif、RTMP等&#xff0c;同时兼容海康Ehome、海大宇等厂家的私有协议和SDK接入。该平台不仅提供传统安防监控功能&#xff0c;还支持接入AI智能分析&#…

【Linux系列】Shell 脚本中的条件判断:`[ ]`与`[[ ]]`的比较

&#x1f49d;&#x1f49d;&#x1f49d;欢迎来到我的博客&#xff0c;很高兴能够在这里和您见面&#xff01;希望您在这里可以感受到一份轻松愉快的氛围&#xff0c;不仅可以获得有趣的内容和知识&#xff0c;也可以畅所欲言、分享您的想法和见解。 推荐:kwan 的首页,持续学…

【LLM论文日更】| 训练大型语言模型在连续潜在空间中进行推理

论文&#xff1a;https://arxiv.org/pdf/2412.06769代码&#xff1a;暂未开源机构 &#xff1a;Meta领域&#xff1a;思维链发表&#xff1a;arxiv 研究背景 研究问题&#xff1a;这篇文章要解决的问题是如何在大语言模型&#xff08;LLMs&#xff09;中实现一种新的推理范式&…

opc da 服务器数据 转 opc ua项目案例

目录 1 案例说明 2 VFBOX网关工作原理 3 应用条件 4 查看OPC DA服务器的相关参数 5 配置网关采集opc da数据 6 用opc ua协议转发采集的数据 7 在服务器上运行仰科OPC DA采集软件 8 案例总结 1 案例说明 在OPC DA服务器上运行OPC DA client软件查看OPC DA服务器的相关参…

05.HTTPS的实现原理-HTTPS的握手流程(TLS1.2)

05.HTTPS的实现原理-HTTPS的握手流程&#xff08;TLS1.2&#xff09; 简介1. TLS握手过程概述2. TLS握手过程细化3. 主密钥&#xff08;对称密钥&#xff09;生成过程4. 密码规范变更 简介 主要讲述了混合加密流程完成后&#xff0c;客户端和服务器如何共同获得相同的对称密钥…

Excel粘贴复制不完整的原因以及解决方法

在数据处理和分析的过程中&#xff0c;Excel无疑是不可或缺的工具。然而&#xff0c;在使用Excel进行复制粘贴操作时&#xff0c;有时会遇到粘贴不完整的情况&#xff0c;这可能会让人感到困惑和烦恼。本文将深入探讨Excel粘贴复制不完整的原因、提供解决方案&#xff0c;并给出…

数据中台从centos升级为国产操作系统后,资源增加字段时,提交报500错误

文章目录 背景一、步骤1.分析阶段2.查看nginx3.修改用户&#xff08;也可以修改所有者权限&#xff09; 背景 故障报错&#xff1a; nginx报错信息&#xff1a; 2024/12/19 15:25:31 [crit, 500299#0: *249 onen0 " /var/lib/nginx/tmp/cient body/0000000001" f…

在Windows11上编译C#的实现Mono的步骤

在Windows11上编译Mono的步骤 1、 在win11打开开发者模式,在更新和安全选项里,如下图: 2、下载并安装64位的cygwin, 下载网站:www.cygwin.com 3、 安装 Visual Studio 2015 or later 的社区版本。 4、 下载Mono的windows最新版本。 5、 在cmd.exe里运行下面的命令来安…

我的创作纪念日(五年)

慕然回首 平平无奇的周一早晨&#xff0c;收到来自csdn的提醒&#xff0c;创作纪念日五周年了&#xff0c;这也意味着我从事开发行业差不多有整整五年了&#xff0c;五年啊&#xff01;你知道这五年我是怎么过的吗&#xff1f;一句Just do IT&#xff0c;我做it整整做了五年&am…

python+reportlab创建PDF文件

目录 字体导入 画布写入 创建画布对象 写入文本内容 写入图片内容 新增页 画线 表格 保存 模板写入 创建模板对象 段落及样式 表格及样式 画框 图片 页眉页脚 添加图形 构建pdf文件 reportlab库支持创建包含文本、图像、图形和表格的复杂PDF文档。 安装&…

人工智能ACA(七)——计算机视觉基础

一、自然语言处理基本介绍 1. 自然语言处理的定义 1-1 自然语言 人类使用的在社会生活中自然形成的语言 1-2 自然语言处理 目标是让计算机能够理解、解析、生成和处理人类的自然语言 包含自然语言理解和自然语言生成两部分组成 2. 自然语言处理的发展趋势 3.自然语言处理…

Ubuntu20.04 交叉编译Qt5.15.15 for rk3588

rk3588编译Qt搞了我大半年了&#xff0c;一直困惑特别鸣谢&#xff1a;qq1033878279的网友远程帮我编译演示了一遍。 一、vmware 安装基础工具 sudo apt install -y build-essential net-tools openssh-server vim openssl libssl-dev 二、vmware 下载 cmake和Qt源码 下载cm…

使用开源在线聊天工具Fiora轻松搭建个性化聊天平台在线交流

前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家&#xff1a;人工智能教程 文章目录 前言1.关于Fiora2.安装Docker3.本地部署Fiora4.使用Fiora5.cpolar内网穿透工具安装6.创建远程连接公网地址7.固定Uptime …

DDoS防护中的流量清洗与智能调度

DDoS防护中的流量清洗与智能调度有哪些好处 在数字化高度发展的今天&#xff0c;企业依赖于互联网进行业务运营&#xff0c;而网络安全威胁也随之增加。其中&#xff0c;DDoS&#xff08;分布式拒绝服务&#xff09;攻击是一种常见且破坏性极强的网络攻击手段。为了有效应对DDo…

“乡村探索者”:村旅游网站的移动应用开发

3.1 可行性分析 从三个不同的角度来分析&#xff0c;确保开发成功的前提是有可行性分析&#xff0c;只有进行提前分析&#xff0c;符合程序开发流程才不至于开发过程的中断。 3.1.1 技术可行性 在技术实现层次&#xff0c;分析了好几种技术实现方法&#xff0c;并且都有对应的成…