当前位置: 首页 > news >正文

spring事件监听的核心机制

Spring 事件监听机制的核心是基于观察者模式(Observer Pattern) 实现的组件间解耦通信机制,通过事件(Event)、监听器(Listener)、事件发布者(Publisher) 三者的协作,实现 “发布 - 订阅” 式的交互。其核心目标是让组件之间无需直接依赖,通过事件传递信息,从而降低耦合度。

核心机制的关键组成

Spring 事件监听机制的核心由以下 4 个部分构成,它们协同工作完成事件的发布与处理:

1. 事件(Event):信息的载体

事件是传递数据的载体,所有事件需直接或间接继承 Spring 提供的ApplicationEvent类(Spring 4.2 + 后可省略继承,支持任意对象作为事件)。
 
  • 内置事件:Spring 定义了一系列容器生命周期相关的事件(如ContextRefreshedEvent容器初始化完成、ContextClosedEvent容器关闭等),用于通知容器状态变化。
  • 自定义事件:用户可通过继承ApplicationEvent定义业务事件,携带业务数据(如OrderCreatedEvent订单创建事件,包含订单 ID、用户信息等)。
 
示例:自定义订单创建事件
 
java
 
运行
 
public class OrderCreatedEvent extends ApplicationEvent {private Long orderId;private String username;// 构造方法需传入事件源(发布事件的对象)public OrderCreatedEvent(Object source, Long orderId, String username) {super(source);this.orderId = orderId;this.username = username;}// getters
}
 

2. 监听器(Listener):事件的处理者

监听器是事件的 “订阅者”,负责定义事件发生后的处理逻辑。Spring 中监听器的实现方式有两种:
 
  • 实现ApplicationListener接口:泛型指定监听的事件类型,重写onApplicationEvent方法处理事件。
  • 使用@EventListener注解:在方法上标注该注解,并指定监听的事件类型(更简洁,推荐)。
 
监听器需要被 Spring 容器管理(如标注@Component),才能被识别并注册。
 
示例:监听订单创建事件的监听器
 
java
 
运行
 
@Component
public class OrderListener {// 方式1:@EventListener注解(推荐)@EventListenerpublic void handleOrderCreated(OrderCreatedEvent event) {System.out.println("订单创建:" + event.getOrderId() + ",用户:" + event.getUsername());// 执行后续逻辑(如发送短信、更新库存等)}// 方式2:实现ApplicationListener接口/*@Componentpublic class OrderListener implements ApplicationListener<OrderCreatedEvent> {@Overridepublic void onApplicationEvent(OrderCreatedEvent event) {// 处理逻辑}}*/
}
 

3. 事件发布者(Publisher):事件的触发者

事件发布者是 “发布者”,负责在特定时机发布事件。Spring 中通过ApplicationEventPublisher接口(或其扩展ApplicationEventPublisherAware)发布事件。
 
  • 所有 Spring 容器(ApplicationContext)都实现了ApplicationEventPublisher接口,因此可直接在 Bean 中注入ApplicationEventPublisher用于发布事件。
 
示例:发布订单创建事件
 
java
 
运行
 
@Service
public class OrderService {// 注入事件发布器@Autowiredprivate ApplicationEventPublisher publisher;public void createOrder(Long orderId, String username) {// 1. 执行创建订单的核心逻辑System.out.println("创建订单:" + orderId);// 2. 发布订单创建事件(通知其他组件)publisher.publishEvent(new OrderCreatedEvent(this, orderId, username));}
}
 

4. 事件多路分发器(ApplicationEventMulticaster):核心调度者

ApplicationEventMulticaster是 Spring 事件机制的 “中枢”,负责管理所有监听器和分发事件,是连接发布者和监听器的核心组件。其工作流程如下:
 
  1. 注册监听器:Spring 容器启动时,会自动扫描所有监听器(ApplicationListener@EventListener标注的 Bean),并将它们注册到ApplicationEventMulticaster中。
  2. 分发事件:当发布者调用publishEvent发布事件时,事件会被传递给ApplicationEventMulticaster;它根据事件类型,找到所有匹配的监听器(监听该事件或其父类事件的监听器),并触发监听器的处理方法。
 
