观察者模式原理详解以及Spring源码如何使用观察者模式?
前言
首先说明观察者模式,观察者模式,也叫发布-订阅模式,应该是用来处理对象间的一对多依赖关系的。当被观察者的状态变化时,所有依赖它的观察者都会得到通知并自动更新。
观察者模式的结构,通常包括Subject(主题)和Observer(观察者)两个主要角色。Subject维护一个观察者列表,提供注册和移除的方法,还有通知观察者的方法。Observer则有一个更新方法,当Subject状态变化时被调用。可能还有具体的ConcreteSubject和ConcreteObserver,实现具体的业务逻辑。
Spring框架中有很多地方用到了观察者模式,特别是事件驱动模型。比如ApplicationEvent和ApplicationListener,用户自定义事件,然后通过ApplicationContext发布事件,监听器会接收到这些事件进行处理。这是典型的观察者模式的应用。
需要详细说明Spring中的事件机制。ApplicationEvent是所有事件的父类,自定义事件需要继承它。ApplicationListener是观察者接口,实现onApplicationEvent方法来处理事件。ApplicationContext作为事件发布者,有publishEvent方法。当事件发布时,所有注册的监听该事件类型的监听器都会被触发。
另外,Spring的事件传播机制可能涉及到同步和异步处理。默认是同步的,但可以通过配置实现异步监听,比如使用@Async注解或者配置TaskExecutor。
还涉及Spring内置的一些事件,比如ContextRefreshedEvent、ContextStartedEvent等,这些事件在容器生命周期不同阶段发布,监听器可以响应这些事件执行相应逻辑。
在本文中会结合源码分析,ApplicationContext的publishEvent方法内部如何获取监听器,如何调用他们的onApplicationEvent方法。可能涉及到ApplicationEventMulticaster这个类,它负责管理监听器和事件广播。具体实现类SimpleApplicationEventMulticaster,使用线程池支持异步事件处理。
其中,Spring中的观察者模式与传统观察者模式的区别,比如Spring使用ApplicationContext作为事件发布者,而传统模式可能由Subject直接维护观察者列表。此外,Spring支持基于注解的事件监听,比如@EventListener,简化了监听器的注册和使用。
学完本篇可以在项目中使用观察者模式,比如通过自定义事件和监听器实现解耦的业务逻辑。比如订单创建后发送邮件通知,可以定义一个OrderCreatedEvent,监听器处理发送邮件的逻辑,这样订单服务和邮件服务就解耦了。
还需要注意可能的问题,比如监听器的执行顺序,异常处理,异步监听时的线程池配置等。这些都是实际使用中需要考虑的。
总结来说,回答需要分两部分:观察者模式的原理,包括结构、角色和流程;然后是Spring中的具体实现,结合事件机制和源码分析,说明如何利用ApplicationEvent、ApplicationListener以及相关类来实现观察者模式,并给出实际应用示例。
观察者模式原理详解及 Spring 源码应用分析
一、观察者模式(Observer Pattern)原理
核心思想:定义对象间的一对多依赖关系,当一个对象(被观察者/主题)状态发生改变时,所有依赖它的对象(观察者)会自动收到通知并更新。
别名:发布-订阅模式(Pub-Sub)。
1. 模式结构
| 角色 | 职责 |
|---|---|
| Subject(主题) | 维护观察者列表,提供注册、移除和通知观察者的方法。 |
| Observer(观察者) | 定义更新接口,用于接收主题状态变化的通知。 |
| ConcreteSubject | 具体主题,实现状态变更逻辑,并在状态变化时通知所有观察者。 |
| ConcreteObserver | 具体观察者,实现更新逻辑以响应主题状态变化。 |
2. 类图
+----------------+ +----------------+
| Subject | | Observer |
+----------------+ +----------------+
| +attach(Observer)| <------| +update():void |
| +detach(Observer)| +----------------+
| +notify() | ^
+----------------+ |^ || |
+----------------+ +------------------+
| ConcreteSubject | | ConcreteObserver |
+----------------+ +------------------+
| +getState() | | +update() |
| +setState() | +------------------+
+----------------+
3. 执行流程
- 观察者注册:
ConcreteObserver调用Subject.attach()注册到主题。 - 状态变更触发通知:
ConcreteSubject调用setState()修改状态后,触发notify()。 - 广播通知:
Subject遍历观察者列表,调用每个观察者的update()方法。
二、Spring 源码中的观察者模式实现
Spring 通过 事件驱动模型 实现观察者模式,核心涉及以下组件:
ApplicationEvent:所有事件的基类(如ContextRefreshedEvent)。ApplicationListener:观察者接口,监听特定事件。ApplicationEventPublisher:主题接口,用于发布事件(由ApplicationContext实现)。ApplicationEventMulticaster:事件广播器,管理监听器并分发事件。
1. Spring 事件机制核心流程
1. 定义事件 → 2. 发布事件 → 3. 监听器处理事件
2. 源码解析
(1)事件发布:ApplicationContext.publishEvent()
入口:AbstractApplicationContext#publishEvent
流程:
public void publishEvent(ApplicationEvent event) {getApplicationEventMulticaster().multicastEvent(event); // 广播事件// 若父容器存在,递归向上传播事件if (this.parent != null) {this.parent.publishEvent(event);}
}
(2)事件广播:ApplicationEventMulticaster
实现类:SimpleApplicationEventMulticaster
关键方法:multicastEvent()
public void multicastEvent(ApplicationEvent event) {for (ApplicationListener<?> listener : getApplicationListeners(event)) {// 判断是否支持异步执行Executor executor = getTaskExecutor();if (executor != null) {executor.execute(() -> invokeListener(listener, event));} else {invokeListener(listener, event); // 同步调用监听器}}
}private void invokeListener(ApplicationListener listener, ApplicationEvent event) {listener.onApplicationEvent(event); // 触发监听器逻辑
}
(3)监听器注册与匹配
- 注册:Spring 容器启动时,自动扫描所有实现
ApplicationListener的 Bean。 - 匹配规则:通过
supportsEventType()检查监听器是否支持当前事件类型。
示例:GenericApplicationListener 判断事件类型:
public boolean supportsEventType(ResolvableType eventType) {return (this.delegate == this || this.delegate.supportsEventType(eventType));
}
3. Spring 内置事件示例
| 事件类型 | 触发时机 |
|---|---|
ContextRefreshedEvent | 容器初始化或刷新完成时(所有 Bean 已加载)。 |
ContextStartedEvent | 调用 ConfigurableApplicationContext.start() 时。 |
ContextStoppedEvent | 调用 ConfigurableApplicationContext.stop() 时。 |
RequestHandledEvent | HTTP 请求处理完成后。 |
三、Spring 观察者模式的实际应用
1. 自定义事件与监听器
步骤:
- 定义事件:继承
ApplicationEvent。 - 定义监听器:实现
ApplicationListener或使用@EventListener注解。 - 发布事件:通过
ApplicationContext.publishEvent()发布。
代码示例:
// 1. 自定义事件
public class OrderCreatedEvent extends ApplicationEvent {private String orderId;public OrderCreatedEvent(Object source, String orderId) {super(source);this.orderId = orderId;}public String getOrderId() { return orderId; }
}// 2. 监听器实现(注解方式)
@Component
public class EmailNotificationListener {@EventListenerpublic void handleOrderCreatedEvent(OrderCreatedEvent event) {System.out.println("发送邮件通知,订单ID: " + event.getOrderId());}
}// 3. 发布事件
@Service
public class OrderService {@Autowiredprivate ApplicationContext applicationContext;public void createOrder(String orderId) {// 业务逻辑...applicationContext.publishEvent(new OrderCreatedEvent(this, orderId));}
}
2. 异步事件处理
配置异步监听器:
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {@Overridepublic Executor getAsyncExecutor() {return Executors.newFixedThreadPool(5);}
}// 使用 @Async 注解异步处理
@Component
public class LoggingListener {@Async@EventListenerpublic void asyncLogOrderEvent(OrderCreatedEvent event) {System.out.println("异步记录日志,订单ID: " + event.getOrderId());}
}
3. 监听器执行顺序
通过 @Order 注解控制监听器执行顺序:
@EventListener
@Order(1)
public void firstListener(OrderCreatedEvent event) {System.out.println("第一个执行");
}@EventListener
@Order(2)
public void secondListener(OrderCreatedEvent event) {System.out.println("第二个执行");
}
四、Spring 观察者模式的设计优势
- 解耦业务逻辑
事件发布者与监听者无需直接交互,例如订单服务不依赖邮件服务。 - 扩展性强
新增监听器只需实现接口或添加注解,无需修改发布者代码。 - 支持异步处理
通过TaskExecutor实现异步事件处理,提升系统吞吐量。 - 事件传播机制
支持事件在容器层次结构中向上传播(如父子容器)。
五、总结
- 观察者模式核心:解耦主题与观察者,通过事件通知机制实现松耦合通信。
- Spring 实现:基于
ApplicationEvent、ApplicationListener和ApplicationEventMulticaster构建事件驱动模型。 - 应用场景:
- 业务流程解耦(如订单创建后发送通知、记录日志)。
- 系统生命周期管理(如容器启动后加载缓存)。
- 异步任务触发(如消息队列事件处理)。
源码设计亮点:
- 事件类型匹配:通过
ResolvableType动态解析事件类型,支持泛型事件。 - 灵活广播策略:
SimpleApplicationEventMulticaster支持同步/异步事件分发。 - 注解驱动简化:
@EventListener和@Async简化监听器定义与异步配置。
相关文章:
观察者模式原理详解以及Spring源码如何使用观察者模式?
前言 首先说明观察者模式,观察者模式,也叫发布-订阅模式,应该是用来处理对象间的一对多依赖关系的。当被观察者的状态变化时,所有依赖它的观察者都会得到通知并自动更新。 观察者模式的结构,通常包括Subject࿰…...
【Spring】Spring配置文件
目录 什么是配置文件? 配置文件的作用 SpringBoot配置文件 配置文件格式 配置文件的优先级 properties配置文件说明 properties基本语法 读取配置文件 properties缺点 yml配置文件说明 yml基本语法 使用yml连接数据库 yml配置不同数据类型及null 注意…...
MSI微星电脑冲锋坦克Pro Vector GP76 12UGS(MS-17K4)原厂Win11系统恢复镜像,含还原功能,预装OEM系统下载
适用机型:【MS-17K4】 链接:https://pan.baidu.com/s/1P8ZgXc6S_J9DI8RToRd0dQ?pwdqrf1 提取码:qrf1 微星笔记本原装出厂WINDOWS11系统自带所有驱动、出厂主题壁纸、系统属性专属联机支持标志、Office办公软件、MSI Center控制中心等预装…...
Unity合批处理优化内存序列帧播放动画
Unity合批处理序列帧优化内存 介绍图片导入到Unity中的处理Unity中图片设置处理Unity中图片裁剪 创建序列帧动画总结 介绍 这里是针对Unity序列帧动画的优化内容,将多个图片合批处理然后为了降低Unity的内存占用,但是相对的质量也会稍微降低。可自行进行…...
【Java】逻辑运算符详解:、|| 与、 | 的区别及应用
博客主页: [小ᶻ☡꙳ᵃⁱᵍᶜ꙳] 本文专栏: Java 文章目录 💯前言💯一、基本概念与运算符介绍💯二、短路与与非短路与:&& 与 & 的区别1. &&:短路与(AND)2. …...
深入解析 Flutter GetX
深入解析 Flutter GetX:从原理到实战 GetX 是 Flutter 中一个轻量级且功能强大的状态管理、路由管理和依赖注入框架。它以简单、快速、高效著称,适合从小型到大型项目的开发需求。GetX 的设计理念是一体化解决方案,通过一个框架解决状态管理…...
Java 大视界 -- 人才需求与培养:Java 大数据领域的职业发展路径(92)
💖亲爱的朋友们,热烈欢迎来到 青云交的博客!能与诸位在此相逢,我倍感荣幸。在这飞速更迭的时代,我们都渴望一方心灵净土,而 我的博客 正是这样温暖的所在。这里为你呈上趣味与实用兼具的知识,也…...
顺序表常用操作和笔试题
1、顺序表的常用操作 1.1 顺序表的创建 如下代码所示:创建了一个默认空间为10的整型顺序表,如果空间不足则会以1.5倍扩容。 List<Integer> list new ArrayList<>(); 创建一个空间为15的整型顺序表 List<Integer> list2 new ArrayL…...
List<Map<String, Object>> 如何对某个字段求和
在Java中,如果你有一个List<Map<String, Object>>的结构,并且你想要对某个特定字段进行求和,你可以使用Java 8的Stream API来简化这个过程。下面是一个示例代码,演示如何对某个字段进行求和。 假设你有一个List<M…...
2024亚马逊数据分析!
整体财务数据23 净销售额:全年净销售额达 6380 亿美元,同比增长 11%。 净利润:全年净利润为 592 亿美元,较上年同期的 304 亿美元增长 95%。 经营活动现金流:经营活动现金流达 1159 亿美元,同比增加了 36…...
foobar2000设置DSP使用教程及软件推荐
foobar2000安卓中文版:一款高品质手机音频播放器 foobar2000安卓中文版是一款备受好评的高品质手机音频播放器。 几乎支持所有的音频格式,包括 MP3、MP4、AAC、CD 音频等。不论是经典老歌还是最新的流行音乐,foobar2000都能完美播放。除此之…...
Apache Logic4j 库反序列化漏洞复现与深度剖析
前言 在渗透测试领域,反序列化漏洞一直是安全研究人员和攻击者关注的焦点。今天,我们将深入探讨 Apache Logic4j 库中的反序列化漏洞,详细了解其原理,并进行完整的复现演示。 一、漏洞原理 Apache Logic4j 库在处理对象的反序列…...
FPGA VIVADO:axi-lite 从机和主机
FPGA VIVADO:axi-lite 从机和主机 TOC在这里插入代码片 前言 协议就不详细讲解了,直接看手册即可。下面主要如何写代码和关键的时序。 此外下面的代码可以直接用于实际工程 一、AXI-LITE 主机 数据转axi lite接口: 读/写数据FIFO缓存 仲裁:…...
LabVIEW 中的 3dgraph.llb库
3dgraph.llb 库位于C:\Program Files (x86)\National Instruments\LabVIEW 2019\vi.lib\Platform目录下,是 LabVIEW 系统里用于 3D 图形相关操作的关键库。它为 LabVIEW 用户提供众多功能,可在应用程序内创建、显示和交互各类 3D 图形,极大增…...
【Linux】文件系统:文件fd
🔥个人主页:Quitecoder 🔥专栏:linux笔记仓 目录 01.回顾C文件接口02.系统文件I/O02.1 openflags 参数(文件打开模式)标记位传参1. 访问模式(必须指定一个)2. 额外控制标志…...
Vue学习记录19
TransitonGroup <TransitionGroup> 是一个内置组件,用于对 v-for 列表中的元素或组件的插入、移除和顺序改变添加动画效果。 和 <Transtion> 的区别 <TranstionGroup> 支持和 <Transtion> 基本相同的 props、CSS过渡 class 和 JavaScript…...
MATLAB更改图论的布局:设置layout
在图论那一章,我们讲过最小生成树和单源最短路径(见:从零开始学数学建模): 以最短路径那节课为例,把绘图pplot那部分代码写为: % plot绘图有很多参数可以设置,使图尽量美观 P plot…...
【分果果——DP(困难)】
题目 分析 分果果题解参考,下面是补充https://blog.csdn.net/AC__dream/article/details/129431299 关于状态 设f[i][j][k]表示第i个人取到的最后一个糖果编号是j,第i-1个人取到的最后一个糖果编号小于等于k时的最大重量的最小值 关于转移方程 关于 j …...
禁止WPS强制打开PDF文件
原文网址:禁止WPS强制打开PDF文件_IT利刃出鞘的博客-CSDN博客 简介 本文介绍如何避免WPS强制打开PDF文件。 方法 1.删除注册表里.pdf的WPS绑定 WinR,输入:regedit,回车。找到:HKEY_CLASSES_ROOT\.pdf删除KWPS.PDF…...
罗技鼠标接收器丢了,怎么用另一个logi接收器重新配对?
1.首先接收器得是logi的,其次看这个接收器是什么类型的,一共有以下3种。(这几种接收器都可以给其他logi鼠标用) 下图左侧带红标的这个(标可能带颜色或者是透明,都一样),叫多设备接收…...
Java面试专项一-准备篇
一、企业简历筛选规则 一般企业的简历筛选流程:首先由HR先筛选一部分简历后,在将简历给到对应的项目负责人后再进行下一步的操作。 HR如何筛选简历 例如:Boss直聘(招聘方平台) 直接按照条件进行筛选 例如:…...
Selenium常用函数介绍
目录 一,元素定位 1.1 cssSeector 1.2 xpath 二,操作测试对象 三,窗口 3.1 案例 3.2 窗口切换 3.3 窗口大小 3.4 屏幕截图 3.5 关闭窗口 四,弹窗 五,等待 六,导航 七,文件上传 …...
HubSpot推出与ChatGPT的深度集成引发兴奋与担忧
上周三,HubSpot宣布已构建与ChatGPT的深度集成,这一消息在HubSpot用户和营销技术观察者中引发了极大的兴奋,但同时也存在一些关于数据安全的担忧。 许多网络声音声称,这对SaaS应用程序和人工智能而言是一场范式转变。 但向任何技…...
MySQL的pymysql操作
本章是MySQL的最后一章,MySQL到此完结,下一站Hadoop!!! 这章很简单,完整代码在最后,详细讲解之前python课程里面也有,感兴趣的可以往前找一下 一、查询操作 我们需要打开pycharm …...
ubuntu系统文件误删(/lib/x86_64-linux-gnu/libc.so.6)修复方案 [成功解决]
报错信息:libc.so.6: cannot open shared object file: No such file or directory: #ls, ln, sudo...命令都不能用 error while loading shared libraries: libc.so.6: cannot open shared object file: No such file or directory重启后报错信息&…...
五子棋测试用例
一.项目背景 1.1 项目简介 传统棋类文化的推广 五子棋是一种古老的棋类游戏,有着深厚的文化底蕴。通过将五子棋制作成网页游戏,可以让更多的人了解和接触到这一传统棋类文化。无论是国内还是国外的玩家,都可以通过网页五子棋感受到东方棋类…...
前端开发者常用网站
Can I use网站:一个查询网页技术兼容性的网站 一个查询网页技术兼容性的网站Can I use:Can I use... Support tables for HTML5, CSS3, etc (查询浏览器对HTML5的支持情况) 权威网站:MDN JavaScript权威网站:JavaScript | MDN...
Python常用模块:time、os、shutil与flask初探
一、Flask初探 & PyCharm终端配置 目的: 快速搭建小型Web服务器以提供数据。 工具: 第三方Web框架 Flask (需 pip install flask 安装)。 安装 Flask: 建议: 使用 PyCharm 内置的 Terminal (模拟命令行) 进行安装,避免频繁切换。 PyCharm Terminal 配置建议: 打开 Py…...
负载均衡器》》LVS、Nginx、HAproxy 区别
虚拟主机 先4,后7...
DAY 45 超大力王爱学Python
来自超大力王的友情提示:在用tensordoard的时候一定一定要用绝对位置,例如:tensorboard --logdir"D:\代码\archive (1)\runs\cifar10_mlp_experiment_2" 不然读取不了数据 知识点回顾: tensorboard的发展历史和原理tens…...
