【设计模式】JAVA Design Patterns——Observer(观察者模式)

🔍目的


定义一种一对多的对象依赖关系这样当一个对象改变状态时,所有依赖它的对象都将自动通知或更新。

🔍解释


真实世界例子

在遥远的土地上生活着霍比特人和兽人的种族。他们都是户外生活的人所以他们密切关注天气的变化。可以说他们不断地关注着天气。

通俗描述

注册成为一个观察者以接收对象状态的改变。

维基百科

观察者模式是这样的一种软件设计模式:它有一个被称为主题的对象,维护着一个所有依赖于它的依赖者清单,也就是观察者清单,当主题的状态发生改变时,主题通常会调用观察者的方法来自动通知观察者们。

编程示例

首先创建天气观察者的接口以及我们的种族,兽人和霍比特人。

public interface WeatherObserver {void update(WeatherType currentWeather);
}@Slf4j
public class Orcs implements WeatherObserver {@Overridepublic void update(WeatherType currentWeather) {LOGGER.info("The orcs are facing " + currentWeather.getDescription() + " weather now");}
}@Slf4j
public class Hobbits implements WeatherObserver {@Overridepublic void update(WeatherType currentWeather) {switch (currentWeather) {LOGGER.info("The hobbits are facing " + currentWeather.getDescription() + " weather now");}
}

创建一个动态变化的天气:

@Slf4j
public class Weather {private WeatherType currentWeather;private final List<WeatherObserver> observers;public Weather() {observers = new ArrayList<>();currentWeather = WeatherType.SUNNY;}public void addObserver(WeatherObserver obs) {observers.add(obs);}public void removeObserver(WeatherObserver obs) {observers.remove(obs);}/*** Makes time pass for weather.*/public void timePasses() {var enumValues = WeatherType.values();currentWeather = enumValues[(currentWeather.ordinal() + 1) % enumValues.length];LOGGER.info("The weather changed to {}.", currentWeather);notifyObservers();}private void notifyObservers() {for (var obs : observers) {obs.update(currentWeather);}}
}

执行示例:

    var weather = new Weather();weather.addObserver(new Orcs());weather.addObserver(new Hobbits());weather.timePasses();// The weather changed to rainy.// The orcs are facing rainy weather now// The hobbits are facing rainy weather nowweather.timePasses();// The weather changed to windy.// The orcs are facing windy weather now// The hobbits are facing windy weather nowweather.timePasses();// The weather changed to cold.// The orcs are facing cold weather now// The hobbits are facing cold weather nowweather.timePasses();// The weather changed to sunny.// The orcs are facing sunny weather now// The hobbits are facing sunny weather now

🔍类图


🔍扩展延伸 

观察者模式在kafka client consumer中的使用:

大致逻辑

consumer想要消费kafka broker中的数据需要发送request,request发送的结果用RequestFuture来表示,RequestFuture中包含RequestFutureListener,当request处理完成后RequestFutureListener的相关方法会被调用。RequestFutureCompletionHandler用来处理RequestFuture、ClientResponse还有RuntimeException。

依赖关系:

RequestFutureListener为观察者,onSuccess和onFail方法相当于之前的update方法;RequestFuture为被观察者,addListener相当于attach方法,fireSuccess和fireFailure方法相当于notify方法。

RequestFutureListener部分代码:
public interface RequestFutureListener<T> {void onSuccess(T value);void onFailure(RuntimeException e);
}
RequestFuture部分代码: 
public class RequestFuture<T> implements ConsumerNetworkClient.PollCondition {private static final Object INCOMPLETE_SENTINEL = new Object();private final AtomicReference<Object> result = new AtomicReference<>(INCOMPLETE_SENTINEL);private final ConcurrentLinkedQueue<RequestFutureListener<T>> listeners = new ConcurrentLinkedQueue<>();private final CountDownLatch completedLatch = new CountDownLatch(1);public void complete(T value) {try {if (value instanceof RuntimeException)throw new IllegalArgumentException("The argument to complete can not be an instance of RuntimeException");if (!result.compareAndSet(INCOMPLETE_SENTINEL, value))throw new IllegalStateException("Invalid attempt to complete a request future which is already complete");fireSuccess();} finally {completedLatch.countDown();}}
//遍历listener并调用其success时的方法private void fireSuccess() {T value = value();while (true) {RequestFutureListener<T> listener = listeners.poll();if (listener == null)break;listener.onSuccess(value);}}
//遍历listener并调用其fail时的方法private void fireFailure() {RuntimeException exception = exception();while (true) {RequestFutureListener<T> listener = listeners.poll();if (listener == null)break;listener.onFailure(exception);}}//增加listenerpublic void addListener(RequestFutureListener<T> listener) {this.listeners.add(listener);if (failed())fireFailure();else if (succeeded())fireSuccess();}

🔍适用场景


在下面任何一种情况下都可以使用观察者模式

