Spring——事件机制
Spring中的事件机制是基于观察者模式实现的一种组件间通信机制，用于解耦不同组件，实现松耦合的消息传递，它允许一个组件发送事件，其他组件接收并处理事件，而无需直接依赖彼此。
事件机制的组成
Spring事件机制包含三个核心部分：
- 事件：继承ApplicationEvent的对象，封装需要传递的数据。Spring4.2+可以省略，任意对象都可以作为事件。
- 事件发布者：通过ApplicationEventPublisher接口发布事件，通常由spring管理的bean实现。
- 事件监听器：监听并处理事件的组件，通过@EventListener注解或实现ApplicationListener接口定义。
示例
事件：
首先自定义一个事件类，去实现ApplicationEvent，该父类没有无参构造：
public class MyEvent extends ApplicationEvent {public MyEvent(Object source) {super(source);}
}
发布者：
在业务代码内注入ApplicationEventPublisher，通过它去发布事件：
@Autowiredprivate ApplicationEventPublisher applicationEventPublisher;public void enent(){//业务代码//发送事件applicationEventPublisher.publishEvent(new MyEvent(this));}监听器：
监听事件类型，两种方式都试一遍：
@Component
public class MyLin implements ApplicationListener<MyEvent> {@Overridepublic void onApplicationEvent(MyEvent event) {System.out.println("监听到事件");}
}
@Component
public class MyLin2 {//注意方法的参数类型是监听的类型@EventListenerpublic void onApplicationEvent(MyEvent event) {System.out.println("监听到事件2");}
}
接下来模拟异步的情况：
异步事件监听器
@Component
public class AsyncEventListener {private static final Logger logger = LoggerFactory.getLogger(AsyncEventListener.class);/*** 异步处理事件 - 不会阻塞主线程*/@Async("taskExecutor") // 指定使用配置的线程池@EventListenerpublic void handleAsyncEvent(MyEvent event) {logger.info("异步事件处理开始 - 事件: {}", event.getMessage());logger.info("当前线程: {}", Thread.currentThread().getName());try {// 模拟耗时操作Thread.sleep(3000);logger.info("异步事件处理完成: {}", event.getMessage());} catch (InterruptedException e) {Thread.currentThread().interrupt();logger.error("异步事件处理被中断", e);}}/*** 同步处理事件 - 会阻塞主线程*/@EventListenerpublic void handleSyncEvent(MyEvent event) {logger.info("同步事件处理开始 - 事件: {}", event.getMessage());logger.info("当前线程: {}", Thread.currentThread().getName());try {// 模拟耗时操作Thread.sleep(2000);logger.info("同步事件处理完成: {}", event.getMessage());} catch (InterruptedException e) {Thread.currentThread().interrupt();logger.error("同步事件处理被中断", e);}}
}
@SpringBootTest
public class EventTest {@Autowiredprivate BusinessService businessService;@Testpublic void testAsyncEvent() {System.out.println("测试开始 - 主线程: " + Thread.currentThread().getName());long startTime = System.currentTimeMillis();businessService.doBusiness();long endTime = System.currentTimeMillis();System.out.println("业务方法执行时间: " + (endTime - startTime) + "ms");// 给异步事件处理留出时间try {Thread.sleep(5000);} catch (InterruptedException e) {Thread.currentThread().interrupt();}}
}Spring 内置事件
Spring 框架自带一些内置事件，用于通知容器生命周期的关键节点，常见的有：
| 事件类型 | 触发时机 |
|---|---|
ContextRefreshedEvent | Spring 容器初始化完成（所有 Bean 加载完成） |
ContextStartedEvent | 容器启动时（调用start()方法） |
ContextStoppedEvent | 容器停止时（调用stop()方法） |
ContextClosedEvent | 容器关闭时（调用close()方法） |
ApplicationFailedEvent | 应用启动失败时（Spring Boot 中常用） |