Spring的监听机制详解
Spring的监听机制详解
讲在前面
对Spring框架,大家都已不陌生,它给我们提供了很多功能,包括IoC、AOP、事务管理等。其中,Spring的事件监听机制是一项非常重要的功能,它允许开发人员定义和处理自定义事件,并在应用程序中发布和监听这些事件。
这个机制可以让我们更加灵活地响应应用程序中发生的事件,同时还可以减少不同组件之间的耦合度。本文老朱将介绍Spring的事件监听机制,包括如何使用Spring提供的标准事件和如何定义和处理自定义事件。同时,我们还将讨论这个机制的底层原理和常见的应用场景。
1 Spring事件监听机制的原理
Spring 的监听机制是非常优秀的思想,它能够很好地实现代码解耦,将业务逻辑与非业务逻辑分离,让程序变得更加灵活和可维护。在业务开发中,我们可以借鉴这种思想,例如电商下单场景,下单业务的核心逻辑只与下单有关,但下单完成后,我们需要执行非业务逻辑,如发通知和记录用户行为日志,这些非业务逻辑可以通过监听器来解耦,从而实现代码的灵活和可维护性。那么监听机制的底层原理是什么呢?我们一起分析下。
实现Spring事件机制主要有4个接口:
1.1 ApplicationEventPublisher:事件发布
javaCopy code
public interface ApplicationEventPublisher {void publishEvent(ApplicationEvent event);void publishEvent(Object event);
1.2 ApplicationListener:事件监听
public interface ApplicationListener<E extends ApplicationEvent> extends EventListener {void onApplicationEvent(E event);
}
1.3 ApplicationEvent:事件
public abstract class ApplicationEvent extends EventObject {private final long timestamp;public ApplicationEvent(Object source) {super(source);this.timestamp = System.currentTimeMillis();}public long getTimestamp() {return this.timestamp;}public String toString() {return getClass().getSimpleName() + "{timestamp=" + this.timestamp + ", source=" + getSource() + "}";}
}
1.4 ApplicationEventMulticaster:事件广播器,Spring中负责事件的发布和监听的核心接口
public interface ApplicationEventMulticaster {//用于向事件广播器注册一个监听器。在广播器发送事件时,这个监听器将会接收到事件。void addApplicationListener(ApplicationListener<?> listener);//用于将一个已经注册的监听器从事件广播器中移除。void removeApplicationListener(ApplicationListener<?> listener);//用于移除所有注册的监听器。void removeAllListeners();//用于向所有已注册的监听器广播一个事件。void multicastEvent(ApplicationEvent event);
}
Spring的源码中,当初始化beanfacotory时,我们会发现Spring会初始化事件广播器以及注册事件监听器源码如下,标红的源码你们追进去看看,逻辑很简单。

2 Spring框架内部事件监听机制的应用
在Spring框架中,有许多预定义的事件,这些事件涵盖了Spring的生命周期、Web应用程序上下文的生命周期以及许多其他方面。下面是一些常见的Spring事件:
ContextRefreshedEvent:
当ApplicationContext被初始化或刷新时触发该事件。
ContextStartedEvent:
当ApplicationContext被启动时触发该事件,即在所BeanDefinition都已加载和bean初始化之后。
ContextStoppedEvent:
当ApplicationContext被停止时触发该事件,即在所有singleton bean被销毁之前。
ContextClosedEvent:
当ApplicationContext被关闭时触发该事件,即在所有singleton bean被销毁之后。
RequestHandledEvent:
在Web应用程序上下文中,当HTTP请求被处理完毕后触发该事件。
ServletRequestHandledEvent:
与RequestHandledEvent类似,但是专为Spring的DispatcherServlet设计。
除了这些预定义的事件之外,开发人员还可以创建自己的自定义事件,并使用ApplicationEventPublisher接口将其发布到应用程序上下文中。
3 自定义监听
假设我们正在开发一个在线商城应用程序,我们需要在用户下单时发送一个通知邮件给商家。为了实现这个功能,我们可以使用自定义事件来触发邮件发送操作。
首先,我们需要定义一个名为OrderPlacedEvent的自定义事件,用于表示用户下单的事件。代码如下:
package com.qf.listener;import org.springframework.context.ApplicationEvent;public class OrderPlacedEvent extends ApplicationEvent {private Order order;public OrderPlacedEvent(Object source, Order order) {super(source);this.order = order;}public Order getOrder() {return order;}
}
在上述代码中,我们定义了一个名为OrderPlacedEvent的自定义事件,并通过实现构造函数和getOrder()方法来传递订单参数和获取订单参数。
然后,我们需要定义一个名为OrderPlacedEventListener的自定义事件监听器,用于处理用户下单事件并触发邮件发送操作。代码如下:
package com.qf.listener;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.event.EventListener;import org.springframework.stereotype.Component;@Component
public class OrderPlacedEventListener {@EventListenerpublic void handleOrderPlacedEvent(OrderPlacedEvent event) {Order order = event.getOrder();String message = "您有一个新的订单,订单号为:" + order.getOid();//todo 发邮件System.out.println("message = " + message);}
}
在上述代码中,我们定义了一个名为OrderPlacedEventListener的自定义事件监听器,在handleOrderPlacedEvent()方法中,我们从事件对象中获取订单参数,然后发送邮件(具体邮件代码此处省略)最后,当用户下单成功时,我们需要在订单服务对象中触发OrderPlacedEvent事件,以便通知邮件能够被发送。代码如下:
package com.qf.listener;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;@Service
public class OrderService {@Autowiredprivate ApplicationEventPublisher eventPublisher;public void placeOrder(Order order) {// 订单保存逻辑// ...// 触发订单下单事件eventPublisher.publishEvent(new OrderPlacedEvent(this, order));}
}
在上述代码中,我们定义了一个名为OrderService的订单服务对象,并使用@Autowired注解来注入一个事件发布器对象。在placeOrder()方法中,我们调用订单保存逻辑,然后使用事件发布器对象触发OrderPlacedEvent事件,并传递订单参数。
通过上述代码,我们可以在用户下单时触发OrderPlacedEvent事件,并通过自定义事件监听器处理该事件并触发邮件发送操作。
4 Spring事件监听机制的优点
Spring事件监听机制具有以下优点:
1.松耦合:通过事件监听机制,组件之间的耦合度得到了很大的降低,每个组件只需要监听自己感兴趣的事件,不需要关心其他组件的实现细节。
2.可扩展性:通过定义新的事件类型和监听器,应用程序的功能可以随着需求的变化而不断扩展。
3.高可靠性:事件监听机制可以保证应用程序的可靠性,即使某个组件出现异常或错误,其他组件仍然可以正常运行。
5 总结
Spring 监听机制是一种非常优秀的设计模式(观察者模式),它可以实现代码的解耦和模块化。通过定义事件和监听器,我们可以将代码的不同模块分离开来,以便更好地维护和修改。Spring 框架内置了许多事件和监听器,如上下文事件、Bean 事件、Web 事件等,开发者也可以根据具体需求自定义事件和监听器。
对于开发者来说,使用 Spring 监听机制非常简单。只需要实现事件和监听器接口,并在代码中注册监听器即可。Spring 会自动管理事件和监听器的生命周期,确保它们的正确运行。同时,由于 Spring 监听器使用了异步执行机制,因此不会影响主线程的运行效率,保证了应用程序的高并发和高效性。
相关文章:
Spring的监听机制详解
Spring的监听机制详解 讲在前面 对Spring框架,大家都已不陌生,它给我们提供了很多功能,包括IoC、AOP、事务管理等。其中,Spring的事件监听机制是一项非常重要的功能,它允许开发人员定义和处理自定义事件,并…...
Cache结构
Cache cache的一般设计 超标量处理器每周期需要从Cache中同时读取多条指令,同时每周期也可能有多条load/store指令会访问Cache,因此需要多端口的Cache L1 Cache:最靠近处理器,是流水线的一部分,包含两个物理存在 指…...
国产版Sora复现——智谱AI开源CogVideoX-2b 本地部署复现实践教程
目录 一、CogVideoX简介二、CogVideoX部署实践流程2.1、创建丹摩实例2.2、配置环境和依赖2.3、上传模型与配置文件2.4、开始运行 最后 一、CogVideoX简介 智谱AI在8月6日宣布了一个令人兴奋的消息:他们将开源视频生成模型CogVideoX。目前,其提示词上限为…...
怎么读取FRM、MYD、MYI数据文件
一、介绍frm、MYD、MYI文件 在MySQL中,使用MyISAM存储引擎时,数据库表会被分割成几个不同的文件文件描述功能扩展名FRM 文件表结构定义文件存储表的结构信息,字段、索引等.FRMMYD 文件数据文件包含表的实际数据.MYD(MYData&#x…...
Leetcode3226. 使两个整数相等的位更改次数
Every day a Leetcode 题目来源:3226. 使两个整数相等的位更改次数 解法1:位运算 从集合的角度理解,k 必须是 n 的子集。如果不是,返回 −1。怎么用位运算判断,见上面的文章链接。 如果 k 是 n 的子集,…...
Linux笔记-3()
目录 一、Linuⅸ实操篇-定时任务调度 二、Linuⅸ实操篇-Linuⅸ磁盘分区、挂载 三、Linux实操篇-网络配置 一、Linuⅸ实操篇-定时任务调度 1 crond任务调度---crontab进行定时任务的设置1.1 概述任务调度:是指系统在某个时间执行的特定的命令或程序。任务调度分类…...
Apache漏洞复现CVE-2021-41773
Apache HTTP Server 路径穿越漏洞 漏洞简介 该漏洞是由于Apache HTTP Server 2.4.49版本存在目录穿越漏洞,在路径穿越目录 <Directory/>Require all granted</Directory>允许被访问的的情况下(默认开启),攻击者可利用该路径穿越…...
GIT如何将远程指定分支的指定提交拉回到本地分支
一、当前我的代码在这个提交,但可以看到远程仓库上面还有两次新的提交 二、现在我想让我本次的代码更新到最上面这个最新的提交 三、输入git fetch命令获取远程分支的最新提交信息。 四、输入 git log origin/<remote_branch_name>查看并找到想要更新的指定提…...
鸿蒙图形开发【3D引擎接口示例】
介绍 本实例主要介绍3D引擎提供的接口功能。提供了ohos.graphics.scene中接口的功能演示。 3D引擎渲染的画面会被显示在Component3D这一控件中。点击按钮触发不同的功能,用户可以观察渲染画面的改变。 效果预览 使用说明 在主界面,可以点击按钮进入不…...
C#实现数据采集系统-系统优化服务封装
系统优化-服务封装 现在我们调用modbustcp和mqtt都直接在Program,所有加载和功能都混合在一起,比较难以维护 类似asp.net core项目的Program.cs代码如下,构建服务配置和启动 要实现的效果,Main方法中就是一个服务启动,只需要几行代码 分析代码 这里分成两部分,一…...
数据结构与算法--栈、队列篇
一、计算机领域的地位 在计算机科学的广袤领域中,数据结构犹如一座精巧的大厦,为信息的存储和处理提供了坚实的框架。而在众多的数据结构中,栈和队列宛如两颗璀璨的明珠,各自闪耀着独特的光芒。 栈和队列虽然看似简单&…...
【程序、游戏、人生】致敬飞逝的3年和新的开始
人,总要向前看。 感谢之前关注的朋友,感谢各位朋友的私信、感谢关心的评论。 不要停下 20年:某银行业务三方开发。 21年:移动内部业务平台开发移动物联网商城开发储备TPL。 22年-至今:手游发行技术综合北漂 经历了行…...
第三届人工智能、人机交互与机器人国际会议
国际人工智能、人机交互和机器人会议是一项年度活动,汇集了来自世界各地的研究人员、从业者和行业专业人士,分享他们在人工智能、人际交互和机器人领域的知识和专业知识。在过去的几十年里,这些领域在计算能力、数据分析和机器学习技术的进步…...
AWS生成式AI项目的全生命周期管理
随着人工智能技术的迅速发展,生成式 AI 已成为当今最具创新性和影响力的领域之一。生成式 AI 能够创建新的内容,如文本、图像、音频等,具有广泛的应用前景,如自然语言处理、计算机视觉、创意设计等。然而,构建一个成功…...
windows go grpc
windows环境安装go grpc 的工具和插件 在Windows环境下,安装Protocol Buffers(proto)和gRPC相关的工具和插件,可以通过以下几个步骤进行 1.安装protoc 在git 仓库下载tag 包 https://github.com/protocolbuffers/protobuf/rele…...
Leetcode 第 135 场双周赛题解
Leetcode 第 135 场双周赛题解 Leetcode 第 135 场双周赛题解题目1:3222. 求出硬币游戏的赢家思路代码复杂度分析 题目2:3223. 操作后字符串的最短长度思路代码复杂度分析 题目3:3224. 使差值相等的最少数组改动次数思路代码复杂度分析 题目4…...
rpc的原理
RPC(Remote Procedure Call,远程过程调用)是一种编程模型,它允许开发者像调用本地函数一样调用位于不同进程或者不同机器上的函数或服务。这种抽象简化了分布式系统的开发,使得开发人员无需关注底层网络通信细节&#…...
【无线通信发展史-第二篇】,带你走进查利·奥古斯丁·库仑的世界,了解(库伦定律)-(扭秤实验)-(如何测量出静电力常量)
前言:用这几个问答形式来解读下我这个系列的来龙去脉。如果大家觉得本篇文章不水的话希望帮忙点赞收藏加关注,你们的鼓舞是我继续更新的动力。 我为什么会写这个系列呢? 首先肯定是因为我本身就是一名从业通信者,想着更加了解自…...
CAPL使用结构体的方式组装一条DoIP车辆声明消息(方法2)
在文章CAPL使用结构体的方式组装一条DoIP车辆声明消息(方法1)中,我们声明一个结构体DoIPMessage表示完整的DoIP车辆声明消息: 上半部分是DoIP报头通用部分(也就是所有类型的DoIP消息都有的),而payload是每个类型的DoIP消息独有的部分,对于车辆声明消息来说,用另一个结…...
基于Matlab的车牌识别系统设计与实现
基于Matlab的车牌识别系统设计与实现 摘要 随着智能交通系统的不断演进,车牌识别技术已成为提升交通管理效率与准确性的关键。本文深入探讨了基于Matlab平台的车牌识别系统设计与实现,该系统通过精细的图像预处理、高效的车牌定位算法、精准的字符分割…...
LBE-LEX系列工业语音播放器|预警播报器|喇叭蜂鸣器的上位机配置操作说明
LBE-LEX系列工业语音播放器|预警播报器|喇叭蜂鸣器专为工业环境精心打造,完美适配AGV和无人叉车。同时,集成以太网与语音合成技术,为各类高级系统(如MES、调度系统、库位管理、立库等)提供高效便捷的语音交互体验。 L…...
【ROS】Nav2源码之nav2_behavior_tree-行为树节点列表
1、行为树节点分类 在 Nav2(Navigation2)的行为树框架中,行为树节点插件按照功能分为 Action(动作节点)、Condition(条件节点)、Control(控制节点) 和 Decorator(装饰节点) 四类。 1.1 动作节点 Action 执行具体的机器人操作或任务,直接与硬件、传感器或外部系统…...
OkHttp 中实现断点续传 demo
在 OkHttp 中实现断点续传主要通过以下步骤完成,核心是利用 HTTP 协议的 Range 请求头指定下载范围: 实现原理 Range 请求头:向服务器请求文件的特定字节范围(如 Range: bytes1024-) 本地文件记录:保存已…...
【2025年】解决Burpsuite抓不到https包的问题
环境:windows11 burpsuite:2025.5 在抓取https网站时,burpsuite抓取不到https数据包,只显示: 解决该问题只需如下三个步骤: 1、浏览器中访问 http://burp 2、下载 CA certificate 证书 3、在设置--隐私与安全--…...
linux 下常用变更-8
1、删除普通用户 查询用户初始UID和GIDls -l /home/ ###家目录中查看UID cat /etc/group ###此文件查看GID删除用户1.编辑文件 /etc/passwd 找到对应的行,YW343:x:0:0::/home/YW343:/bin/bash 2.将标红的位置修改为用户对应初始UID和GID: YW3…...
微服务商城-商品微服务
数据表 CREATE TABLE product (id bigint(20) UNSIGNED NOT NULL AUTO_INCREMENT COMMENT 商品id,cateid smallint(6) UNSIGNED NOT NULL DEFAULT 0 COMMENT 类别Id,name varchar(100) NOT NULL DEFAULT COMMENT 商品名称,subtitle varchar(200) NOT NULL DEFAULT COMMENT 商…...
leetcodeSQL解题:3564. 季节性销售分析
leetcodeSQL解题:3564. 季节性销售分析 题目: 表:sales ---------------------- | Column Name | Type | ---------------------- | sale_id | int | | product_id | int | | sale_date | date | | quantity | int | | price | decimal | -…...
全面解析各类VPN技术:GRE、IPsec、L2TP、SSL与MPLS VPN对比
目录 引言 VPN技术概述 GRE VPN 3.1 GRE封装结构 3.2 GRE的应用场景 GRE over IPsec 4.1 GRE over IPsec封装结构 4.2 为什么使用GRE over IPsec? IPsec VPN 5.1 IPsec传输模式(Transport Mode) 5.2 IPsec隧道模式(Tunne…...
vulnyx Blogger writeup
信息收集 arp-scan nmap 获取userFlag 上web看看 一个默认的页面,gobuster扫一下目录 可以看到扫出的目录中得到了一个有价值的目录/wordpress,说明目标所使用的cms是wordpress,访问http://192.168.43.213/wordpress/然后查看源码能看到 这…...
JavaScript 数据类型详解
JavaScript 数据类型详解 JavaScript 数据类型分为 原始类型(Primitive) 和 对象类型(Object) 两大类,共 8 种(ES11): 一、原始类型(7种) 1. undefined 定…...
