浅析观察者模式在Java中的应用

观察者模式（Observer Design Pattern）,也叫做发布订阅模式（Publish-Subscribe Design Pattern）、模型-视图（Model-View）模式、源-监听器（Source-Listener）模式、从属者（Dependents）模式

观察者模式应用最广的场景就是消息发布订阅， 比如当系统中完成一个业务事件， 需要通知给不同的用户平台，这个时候就会有多种通知方式，如：

在这里插入图片描述

那么就需要将消息发布对象这一个状态的改变， 通知给另外多个平台的对象，像这种情况就适合观察者模式。下面就详细的介绍一下观察者模式

一、观察者模式的介绍

前面说到，观察者是一种行为设计模式，允许一个对象将其状态的改变通知其他对象。实际上主要的部分就是观察者和被观察者，比如前言提到的消息发布，就属于被观察者，而各种不同的平台消息提醒，则是一系列的观察者。那么观察者如何获取被观察者的状态变化呢？在观察者模式中是这样设计的：

1.1 观察者模式的结构

在被观察者这一块，通过在被观察者中管理观察者，如add（） 增加观察者，remove() 移除观察者和notifyObserver() 通知/发送消息给观察者等等方法，来达到通知观察者，管理观察者数量的作用。在观察者这个角度，需要有response() 接收被观察者通知的方法，来完成整个观察者模式的闭环。用UML图来展示则如下所示：

观察者模式结构中主要包括被观察者（Object）和观察者（Observer）两个结构：

image-20220409112301928

  • Subject：主题抽象类，提供一系列观察者对象，以及对这些对象的增加、删除和通知的方法
  • ConcreteSubject：主题具体实现类，实现抽象主题中的通知方法，通知所有注册过的观察者对象
  • Observer：观察者抽象类，包含一个通知响应抽象方法
  • ConcreteObserver1、ConcreteObserver2：观察者实现类，实现抽象观察者中的方法，以便在得到目标的更改通知时更新自身的状态
  • Client：客户端，对主题及观察者进行调用

从上面的UML图我们会知道，通过抽象观察者和被观察者，然后分别实现不同的观察者和被观察者，来达到将多个对象的不同状态传递给多个对象的作用。

1.2 观察者模式的实现

根据上面的类图，我们可以实现对应的代码。

首先定义一个抽象目标类Subject，其中包括增加、注销和通知观察者方法

public abstract class Subject {protected List<Observer> observerList = new ArrayList<Observer>();/*** 增加观察者* @param observer 观察者*/public void add(Observer observer) {observerList.add(observer);}/*** 注销观察者，从观察者集合中删除一个观察者* @param observer 观察者*/public void remove(Observer observer) {observerList.remove(observer);}/**通知观察者*/public abstract void notifyObserver();
}

对应具体的目标类ConcreteSubject

public class ConcreteSubject extends Subject{@Overridepublic void notifyObserver() {System.out.println("遍历观察者：");for (Observer observer : observerList) {observer.response();}}
}

此外需要定义抽象观察者Observer，它一般定义为一个接口，声明一个response()方法，为不同观察者的响应行为定义相同的接口：

public interface Observer {/**声明响应方法*/void response();
}

具体的观察者实现：

public class ConcreteObserver1 implements Observer{@Overridepublic void response() {System.out.println("我是具体观察者ConcreteObserver1");}
}public class ConcreteObserver2 implements Observer{@Overridepublic void response() {System.out.println("我是具体观察者ConcreteObserver2");}
}

最后是客户端测试：