Spring 默认的ApplicationEventMulticaster实现是SimpleApplicationEventMulticaster,支持同步和异步两种事件分发方式:
 
  • 同步(默认):事件发布后,会立即执行所有监听器的逻辑,直到全部完成(发布者会阻塞等待)。
  • 异步:通过配置TaskExecutor,可让监听器在独立线程中执行,发布者无需等待(需在@EventListener上标注@Async,并配置线程池)。

核心流程总结

Spring 事件监听的完整流程可概括为:
 
  1. 定义事件:通过ApplicationEvent子类或普通对象封装业务数据。
  2. 注册监听器:监听器被 Spring 容器扫描并注册到ApplicationEventMulticaster
  3. 发布事件:业务逻辑中通过ApplicationEventPublisher发布事件。
  4. 分发与处理:ApplicationEventMulticaster接收事件,找到匹配的监听器,触发其处理方法(同步或异步)。

核心价值

  • 解耦:发布者与监听器无需互相依赖,通过事件间接通信,降低组件耦合度。
  • 扩展性:新增业务逻辑(如订单创建后新增 “发送邮件” 功能)只需添加新的监听器,无需修改发布者代码。
  • 灵活性:支持同步 / 异步处理,可根据业务需求选择(如耗时操作适合异步)。
 
这一机制在 Spring 内部被广泛使用(如容器生命周期管理),也常用于业务系统中跨组件通信(如订单流程、消息通知等场景)。
http://www.hskmm.com/?act=detail&tid=33172

相关文章:

  • 直播软件开发搭建公司
  • freeswitch的proxy_media模式下video流的问题与修正
  • DNS 相关
  • 2025 年无锡专线物流公司最新推荐排行榜:聚焦个性化运输解决方案,精选优质服务商往返无锡/冷链无锡/公路无锡/大件无锡专线物流公司推荐
  • Dubbo入门-通过spring-boot来动手实践
  • 使用ceph rdb做k8s后端存储(ceph-csi storageclass
  • 2025 最新火烧板源头厂家推荐排行榜:自有矿山加持 + 品质卓越,芝麻灰 / 五莲花等石材采购优选指南
  • 【IEEE出版、吉首大学主办】第二届智能机器人与自动控制国际学术会议 (IRAC 2025)
  • 第三次课动手动脑合集
  • 2025 年火山石厂家最新推荐排行榜:聚焦自有矿藏与全自动生产,涵盖滤料填料等多品类企业权威指南人工湿地填料/人工湿地滤料/黑色/红色火山石厂家推荐
  • 【SPIE出版、往届已检索】第十届能源系统、电气与电力国际学术会议 (ESEP 2025)
  • 2025 防火隔断厂家最新推荐排行榜:甲级防火玻璃隔断厂家深度测评,精选优质品牌助力采购决策
  • 作业3
  • 2025-10-17
  • 2025 年最新推荐!国内优质球墨铸铁管厂家排行榜,涵盖市政 / 给水 / 水利工程用管,助力采购高效选材
  • Nexpose 8.24.0 for Linux Windows - 漏洞扫描
  • 用于博客美化的测试(后面再更新)
  • 2025 年最新留学中介机构推荐排行榜:覆盖英美澳加新等热门地,专业团队护航学子海外深造之选
  • 有趣评测小程序系统:开启视频与答题变现新创业风口
  • 看图猜成语达人小程序:一站式趣味与变现解决方案
  • Metasploit Pro 4.22.8-20251014 (Linux, Windows) - 专业渗透测试框架
  • 设备租赁归还小程序系统:免人工化租赁管理解决方案
  • Navcat如何上传数据大的sql文件?
  • 实测PaddleOCR-VL:文心4.5最强衍生模型如何重构文档处理效率
  • 高考语文 词类活用
  • 使用Scalar.AspNetCore来管理你的OpenApi
  • 2025年市面上景观灯品牌推荐排行榜:权威解析与选择指南
  • 设计社会意识算法的三大关键问题
  • 【转】[C#] 项目里的配置文件与选项对比
  • Windows定时任务 每隔一段时间(最小到秒级)执行一次指定的Python脚本