设计模式 - Observer Pattern 观察者模式

server/2024/9/23 9:22:01/

文章目录

定义

观察者模式是行为型模式的一种,它定义对象间的一种一对多的依赖关系,使得每当一个对象改变状态,它的所有依赖都会收到通知并且自动更新状态。

简单来说就是:当一个行为发生时传递信息给另外一个用户接收做出相应的处理,它们之间其实没有什么直接的关联。

观察者模式的实现构成

构成

 1. 主题(Subject):抽象主题,提供方法来增加和删除观察者,当自身状态发生改变时,通知所有观察者。
 2. 观察者(Observer):抽象观察者,用于接收主题状态更新的通知。
 3. 具体主题(Concrete Subject):实现主题接口、在其内部状态发生改变时,通知所有注册的观察者。
 4. 具体观察者(Concrete Observer):实现观察者接口、在接收到主题的通知时更新自身状态。

UML图

在这里插入图片描述

观察者模式的代码实现

场景

假设我们有一个股票价格监控系统,不同的模块(图表模块、统计模块和警报模块),它们需要实时更新股票价格信息。当股票价格发生变化时,这些模块就立即可以获取到通知并且可以进行更新显示。

代码实现

观察者接口
java">// 观察者接口,定义更新方法
interface Observer {// 当主题状态变化时调用此方法通知观察者。void update(double price);
}
具体观察者
java">// 具体观察者:图表模块
class ChartDisplay implements Observer {@Overridepublic void update(double price) {System.out.println("图表模块更新股票价格: " + price);}
}// 具体观察者:统计模块
class StatisticsDisplay implements Observer {@Overridepublic void update(double price) {System.out.println("统计模块更新股票价格: " + price);}
}// 具体观察者:警报模块
class AlertSystem implements Observer {@Overridepublic void update(double price) {if (price > 100.0) {System.out.println("警报!股票价格超过100元: " + price);}}
}
主题接口
java">// 主题接口,定义增加、删除观察者及通知方法,用于管理和通知观察者。
interface Subject {void addObserver(Observer observer);void removeObserver(Observer observer);void notifyObservers();
}
具体主题
java">// 具体主题:实现了Subject,用来维护观察者列表并在价格变化时通知所有观察者。
class StockPrice implements Subject {private List<Observer> observers;private double price;public StockPrice() {observers = new ArrayList<>();}@Overridepublic void addObserver(Observer observer) {observers.add(observer);}@Overridepublic void removeObserver(Observer observer) {observers.remove(observer);}@Overridepublic void notifyObservers() {for (Observer observer : observers) {observer.update(price);}}// 设置新价格并通知观察者public void setPrice(double price) {this.price = price;notifyObservers();}
}
客户端代码
java">// 客户端代码
public class ObserverPatternDemo {public static void main(String[] args) {// 创建具体主题StockPrice stockPrice = new StockPrice();// 创建具体观察者ChartDisplay chartDisplay = new ChartDisplay();StatisticsDisplay statisticsDisplay = new StatisticsDisplay();AlertSystem alertSystem = new AlertSystem();// 注册观察者stockPrice.addObserver(chartDisplay);stockPrice.addObserver(statisticsDisplay);stockPrice.addObserver(alertSystem);// 更新股票价格stockPrice.setPrice(95.0);System.out.println();stockPrice.setPrice(105.0);}
}

总结

优点

 1. 解耦:主题只需知道观察者实现了某个接口,不需要知道具体实现细节,双方可以独立变化。
 2. 目标与观察者之间建立了一套触发机制。

缺点

 1. 当观察者对象很多时,通知的发布会花费很长时间,影响程序的效率。
 2. 如果在观察者和观察目标之间有循环依赖的话,观察目标会触发它们之间进行循环调用,可能导致系统崩溃。

应用场景

 跨系统的消息交换场景,如消息队列,事件总线的处理机制

其他设计模式文章:


http://www.ppmy.cn/server/53502.html

相关文章

Retrieval-Augmented Generation for Large Language Models A Survey

Retrieval-Augmented Generation for Large Language Models: A Survey 文献综述 文章目录 Retrieval-Augmented Generation for Large Language Models: A Survey 文献综述 Abstract背景介绍 RAG概述原始RAG先进RAG预检索过程后检索过程 模块化RAGModules部分Patterns部分 RAG…

[数据集][目标检测]电力场景下电柜箱门把手检测数据集VOC+YOLO格式1167张1类别

数据集格式&#xff1a;Pascal VOC格式YOLO格式(不包含分割路径的txt文件&#xff0c;仅仅包含jpg图片以及对应的VOC格式xml文件和yolo格式txt文件) 图片数量(jpg文件个数)&#xff1a;1167 标注数量(xml文件个数)&#xff1a;1167 标注数量(txt文件个数)&#xff1a;1167 标注…

《重构》读书笔记【第1章 重构,第一个示例,第2章 重构原则】

文章目录 第1章 重构&#xff0c;第一个示例1.1 重构前1.2 重构后 第2章 重构原则2.1 何谓重构2.2 两顶帽子2.3 为何重构2.4 何时重构2.5 重构和开发过程 第1章 重构&#xff0c;第一个示例 我这里使用的IDE是IntelliJ IDEA 1.1 重构前 plays.js export const plays {&quo…

SQL面试真题解答 数据统计分析,求“同比、环比”等(SQL窗口函数使用)

SQL面试真题解答 数据统计分析&#xff0c;求“同比、环比”等&#xff08;SQL窗口函数使用&#xff09; 环比、环比增长率、同比、同比增长率&#xff0c;根据百度百科上的 说明&#xff1a; 环比增长率 环比增长率&#xff0c;一般是指和上期相比较的增长率。 环比增长率&a…

Hadoop 面试题(九)

1. 简述下面关于Hadoop系统中使用CombineFileInputFormat解决小文件问题的描述错误的是&#xff08;&#xff09; &#xff1f; A&#xff1a;CombineFileInputFormat是使用Hadoop API(抽象类CombineFileInputFormat)来解决小文件的问题 B&#xff1a;抽象类CombineFileInputF…

新型裂变营销,茶叶店茶馆会员卡模式,社交电商新玩法分享

大多数茶叶店只是简单地售卖茶叶&#xff0c;偶尔附赠一些茶点作为促销手段。然而&#xff0c;这家茶叶店的老板却采用了与众不同的商业模式&#xff0c;成功吸引了周围8家同行80%的客户。 接下来&#xff0c;让我们揭开这家茶叶店成功的秘密。 首先&#xff0c;他们推出了一个…

计算机网络微课堂(湖科大教书匠)TCP部分

计算机网络微课堂&#xff08;湖科大教书匠&#xff09;TCP部分 【计算机网络微课堂&#xff08;有字幕无背景音乐版&#xff09;】 TCP的流量控制 一般来说&#xff0c;我们希望数据传输得更快一些。但如果发送方把数据发送得过快&#xff0c;接收方就可能来不及接收&#…

存储请求地址但是使用时请求的是端口

baseURL默认全局加载一次&#xff0c;后续直接读取缓存 解决方案&#xff1a;