Java实现观察者模式
一、前言
观察者模式，又称为发布订阅模式，是一种行为设置模式，允许对象之间建立一对多的依赖关系，这样当一个对象状态改变时，它的所有依赖者（观察者）都会收到通知并自动更新。
二、具体实现
1、发布订阅案例
观察者接口：
/*** @Description: 观察者接口* @Date: 2024-12-27 10:08* @Author: gaoyufei**/
public interface Observer {void accept(String message);
}
观察者实现：
/*** @Description: 订阅者* @Date: 2024-12-27 10:10* @Author: gaoyufei**/
public class Subscriber implements Observer{public String clientId;public Subscriber(String clientId){this.clientId=clientId;}@Overridepublic void accept(String message) {System.out.println("订阅者："+clientId+" 接受到消息："+message);}
}
主题接口：
/*** @Description: 主题接口* @Date: 2024-12-27 10:15* @Author: gaoyufei**/
public interface Subject {void add(Observer observer);void del(Observer observer);void notify(String message);
}
主题实现：
import java.util.ArrayList;
import java.util.List;/*** @Description: 主题，维护了订阅者列表，通知订阅者* @Date: 2024-12-27 10:16* @Author: gaoyufei**/
public class Topic implements Subject {private List<Observer> observerList=new ArrayList<>();@Overridepublic void add(Observer observer) {observerList.add(observer);}@Overridepublic void del(Observer observer) {observerList.remove(observer);}@Overridepublic void notify(String message) {observerList.stream().forEach(e->{e.accept(message);});}
}
模拟订阅者订阅主题，客户端发布消息:
/*** @Description: 模拟订阅者订阅主题，客户端发布消息* @Date: 2024-12-27 10:18* @Author: gaoyufei**/
public class Client {public static void main(String[] args) {Topic topic=new Topic();Subscriber subscriber1=new Subscriber("001");Subscriber subscriber2=new Subscriber("002");Subscriber subscriber3=new Subscriber("003");topic.add(subscriber1);topic.add(subscriber2);topic.add(subscriber3);topic.notify("您有一条新消息！");}
}
2、村长通知村民案例
观察者接口：
/*** @Description: 观察者接口* @Date: 2024-12-27 9:35* @Author: gaoyufei**/
public interface Observer {void accept(String message);
}
观察者具体观察者村民：
/*** @Description: 具体观察者，村民，能接受消息* @Date: 2024-12-27 9:37* @Author: gaoyufei**/
public class Resident implements Observer{private String name;public Resident(String name){this.name=name;}@Overridepublic void accept(String message) {System.out.println("村民："+this.name+" 收到信息："+message);}
}
抽象主题：
/*** @Description: 抽象主题* @Date: 2024-12-27 9:39* @Author: gaoyufei**/
public interface Subject {void add(Observer observer);void del(Observer observer);void notify(String message);
}
主题的具体实现，村长的记录本：
import java.util.ArrayList;
import java.util.List;
/*** @Description: 主题的具体实现，村长的记录本，维护了村民信息，村长可以通过记录本给村民群发信息* @Date: 2024-12-27 9:42* @Author: gaoyufei**/
public class RecordBook implements Subject {private List<Observer> observerList = new ArrayList<>();@Overridepublic void add(Observer observer) {observerList.add(observer);}@Overridepublic void del(Observer observer) {observerList.remove(observer);}@Overridepublic void notify(String message) {observerList.stream().forEach(e -> {e.accept(message);});}
}
村长登记村民信息，用记录本给村民群发信息：
/*** @Description: 村长登记村民信息，用记录本给村民群发信息* @Date: 2024-12-27 9:44* @Author: gaoyufei**/
public class VillageHead {public static void main(String[] args) {
// 1、村里，村长有一个记录村民电话的本子，村民都需要登记一下。
// 在村里有什么事情的时候，村长就通过群发消息的方式通知村民。
// 2、村民就是观察者、订阅者，村长发布信息，记录本就是主题，RecordBook recordBook=new RecordBook();Resident resident=new Resident("王满银");Resident resident1=new Resident("孙玉亭");Resident resident2=new Resident("孙玉厚");recordBook.add(resident);recordBook.add(resident1);recordBook.add(resident2);recordBook.notify("大家好，今天下午三点来村支部开会，有重要事情通知！");}
}
相关文章：
Java实现观察者模式
一、前言 观察者模式，又称为发布订阅模式，是一种行为设置模式，允许对象之间建立一对多的依赖关系，这样当一个对象状态改变时，它的所有依赖者（观察者）都会收到通知并自动更新。 二、具体实现 …...
OpenResty开发环境搭建
简介 OpenResty 是一个基于 Nginx的高性能 Web 平台，用于方便地搭建能够处理超高并发、扩展性极高的动态 Web 应用、Web 服务和动态网关。官方地址：http://openresty.org/cn/ 具备下列特点： 具备Nginx的完整功能基于Lua语言进行扩展&#…...
鸿蒙系统文件管理基础服务的设计背景和设计目标
有一定经验的开发者通常对文件管理相关的api应用或者底层逻辑都比较熟悉，但是关于文件管理服务的设计背景和设计目标可能了解得不那么清楚，本文旨在分享文件管理服务的设计背景及目标，方便广大开发者更好地理解鸿蒙系统文件管理服务。 1 鸿蒙…...
Elasticsearch-脚本查询
脚本查询 概念 Scripting是Elasticsearch支持的一种专门用于复杂场景下支持自定义编程的强大的脚本功能，ES支持多种脚本语言，如painless，其语法类似于Java,也有注释、关键字、类型、变量、函数等，其就要相对于其他脚本高出几倍的性…...
【蓝桥杯——物联网设计与开发】拓展模块4 - 脉冲模块
目录 一、脉冲模块 （1）资源介绍 🔅原理图 🔅采集原理 （2）STM32CubeMX 软件配置 （3）代码编写 （4）实验现象 二、脉冲模块接口函数封装 三、踩坑日记 &a…...
devops和ICCID简介
Devops DevOps（Development 和 Operations 的组合）是一种软件开发和 IT 运维的哲学，旨在促进开发、技术运营和质量保障（QA）部门之间的沟通、协作与整合。它强调自动化流程，持续集成（CI…...
uniapp使用live-pusher实现模拟人脸识别效果
需求： 1、前端实现模拟用户人脸识别，识别成功后抓取视频流或认证的一张静态图给服务端。 2、服务端调用第三方活体认证接口，验证前端传递的人脸是否存在，把认证结果反馈给前端。 3、前端根据服务端返回的状态，显示在…...
OSI 网络 7 层模型
问: 请你介绍一下OSI七层网络模型物理层解决什么问题?功能原理问题 数据链路层解决什么问题功能原理 网络层解决的问题功能原理 传输层解决什么问题功能原理会话层解决什么问题功能原理: 表示层解决什么问题 应用层解决什么问题如何展示? 问: 请你介绍一下OSI七层网络模型 物…...
RK356x bsp 7 - PCF8563 RTC调试记录
文章目录 1、环境介绍2、目标3、PCF85634、dts配置5、内核配置6、测试验证 1、环境介绍 硬件：飞凌ok3568-c开发板 软件：原厂rk356x sdk 2、目标 开发板断电后仍正常计时。 3、PCF8563 PCF8563 是由 NXP Semiconductors 公司生产的低功耗 CMOS 实时…...
Vue.js组件开发-如何实现vueFLow流程
在Vue.js组件中实现vueFlow流程实例 确保已经安装了vueFlow库。如果还没有安装，可以使用npm或yarn进行安装： npm install braks/vue-flow # 或者 yarn add braks/vue-flow步骤： 引入vueFlow组件： 在Vue组件文件中ÿ…...
upload-labs关卡记录15
图片马，这里就可以看到任务和注意事项： 使用一个正常图片，然后拼接一个一句话木马即可实现。这里就用命令窗口进行实现： copy 111.png/b shell.php/a shell.png 注意这里的命令窗口要在存在图片和一句话木马的目录下打开&#…...
面试题总结
一、mysql中的乐观锁、悲观锁、共享锁、排它锁、行锁、表锁 1、乐观锁 通过sql实现的，更新sql语句时加上where version #{version}乐观锁不是数据库自带的锁，需要我们自己去实现。乐观锁是指操作数据库时(更新操作)，想法很乐观，认…...
Linux | 零基础Ubuntu解压RaR等压缩包文件
目录 介绍 案例分析 安装工具 解压实践 介绍 RAR是一种专利文件格式，用于数据压缩与归档打包，开发者为尤金罗谢尔（俄语：Евгений Лазаревич Рошал，拉丁转写：Yevgeny Lazarevich R…...
自动化测试-Pytest测试
目录 pytest简介 基本测试实例 编写测试文件 执行测试 pytest运行时参数 mark标记 Fixture pytest插件 Allure测试报告 测试步骤 pytest简介 Pytest是一个非常流行的Python测试框架，它支持简单的单元测试和复杂的功能测试，具有易于上手、功…...
磁盘调度算法
先来先服务（FCFS）算法 原理： 按照进程请求访问磁盘的先后顺序进行调度。就像是排队买东西，先到的先服务。 示例（Python）： def fcfs(requests):"""requests是一个包含磁盘请求序…...
 与多模态 (Multi-modal))
多视图 (Multi-view) 与多模态 (Multi-modal)
多视图 (Multi-view) 与多模态 (Multi-modal) 是两种不同的数据处理方式，它们在机器学习和数据分析中有着重要的应用。尽管这两者有一些相似之处，但它们关注的角度和处理方法有所不同。 多视图 (Multi-view) 定义：多视图指的是同一数据对象…...
CFA知识点梳理系列：CFA Level II, Reading 7 Economics of Regulation
这是CFA知识点梳理系列的第七篇文章，上一篇文章可以参考以下链接: CFA知识点梳理系列：CFA Level II, Reading 6 Economic Growth...
微信流量主挑战：三天25用户！功能未完善？（新纪元4）
🎉【小程序上线第三天！突破25用户大关！】🎉 嘿，大家好！今天是我们小程序上线的第三天，我们的用户量已经突破了25个！昨天还是16个，今天一觉醒来竟然有25个！这涨…...
)
1.微服务灰度发布落地实践(方案设计)
前言 微服务架构中的灰度发布（也称为金丝雀发布或渐进式发布）是一种在不影响现有用户的情况下，逐步将新版本的服务部署到生产环境的策略。通过灰度发布，你可以先将新版本的服务暴露给一小部分用户或特定的流量，观察其…...
Web3如何推动元宇宙的去中心化发展？
随着科技的不断进步，元宇宙的概念逐渐从科幻变成现实，它不仅是虚拟世界与现实世界的融合，更是数字交互和社会参与的新形态。在这个过程中，Web3作为下一代互联网的核心技术，正发挥着关键作用。特别是在去中心化的元宇宙…...
【NODE】01-fs和path常用知识点
前言 最近在使用express-generator知识进行搭建前后端通信，其中有些知识点涉及到nodejs的fs和path核心模块，因此另写一篇文章进行介绍和代码案例练习。 fs（文件系统）和 path 是 Node.js 的核心模块，用于文件操作和路径…...
矩阵线性方程组
矩阵可以是任何形状 当矩阵的行数等于列数,称之为方阵,那么它就有行列式 矩阵的公式 矩阵分块法 Matrix(母体) 克拉默法则 线性方程组 注意初等列变换不是一个同解变换 初等变换与秩 XAB 可以用初等列变换但是不推荐,还是使用初等行变换.用转置思想求解 ( X A ) T…...
Web API和Web Services的区分
前些年一提及自动化测试，大多是指UI界面层的自动化测试。近几年，随着分层自动化测试概念的兴起，以及自动化测试自身的发展与细分，自动化测试包含了更多的内容。 API(Application ProgrammingInterface，应用程序编程接…...
各种数据库类型介绍
在软件开发和数据处理领域，数据库扮演着至关重要的角色。它们用于存储、检索和管理大量数据，是信息系统不可或缺的基础。以下是几种常用的数据库类型及其简要介绍： 1.关系型数据库（Relational Databases） 关系型数据库…...
Hive练习题11-15
11、第11题 info 表 date result 2005-05-09 win 2005-05-09 lose 2005-05-09 lose 2005-05-09 lose 2005-05-10 win 2005-05-10 lose 2005-05-10 lose 如果要生成下列结果, 该如何写sql语句? win lose 2005-05-09 2 2 2005-05-10 1 2 答案： (1) …...
【微信小程序】4plus|搜索框-历史搜索 | 我的咖啡店-综合实训
升级版1-清空全部的再次确认 实现功能： 历史搜索记录展示-历史搜索记录展示10条点击跳转-点击历史搜索记录可同步到搜索框并自动搜索全部删除-可一次性全部删除历史搜索记录全部删除-有再次确认操作展示 进行搜索后留下搜索记录 点击垃圾桶图标，显示【清空全部】 点击【清…...
学习笔记（C#基础书籍）-- C#高级应用
（12.25，12.26） I/O数据流技术：《第十二章》 为了能够长时间保存程序中的数据，I/O技术可以将数据保存到文件（如文本文件等）中。 ⭕文件基本操作 a.File类：支持对文件的基本操作&…...
pytorch将数据与模型都放到GPU上训练
默认是CPU，如果想要用GPU需要： 安装配置cuda，然后更新/下载支持gpu版本的pytorch，可以参考：https://blog.csdn.net/weixin_35757704/article/details/124315569设置device：device torch.device(cuda if t…...
华为 IPD，究竟有什么特点？（二）
关注作者 （四）华为版 IPD 特点四：一定要把差异化竞争力持 续建立在平台上 平台不仅带来研发效率的提升，更重要的是，它是技术竞争力的载体，是研发质 量的重要保证。 1）为什么很多企业摆脱不了同…...
--神经网络训练)
CV(7)--神经网络训练
前言 仅记录学习过程，有问题欢迎讨论 什么是神经网络： 神经网络是一种模拟人脑神经元工作原理的算法，它由多个神经元组成，每个神经元都接受输入，通过计算产生输出，并将输出传递给其他神经元。神经网络的…...
git更改当前项目的远程仓库，保留原始仓库提交记录提交到新仓库
在开发过程中，有时需要将当前项目的远程仓库切换到另一个新的远程仓库，同时保留所有原始的提交记录。以下是详细的步骤和最佳实践，确保你能够顺利完成这一操作。 更改当前项目的远程仓库 1.查看当前的远程仓库 确认当前项目的远程仓库地址。…...
【产品应用】一体化无刷电机在旋转等离子喷枪中的应用
在现代工业制造与加工领域，等离子喷枪凭借其高温、高速的等离子射流，能够实现高效的材料表面处理、切割以及焊接等工艺，在众多行业中发挥着关键作用。而一体化无刷电机的应用，更是为等离子喷枪的性能提升和稳定运行注入了强大动力…...
docker django uwsgi 报错记录
这个配置中是能够正常进行网页访问的，能够查看网页 [uwsgi] chdir /home/luichun/lc/Pyfile/PyCursor/app module app.wsgi:application plugin-dir /usr/lib/uwsgi/plugins plugins python311 env TZAsia/Shanghai socket-timeout 60 websocket-ma…...
【自由能系列（初级），论文解读】神经网络中，熵代表系统的不确定性，自由能则引导系统向更低能量的状态演化，而动力学则描述了系统状态随时间的变化。
神经网络中的熵、自由能与动力学 核心结论： 神经网络在“学习”和“成长”过程中，熵、自由能以及动力学扮演着关键角色。 熵代表系统的不确定性，自由能则引导系统向更低能量的状态演化，而动力学则描述了系统状态随时间的变化。 这…...
云计算时代携程的网络架构变迁
大家觉得有意义和帮助记得及时关注和点赞!!! 前言0 携程云平台简介 网络演进时间线1 基于 VLAN 的二层网络 1.1 需求1.2 解决方案：OpenStack Provider Network 模型1.3 硬件网络拓扑1.4 宿主机内部网络拓扑1.5 小结 优点缺点2 基于 SDN 的大二层网络 2.1 面临的新问…...
uniapp 微信小程序 数据空白展示组件
效果图 html <template><view class"nodata"><view class""><image class"nodataimg":src"$publicfun.locaAndHttp()?localUrl:$publicfun.httpUrlImg(httUrl)"mode"aspectFit"></image>&l…...
java 线程池为什么设计成先进队列再创建最大线程为何先入队列再增加线程数？
java 线程池为什么设计成先进队列再创建最大线程为何先入队列再增加线程数？ 这个设计与 线程池的性能优化 、资源利用和任务调度策略密切相关。要理解为什么线程池设计成“ 先将任务入队列，再创建最大线程数 ”，可以从以下几个方面进行分析&…...
我的Qt作品（20）使用Qt+OpenCV写一个旋转/抠图/mask生成工具
使用QtOpenCV写一个旋转/抠图/mask生成工具 1、旋转功能 void FormRotate::rotateImage(const cv::Mat &src, cv::Mat &dst, double degree) //旋转 {if (fabs(degree) < 0.001){dst src;return;}//center旋转的中心点坐标//degree旋转的角度,不是弧度,>0逆时针…...
【vue】vite + ts +vue3 安装及使用 pinia
vue3 TS 安装使用pinia状态管理_vue3 ts pinia-CSDN博客 Vue项目进阶：再谈Pinia函数式（composition API）用法-腾讯云开发者社区-腾讯云...
计算机网络 （10）网络层
前言 计算机网络中的网络层（Network Layer）是OSI（开放系统互连）模型中的第三层，也是TCP/IP模型中的第二层，它位于数据链路层和传输层之间。网络层的主要任务是负责数据包从源主机到目的主机的路径选择和数据…...
1085 PAT单位排行
每次 PAT 考试结束后，考试中心都会发布一个考生单位排行榜。本题就请你实现这个功能。 输入格式： 输入第一行给出一个正整数 N（≤105），即考生人数。随后 N 行，每行按下列格式给出一个考生的信息ÿ…...
知识库1: 什么是知识库？
知识库（Knowledge Base, KB）是一个存储和组织知识的信息系统或数据集合，用于保存、管理和访问结构化或非结构化的信息。它的目的是帮助人们快速获取所需的知识、解答问题或支持决策。知识库可以被广泛应用于技术支持、教育、研究以及智能系统…...
[SAP ABAP] 程序备份
备份当前程序到本地的方式如下： 1.复制粘贴 Ctrl A 、Ctrl V 2.【实用程序】|【更多实用程序】|【上载/下载】|【下载】 3.快捷键，支持多种格式导出(.abap .html .pdf 等) 在事务码SE38(ABAP编辑器)屏幕右下角，点击【Options选项】图…...
SpringBoot 自动装配原理及源码解析
目录 一、引言 二、什么是 Spring Boot 的自动装配 三、自动装配的核心注解解析 3.1 SpringBootApplication 注解 （1）SpringBootConfiguration： （2）EnableAutoConfiguration： （3…...
【专题】2024年悦己生活消费洞察报告汇总PDF洞察（附原数据表）
原文链接： https://tecdat.cn/?p38654 在当今时代背景下，社会发展日新月异，人们的生活方式与消费观念正经历深刻变革。MoonFox 月狐数据的《2024 年悦己生活消费洞察报告》聚焦于这一充满活力与变化的消费领域。随着就业、婚姻等社会压力的…...
empire靶机
打开靶机 我们先查看页面源代码，发现什么也没有 再去用nmap扫描 nmap -sV -p- 192.168.95.144 发现也没什么用 我们在用dirb扫一下 dirb http://192.168.95.144 我们发现了robots.txt并且响应码是200，去访问一下 又得到了一个目录，去访问…...
uniapp 判断多选、选中取消选中的逻辑处理
一、效果展示 二、代码 1.父组件： :id=“this.id” ： 给子组件传递参数【id】 @callParentMethod=“takeIndexFun” ：给子组件传递方法，这样可以在子组件直接调用父组件的方法 <view @click="$refs.member.open()"...
arthas查看拼接好参数的sql, redis, es完整可直接执行的命令
arthas查看拼接好参数的sql, redis, es完整可直接执行的命令 arthas查看sql可执行命令arthas查看redis可执行命令arthas查看es可执行命令相关链接 经常修bug的时候, 拿不到能够执行的命令, 真是太难受了 arthas查看sql可执行命令 # mybatis plus (参数和sql分离了) watch org.…...
Flamingo：少样本多模态大模型
Flamingo：少样本多模态大模型 论文大纲理解1. 确认目标2. 分析过程（目标-手段分析）3. 实现步骤4. 效果展示5. 金手指 解法拆解全流程核心模式提问Flamingo为什么选择使用"固定数量的64个视觉tokens"这个特定数字?这个数字的选择背…...
nacos-gateway动态路由
在Nacos官网中给出了手动监听Nacos配置变更的SDK： Nacos Java SDK 所需依赖 <!--统一配置管理--> <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId> <…...