public class Client {public static void main(String[] args) {Subject concreteSubject = new ConcreteSubject();//具体观察者Observer concreteObserver1 = new ConcreteObserver1();Observer concreteObserver2 = new ConcreteObserver2();concreteSubject.add(concreteObserver1);concreteSubject.add(concreteObserver2);concreteSubject.notifyObserver();}
}

测试结果：

遍历观察者：
我是具体观察者ConcreteObserver1
我是具体观察者ConcreteObserver2

1.3 观察者模式和订阅发布者模式的区别

在平常的开发中， 我们也会接触到订阅发布者模式（Pub-Sub Pattern）， 前面我们也说到它是观察者模式另外一种叫法，但是它们两者之间有什么不同呢？先来看看两个模式的实现结构：

在这里插入图片描述

在实际业务中，发布订阅者模式就是消息中间件的实现， 两者的区别在于：观察者模式中， 被观察者和观察者两者直接相关依赖，而在发布订阅者模式中，因为有调度中心的存在，被观察者和观察者两者不相互依赖，因此对于发布订阅者模式，实现了被观察者和观察者的解耦，更利于各个组件的独立扩展。

在具体调度中心中，可以通过不同的消息中间件来完成，比如Java中的RabbitMQ, Kafka等等

二、观察者模式的应用场景

在以下情况就可以考虑使用观察者模式：