  • 当抽象具有两个方面时,一个方面依赖于另一个方面。将这些方面封装在单独的对象中,可以使你分别进行更改和重用
  • 当一个对象的改变的同时需要改变其他对象,同时你又不知道有多少对象需要改变时
  • 当一个对象可以通知其他对象而无需假设这些对象是谁时。换句话说,你不想让这些对象紧耦合。

🔍Ending


观察者模式(Observer Pattern)是一种行为设计模式,它定义了一种一对多的依赖关系,使得当一个对象的状态发生变化时,所有依赖于它的对象都会得到通知并自动更新。

在观察者模式中,通常包含以下几个角色:

  1. 主题(Subject):被观察的对象,它会维护一组观察者对象,并在自身状态发生变化时通知观察者。
  2. 观察者(Observer):观察主题对象的状态变化,并根据变化做出相应的动作。
  3. 具体主题(ConcreteSubject):实现了主题接口的具体对象,负责维护观察者列表,并在自身状态发生变化时通知观察者。
  4. 具体观察者(ConcreteObserver):实现了观察者接口的具体对象,负责接收主题对象的通知,并根据通知更新自身状态。

希望本文能够帮助读者更深入地理解观察者模式,并在实际项目中发挥其优势。谢谢阅读!


希望这份博客草稿能够帮助到你。如果有其他需要修改或添加的地方,请随时告诉我。

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

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

相关文章

深度解析ChatGPT原理

深度解析ChatGPT原理 ChatGPT是基于OpenAI的生成式预训练变换器&#xff08;GPT&#xff09;模型的自然语言处理技术。它通过大规模预训练和微调来生成高质量的自然语言文本。本文将详细探讨ChatGPT的技术原理&#xff0c;包括其架构、训练过程、生成机制和应用场景&#xff0…

Linux之线程及线程安全详解

前言&#xff1a;在操作系统中&#xff0c;进程是资源分配的基本单位&#xff0c;那么线程是什么呢&#xff1f;线程是调度的基本单位&#xff0c;我们该怎么理解呢&#xff1f; 目录 一&#xff0c;线程概念理解 二&#xff0c;Linux里面的线程原理 三&#xff0c;为什么要…

碳微球是新型碳材料 在高科技领域应用价值极高

碳微球是新型碳材料 在高科技领域应用价值极高 碳微球是一种新型碳材料&#xff0c;由石墨片层在玻璃相的石墨结构间断分布而构成。   与碳纳米管、石墨烯等碳材料不同&#xff0c;碳微球具有独特的球形结构&#xff0c;这赋予了其高比表面、高堆积密度等特点及良好的导电性、…

【高阶数据结构(八)】跳表详解

&#x1f493;博主CSDN主页:杭电码农-NEO&#x1f493;   ⏩专栏分类:高阶数据结构专栏⏪   &#x1f69a;代码仓库:NEO的学习日记&#x1f69a;   &#x1f339;关注我&#x1faf5;带你学习更多数据结构   &#x1f51d;&#x1f51d; 高阶数据结构 1. 前言2. 跳表的概…

python下用cartopy绘制地形晕染(shading)图

python可以利用rasterio&#xff0c;cartopy&#xff0c;matplotlib等库绘制地形晕染图。 1.获取高程数据 高程数据可以从GEBCO网站下载&#xff1a;&#xff08;https://www.gebco.net/data_and_products/gridded_bathymetry_data/&#xff09;。 选择raster&#xff08;栅…

浅谈一些AIGC赚钱赛道

前段时间&#xff0c;做过一期关于AIGC的分享。 ​缘起于近两年看到 DELL E 到 Stable Diffusion 多模态文本可控图像生成的大火&#xff0c;让AIGC概念涨了一大波流量。百度等一些头部大厂&#xff0c;以及关注元宇宙、web3.0领域的很多媒体和公司&#xff0c;都蹭上了这波热…

el-table动态配置显示表头

在实际工作中&#xff0c;会遇到动态配置e-table表头的情况&#xff0c;如下方法可以实现&#xff1a; // 要展示的列 column: [{prop: name, name: 名称 }, {prop: age, name: 年龄 }, {prop: sex, name: 性别 }, {prop: address, name: 地址 }, {prop: city, name: 城市 }]…

生活旅游数据恢复:全国违章查询

【步骤一&#xff1a;备份数据】 在开始数据恢复之前&#xff0c;首先要做的是备份现有的数据。虽然这一步不直接涉及到数据恢复&#xff0c;但万一在恢复过程中出现问题&#xff0c;您还可以回滚到备份&#xff0c;以避免数据丢失。 打开全国违章查询app。在主界面上找到并点…

量化投资分析平台 迅投 QMT(二)

量化投资分析平台 迅投 QMT [迅投 QMT](https://www.xuntou.net/?user_code7NYs7O)我目前在使用如何获取数据上代码历史帖子 迅投 QMT 我目前在使用 两个月前&#xff08;2024年4月&#xff09;迅投和CQF有一个互动的活动&#xff0c;进行了平台的一个网上路演&#xff0c;刚…

数据隐私重塑:Web3时代的隐私保护创新

随着数字化时代的不断深入&#xff0c;数据隐私保护已经成为了人们越来越关注的焦点之一。而在这个数字化时代的新篇章中&#xff0c;Web3技术作为下一代互联网的代表&#xff0c;正在为数据隐私保护带来全新的创新和可能性。本文将深入探讨数据隐私的重要性&#xff0c;Web3时…

Android多媒体之调用摄像头和相册

Android调用摄像头拍照的使用 权限申请&#xff1a; 在AndroidManifest.xml文件中添加摄像头使用权限&#xff1a; <uses-permission android:name"android.permission.CAMERA"/>如果需要存储图片&#xff0c;还需要添加文件读写权限&#xff1a; <uses-pe…

Jetson Orin安装部署和使用(1)

Jetson Orin使用 一、 安装NVIDIA-jetpack和基础开发环境 1、修改deb source sudo bash -c echo "deb https://repo.download.nvidia.com/jetson/common r34.1 main" >> /etc/apt/sources.list.d/nvidia-l4t-apt-source.listsudo bash -c echo "deb ht…

WSDM 2023 推荐系统相关论文整理(二)

WSDM 2023的论文录用结果已出&#xff0c;推荐系统相关的论文方向包含序列推荐&#xff0c;点击率估计等领域&#xff0c;涵盖图学习&#xff0c;对比学习&#xff0c;因果推断&#xff0c;知识蒸馏等技术&#xff0c;累计包含近四十篇论文&#xff0c;下文列举了部分论文的标题…

STM32H750外设ADC之外部触发和注入管理

目录 概述 1 外部触发转换和触发极性 1.1 外部触发条件 1.2 忽略硬件触发条件 1.3 触发框图 1.4 常规通道的外部触发 1.5 注入通道的外部触发 2 注入通道管理 2.1 触发注入模式 2.2 自动注入模式 2.3 注入转换延迟 概述 本文主要介绍STM32H750外设ADC之外部触发和注…

Win10 TiKV单机单节点Docker部署测试

1. 环境 环境&#xff1a;Windows10、WSL2、Ubuntu20.04、Docker Desktop目标&#xff1a;单节点单机部署&#xff0c;测试用 2. 前置操作 docker pull pingcap/tikv:latest docker pull pingcap/pd:latestmkdir -p /mnt/tikv/pd mkdir -p /mnt/tikv/tikvip a 命令查看虚拟…

PROFINET转CANOPEN(WL-ABC3033)连接台达伺服驱动器ASDA-B3

在工业自动化领域这片广阔天地中&#xff0c;通信协议的转换犹如一道横亘在工程师们面前的难题。特别是在将众多采用不同通信协议的设备汇聚一堂&#xff0c;共同协作完成任务的场景中&#xff0c;如何确保数据如丝般顺滑地穿梭于各个节点之间&#xff0c;确保每台设备都能心领…

在GEE中显示矢量或栅格数据的边界(包含样式设计)

需要保证最后显示的数据是一个 FeatureCollection 对象。 如果数据是一个 Geometry 或 Image&#xff0c;我们也可以使用 style 方法来设置样式并将其添加到地图上。以下是针对不同类型对象的处理方式&#xff1a; 1 Geometry对象 如果 table 是一个 Geometry 对象&#xff…

智慧社区信息化建设整体解决方案(PPT原件获取及软件各类建设方案)

智慧社区信息化系统建设要点可以归纳为以下几个方面&#xff1a; 一、社区基础设施建设 网络设施&#xff1a;建设高速网、城域网、校内网等网络&#xff0c;以满足社区信息传输和管理所需。信息终端设备&#xff1a;建设各种类型的智能终端设备&#xff0c;包括智能手机、智能…

子窗体关闭后父窗体操作

子窗体关闭后父窗体操作 子窗体代码: window.close();//关闭子窗体window.parent.opener.redirectOutList();父窗体: //子窗体关闭后父窗体重定向监控 function redirectOutList (){IOOP.getRequest("#es","sec/secdes.do",{pageNo:1,searchKey:}); }

【GD32F303红枫派使用手册】第八节 TIMER-RGB彩灯实验

8.1 实验内容 通过本实验主要学习以下内容&#xff1a; RGB彩灯控制原理 TIMER PWM输出原理 8.2 实验原理 本例程中使用的RGB彩灯采用共阳极驱动方式&#xff0c;使用三路PWM进行驱动&#xff0c;对应引脚输出低电平的时候对应RGB灯珠点亮&#xff0c;调节不同路的PWM占空…