Spring 自定义了继承 JDK 事件监听器的接口ApplicationListener<E extends ApplicationEvent> extends EventListener
,用来监听 Spring 应用程序中的事件;自定义了继承 JDK 事件对象的抽象类ApplicationEvent extends EventObject
,用来表示 Spring 应用程序中的事件类型。容器启动刷新过程中,可以定义事件监听器,来监听应用程序上下文事件ApplicationContextEvent extends ApplicationEvent
,它有四个具体的实现类:
ContextStartedEvent/ContextRefreshedEvent/ContextStoppedEvent/ContextClosedEvent
,分别表示容器启动/刷新/停止/关闭的事件。
通常有两种方式来实现 Spring 中的事件监听:
- 实现 ApplicationListener 接口
public class MyListener implements ApplicationListener<ApplicationEvent> {
@Override
public void onApplicationEvent(ApplicationEvent event) {
System.out.println("MyListener: " + event);
}
}
- 使用 @EventListener 注解
public class MyAnnotationListener {
@EventListener(classes = ApplicationEvent.class)
public void listen(ApplicationEvent event) {
System.out.println("@EventListener:" + event);
}
}
- 自定义发布事件
public class Test {
public static void main(String[] args) {
AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(Test.class);
// 发布事件
context.publishEvent(new ApplicationEvent("my event") {});
}
}
原理
在 Spring 容器启动,调用 refresh() 刷新的过程中,会初始化事件派发器,并注册事件监听器,最后通过事件派发器,将事件发布给自己的监听器。
1 初始化事件派发器
initApplicationEventMulticaster();
为容器中的 BeanFactory 初始化一个事件派发器 (ApplicationEventMulticaster) :SimpleApplicationEventMulticaster,并注册到 BeanFactory,name 为 applicationEventMulticaster。
2 添加 ApplicationListener 监听器
registerListeners();
取出 BeanFactory 中 ApplicationListener 类型的事件监听器,全部添加到上面的事件派发器的缓存中。
3 添加 @EventListener 监听器
finishBeanFactoryInitialization(beanFactory)
从 Spring 后置处理器源码 可知,Spring 初始化时会注册 EventListenerMethodProcessor 和 DefaultEventListenerFactory。
EventListenerMethodProcessor 实现了 EventListenerMethodProcessor,所以执行 BeanFactory 后置处理器时,会调用 postProcessBeanFactory(),将 DefaultEventListenerFactory 添加到缓存中。
EventListenerMethodProcessor 实现了 SmartInitializingSingleton,所以在初始化剩余的单例 Bean 之后,会调用 afterSingletonsInstantiated(),获取所有的 BeanFactory,找到其中标注了 @EventListener 的方法,利用反射和 DefaultEventListenerFactory 为其创建 ApplicationListener,并添加到事件派发器的缓存中。
4 发布事件
finishRefresh();
- 初始化生命周期处理器,注册到 BeanFactory,name 为 lifecycleProcessor。
- 调用生命周期处理器的 onRefresh(),表示刷新状态。
- 发布上下文刷新事件。调用事件派发器的 multicastEvent() 进行派发,最终,通过回调事件监听器的 onApplicationEvent() 方法,来通知监听器。
异步派发和异常处理器
- 如果事件派发器设置了 Executor,则可以进行异步多线程的事件派发。
- 如果事件派发器设置了 ErrorHandler,则可以用异常处理器来处理异常。