  1. 一个对象的改变会导致一个或多个对象发生改变，而并不知道具体有多少对象将会发生改变，也不知道这些对象是谁
  2. 当一个抽象模型有两个方面，其中的一个方面依赖于另一个方面时，可将这两者封装在独立的对象中以使他们可以各自独立地改变和复用
  3. 需要在系统中创建一个触发链，使得事件拥有跨域通知（跨越两种观察者的类型）

2.1 观察者模式在java.util包中的应用

观察者模式在JDK中就有典型应用，比如java.util.Observable和java.util.Observer类。结构如下图所示：

image-20220409083948434

我们可以通过实现具体的ConcreteObserver和具体的ConcreteObservable完成观察者模式流程

2.2 观察者模式在MVC中的应用

MVC(Modew-View-Controller)架构中也应用了观察者模式，其中模型（Model）可以对应观察者模式中的观察目标，而视图（View）对应于观察者，控制器（Controller）就是中介者模式的应用：

image-20220409091533004

三、观察者模式实战

3.1 在本案例中模拟北京小客车指标摇号事件的消息通知场景（来源于《重学Java设计模式》）

对于通知事件，可以将其分成三个部分：事件监听、事件处理和具体的业务流程，如下图所示：

image-20220409095032686

对于和核心流程和非核心流程的结构，非核心流程可以是异步的，在MQ以及定时任务的处理下，能够最终保证一致性。

3.1.1 具体代码实现
  1. 事件监听接口及具体实现

这个部分就相当于观察者（Observer）的角色， 需要被观察者将信息发送给这些不同的观察者

在接口中定义基本事件类方法doEvent()，相当于UML图中的response() 方法

public interface EventListener {void doEvent(LotteryResult result);}

监听事件的具体实现MessageEventListener（短消息事件）和MQEventListener（MQ发送事件）

public class MessageEventListener implements EventListener{private Logger logger = LoggerFactory.getLogger(MessageEventListener.class);@Overridepublic void doEvent(LotteryResult result) {logger.info("给用户 {} 发送短信通知(短信)：{}", result.getuId(), result.getMsg());}
}public class MQEventListener implements EventListener{private Logger logger = LoggerFactory.getLogger(MQEventListener.class);@Overridepublic void doEvent(LotteryResult result) {logger.info("记录用户 {} 摇号结果(MQ)：{}", result.getuId(), result.getMsg());}
}
  1. 事件处理类

该部分就相当于Object部分，也就是被观察者

对于不同的事件类型（MQ和Message）进行枚举处理，并提供三个方法：subscribe()、unsubscribe()和notify()用于对监听事件的注册和使用：

public class EventManager {Map<Enum<EventType>, List<EventListener>> listeners = new HashMap<>();public EventManager(Enum<EventType>... operations) {for (Enum<EventType> operation : operations) {listeners.put(operation, new ArrayList<>());}}public enum EventType {MQ,Message}/*** 订阅* @param eventType 事件类型* @param listener  监听*/public void subscribe(Enum<EventType> eventType, EventListener listener) {List<EventListener> eventListeners = listeners.get(eventType);eventListeners.add(listener);}/*** 取消订阅* @param eventType 事件类型* @param listener 监听*/public void unsubscribe(Enum<EventType> eventType, EventListener listener) {List<EventListener> eventListeners = listeners.get(eventType);eventListeners.remove(listener);}/*** 通知* @param eventType 事件类型* @param result    结果*/public void notify(Enum<EventType> eventType, LotteryResult result) {List<EventListener> eventListeners = listeners.get(eventType);for (EventListener eventListener : eventListeners) {eventListener.doEvent(result);}}
}
  1. 业务抽象类接口及其实现

这一部分不属于观察者模式中的部分，是属于具体业务中的代码， 通过使用抽象类的方式实现方法可以在方法中扩展额外的调用，并提供抽象方法doDraw（），让继承者去实现具体逻辑

public abstract class LotteryService {private EventManager eventManager;public LotteryService() {eventManager = new EventManager(EventManager.EventType.MQ, EventManager.EventType.Message);eventManager.subscribe(EventManager.EventType.MQ, new MQEventListener());eventManager.subscribe(EventManager.EventType.Message, new MessageEventListener());}public LotteryResult draw(String uId) {LotteryResult lotteryResult = doDraw(uId);eventManager.notify(EventManager.EventType.MQ, lotteryResult);eventManager.notify(EventManager.EventType.Message, lotteryResult);return lotteryResult;}protected abstract LotteryResult doDraw(String uId);
}public class LotteryServiceImpl extends LotteryService{private MinibusTargetService minibusTargetService = new MinibusTargetService();@Overrideprotected LotteryResult doDraw(String uId) {//摇号测试String lottery = minibusTargetService.lottery(uId);return new LotteryResult(uId, lottery, new Date());}
}
  1. 其他的类

摇号服务接口：

/*** 小客车指标调控服务*/
public class MinibusTargetService {/*** 模拟摇号，但不是摇号算法** @param uId 用户编号* @return 结果*/public String lottery(String uId) {return Math.abs(uId.hashCode()) % 2 == 0 ? "恭喜你，编码".concat(uId).concat("在本次摇号中签") : "很遗憾，编码".concat(uId).concat("在本次摇号未中签或摇号资格已过期");}}

事件信息返回类：用于返回信息，在实际业务中这一部分可以进行对应的取舍

public class LotteryResult {private String uId;private String msg;private Date dateTime;//get set constructor... 
}
  1. 测试类
public class ApiTest {private Logger logger = LoggerFactory.getLogger(ApiTest.class);@Testpublic void test() {LotteryServiceImpl lotteryService = new LotteryServiceImpl();LotteryResult result = lotteryService.draw("1234567");logger.info("摇号结果：{}", JSON.toJSONString(result));}
}

测试结果：

11:43:09.284 [main] INFO  c.e.d.event.listener.MQEventListener - 记录用户 1234567 摇号结果(MQ)：恭喜你，编码1234567在本次摇号中签
11:43:09.288 [main] INFO  c.e.d.e.l.MessageEventListener - 给用户 1234567 发送短信通知(短信)：恭喜你，编码1234567在本次摇号中签
11:43:09.431 [main] INFO  ApiTest - 摇号结果：{"dateTime":1649475789279,"msg":"恭喜你，编码1234567在本次摇号中签","uId":"1234567"}

3.2 监听系统工作流完成消息，分别发送给不同的平台，比如微信，钉钉等

在这里插入图片描述

3.2.1 具体代码实现
  1. 消息事件监听

该类监听系统中的流程信息，通过这个processor来管理第三方平台，并选择性推送。继承ThirdMessageListener，接收系统传递过来的流程信息userMessage。

@ThirdMessageListenerAnnotation
public class ThirdMessageProcessor implements ThirdMessageListener {@Autowiredprivate WeChatMessageSender weChatMessageSender;@Value("${sys.ThirdPlatform.weChat}")private boolean weChatSwitch;@Value("${sys.ThirdPlatform.DingDing}")private boolean dingDingSwitch;@Overridepublic void onMessage(FlowUserMessage userMessage) {//若在系统配置文件中关闭该三方平台, 则对该平台不发送消息if (weChatSwitch || dingDingSwitch) {//集成各种第三方平台MessageSenderManager messageSenderManager = new MessageSenderManager(MessageSenderManager.MessagePlatform.weChat);//将微信平台集成在消息发送管理器中messageSenderManager.subscribe(MessageSenderManager.MessagePlatform.weChat, beijingOfficeMessageSender);//向微信平台发送消息messageSenderManager.notify(MessageSenderManager.MessagePlatform.weChat, userMessage);}}
}

  1. 消息发送管理器

    该部分是MessageSenderManager，相当于观察者模式中的被观察者，对不同的观察者进行管理和消息发送：

public class MessageSenderManager {Map<Enum<MessagePlatform>, List<MessageSender>> senders = new HashMap<>();public MessageSenderManager(Enum<MessagePlatform>... operations) {for (Enum<MessagePlatform> operation : operations) {senders.put(operation, new ArrayList<>());}}/*** 配置不同平台类型*/public enum MessagePlatform {/*** 微信平台*/Wechat,DingDing}/*** 订阅对应平台的监听器* @param platformType 平台类型* @param sender 监听器*/public void subscribe(Enum<MessagePlatform> platformType, MessageSender sender) {List<MessageSender> messageSenders = senders.get(platformType);messageSenders.add(sender);}/*** 取消对应平台的监听器* @param platformType 平台类型* @param sender 监听器*/public void unsubscribe(Enum<MessagePlatform> platformType, MessageSender sender) {List<MessageSender> messageSenders = senders.get(platformType);messageSenders.remove(sender);}/*** 通知消息* @param platformType 平台类型* @param userMessage 监听器*/public void notify(Enum<MessagePlatform> platformType, FlowUserMessage userMessage) {List<MessageSender> messageSenders = senders.get(platformType);for (MessageSender messageSender : messageSenders) {messageSender.sendMessage(userMessage);}}}
  1. 具体平台消息发送

该部分是具体的平台消息发送过程，也就是观察者，当观察者订阅后，每次被观察状态变化后，都会将该状态发送给观察者。

public interface MessageSender {/*** 发送消息* @param userMessage 流程消息*/void sendMessage(FlowUserMessage userMessage);/*** 重发消息* @param userMessage 流程消息*/void resendMessage(FlowUserMessage userMessage);
}@Component
public class WeixinMessageSender implements MessageSender{@Overridepublic void sendMessage(FlowUserMessage userMessage) {...}@Overridepublic void resendMessage(FlowUserMessage userMessage) {...}}

四、参考资料

《重学Java设计模式》

《设计模式》

http://c.biancheng.net/view/1390.html

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

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

相关文章

AI绘画Midjourney绘画提示词Prompt大全

AI绘画Midjourney绘画提示词Prompt大全

一、Midjourney绘画工具 SparkAi创作系统是基于ChatGPT进行开发的Ai智能问答系统和Midjourney绘画系统&#xff0c;支持OpenAI-GPT全模型国内AI全模型。本期针对源码系统整体测试下来非常完美&#xff0c;可以说SparkAi是目前国内一款的ChatGPT对接OpenAI软件系统。那么如何搭…
阅读更多...
高版本ant-design动态引用icon

高版本ant-design动态引用icon

需求 最近在更新自己的博客系统&#xff0c;从 vue2 升到 vue3&#xff0c;同步的也把 ant-design 从 1.7.8 跨越多个大版本升级到了 4.0.8&#xff0c;发现菜单上的 icon 报错了。 查询官方文档发现自从 2.0 版本以后的 icon 就不再支持通过 <a-icon /> 组件动态 type…
阅读更多...
uniapp 文字超出多少字，显示收起全文按钮效果demo（整理）

uniapp 文字超出多少字，显示收起全文按钮效果demo（整理）

收起展开 <template><view class"font30 color000 mL30 mR30"><text :class"showFullText ? : clamp-text">{{ text }}</text><view v-if"showToggleBtn && text.length > 42" click"toggleShowFu…
阅读更多...
Python：类型标注解决循环引用问题most likely due to a circular import

Python：类型标注解决循环引用问题most likely due to a circular import

两个模块&#xff0c;我们需要做类型标注&#xff0c;于是出现了循环引用的问题 # models.py from controllers import BookControllerclass Book:def get_controller(self) -> BookController:return BookController(self)# controllers.py from models import Bookclass …
阅读更多...
基于多目标粒子群算法的支配解求解，基于多目标粒子群的帕累托前沿求解，基于mopso的多目标求解，基于mopso+bp的多目标求解资源

基于多目标粒子群算法的支配解求解，基于多目标粒子群的帕累托前沿求解，基于mopso的多目标求解，基于mopso+bp的多目标求解资源

目录 摘要 测试函数shubert 粒子群算法的原理 粒子群算法的主要参数 粒子群算法原理 基于多目标粒子群算法的支配解求解，基于多目标粒子群的帕累托前沿求解，基于mopso的多目标求解，基于mopso+bp的多目标求解资源 代码 结果分析 展望 代码下载：基于多目标粒子群算法的支配解…
阅读更多...
Github 2024-01-07 开源项目日报 Top10

Github 2024-01-07 开源项目日报 Top10

根据Github Trendings的统计&#xff0c;今日(2024-01-07统计)共有10个项目上榜。根据开发语言中项目的数量&#xff0c;汇总情况如下&#xff1a; 开发语言项目数量Python项目4Jupyter Notebook项目2Go项目2C#项目1Starlark项目1非开发语言项目1Java项目1 跨平台应用程序UI框…
阅读更多...
qt信号和槽

qt信号和槽

Qt是一个跨平台的C图形用户界面应用框架 91年奇趣科技开发 pro工程文件介绍 .pro就是工程文件(project)&#xff0c;它是qmake自动生成的用于生产makefile的配置文件 QT core gui //Qt包含的模块greaterThan(QT_MAJOR_VERSION, 4): QT widgets //大于4版本包含…
阅读更多...
openssl ans1定义的实体

openssl ans1定义的实体

由于openssl中的ASN1的结构是通过宏来定义的&#xff0c;导致我们经常找不到他的结构在哪里&#xff0c;通过阅读rfc&#xff0c;并且对照OPENSSL&#xff0c;发现OPENSSL中的结构基本是按照相关rfc中的名称&#xff0c;在openssl中进行搜索&#xff0c;就能找到具体的定义了。…
阅读更多...
在线制作假期承诺书，电子手写签名确认，一键导出打印。

在线制作假期承诺书，电子手写签名确认，一键导出打印。

假期将至&#xff0c;为积极落实安全管理规定&#xff0c;单位通常需要下发安全承诺书进行签字确认。 易查分可以实现网上下发安全承诺书通知&#xff0c;让查询者进行签名确认&#xff0c;还可以生成PDF&#xff0c;方便打印一人一张的纸质版承诺书&#xff0c;本次就来介绍如…
阅读更多...
docker-compose安装及常用指令学习和harbor安装使用

docker-compose安装及常用指令学习和harbor安装使用

文章目录 1 docker-compose1.1 docker-compose安装1.2 docker-compose卸载1.3 docker-compose常用命令 2 harbor安装使用2.1 harbor安装2.2 harbor使用 1 docker-compose ​ 在实际生产环境中&#xff0c;一个应用往往由许多服务构成&#xff0c;而 docker 的最佳实践是一个容…
阅读更多...
java碳排放数据信息管理系统Myeclipse开发mysql数据库web结构java编程计算机网页项目

java碳排放数据信息管理系统Myeclipse开发mysql数据库web结构java编程计算机网页项目

一、源码特点 java Web碳排放数据信息管理系统是一套完善的java web信息管理系统&#xff0c;对理解JSP java编程开发语言有帮助&#xff0c;系统具有完整的源代码和数据库&#xff0c;系统主要采用B/S模式开发。开发环 境为TOMCAT7.0,Myeclipse8.5开发&#xff0c;数据库为…
阅读更多...
1.7 OVERARCHING GOALS

1.7 OVERARCHING GOALS

我们的主要目标是教读者如何对大规模并行处理器进行编程以实现高性能&#xff0c;我们的方法不需要大量的硬件专业知识。因此&#xff0c;我们将用许多页面来开发高性能并行程序的技术。而且&#xff0c;我们相信&#xff0c;一旦你发展正确的洞察力并以正确的方式进行&#xf…
阅读更多...
阿里云ECS云服务器客户端下载

阿里云ECS云服务器客户端下载

天行健&#xff0c;君子以自强不息&#xff1b;地势坤&#xff0c;君子以厚德载物。 每个人都有惰性&#xff0c;但不断学习是好好生活的根本&#xff0c;共勉&#xff01; 文章均为学习整理笔记&#xff0c;分享记录为主&#xff0c;如有错误请指正&#xff0c;共同学习进步。…
阅读更多...
计算机网络-VLAN原理与配置

计算机网络-VLAN原理与配置

之前我们学习了以太网的基础知识&#xff0c;了解了网络交换设备的发展&#xff0c;交换机的工作原理&#xff0c;广播域和冲突域。 一、概述 还简单了解了以太网的CSMA/CD通讯机制&#xff0c;以太网是建立在CSMA/CD (Carrier Sense Multiple Access/Collision Detection&…
阅读更多...
2024 电子科技大学 《820 计算机专业基础》真题及解析（更新中...）

2024 电子科技大学 《820 计算机专业基础》真题及解析（更新中...）

数据结构算法题&#xff08;15 分&#xff0c;8 7&#xff09; 1. 比较一棵二叉树的终端节点到根节点的路径长度&#xff0c;路径长度为关键字之和&#xff0c;输出路径长度最短的终端节点。 输入&#xff1a;第一行输入一个整数 n, 表示结点的个数&#xff0c;第二行输入二叉…
阅读更多...
Rustdesk打开Win10 下客户端下面服务不会自启，显示服务未运行

Rustdesk打开Win10 下客户端下面服务不会自启，显示服务未运行

环境： Rustdesk1.19 问题描述： Rustdesk打开Win10 下客户端下面服务不会自启，显示服务未运行 解决方案： 1.查看源代码 pub async fn start_all() {crate::hbbs_http::sync::start();let mut nat_tested = false;check_zombie()
阅读更多...
go work

go work

vscode gopls插件工具依赖go work,否则会报错 https://github.com/golang/tools/blob/master/gopls/doc/workspace.md Go 1.18 新特性多模块工作区教程-让多模块开发变得简单 - Go语言中文网 - Golang中文社区
阅读更多...
A2DP Source如何从android系统拿到音频数据

A2DP Source如何从android系统拿到音频数据

Android 13 简单来说就是两条本地socket通道&#xff0c;分别使用文件&#xff1a; #define A2DP_CTRL_PATH "/data/misc/bluedroid/.a2dp_ctrl" #define A2DP_DATA_PATH "/data/misc/bluedroid/.a2dp_data" A2DP_CTRL_PATH是控制通道&#xff0c;A2DP…
阅读更多...
物联网协议Coap中Californium CoapClient解析

物联网协议Coap中Californium CoapClient解析

目录 前言 一、CoapClient对象 1、类定义 2、Client方法调用 二、发送请求 1、构建请求 2、发起请求 3、接收响应 总结 前言 在之前的博客中物联网协议Coap之Californium CoapServer解析&#xff0c;文中简单介绍了CoapServer的实现。在物联网开发环境中&#xff0c;除了…
阅读更多...
给Flutter + FireBase 增加 badge 徽章，App启动器 通知红点。

给Flutter + FireBase 增加 badge 徽章，App启动器 通知红点。

在此之前需要配置好 firebase 在flutter 在项目中。&#xff08;已经配置好的可以忽略此提示&#xff09; Firebase 配置教程&#xff1a;flutter firebase 云消息通知教程 (android-安卓、ios-苹果)_flutter firebase_messaging ios环境配置-CSDN博客 由于firebase 提供的消息…
阅读更多...
最新文章

Copyright @ 2022~2023