Spring中的事件机制
Spring中的事件机制是一个观察者模式的实现.观察者模式就是一个目标对象管理所有相依于它的观察者对象,并且在它本身的状态改变时主动发出通知.Spring的事件由ApplicationContext发布
ApplicationEvent
ApplicationEvent充当事件的角色,这是一个Abstract实现,所有的事件必须继承自该类,约束子类实现的体现,我们可以实现这个类定义自己的事件
image_1babkj7vg14en1oeaq7a158n1f9dt.png-9.2kB
Spring中默认存在的事件有
- ContextStartedEvent：ApplicationContext启动后触发的事件
- ContextStoppedEvent：ApplicationContext停止后触发的事件
- ContextRefreshedEvent：ApplicationContext初始化或刷新完成后触发的事件
- ContextClosedEvent：ApplicationContext关闭后触发的事件
- [x] WEB项目里会存在两个容器，一个是rootApplicationContext ,另一个就是projectName-servlet context,这个时候会触发两次ContextRefreshedEvent,注意rootApplicationContext没有parent,可以以此来区分
ApplicationListener
ApplicationListener充当监听器的角色
image_1babl33qv1rno1rcobrs145616339.png-6.3kB
想要监听相关事件只要实现ApplicationListener接口,并将该类注册到Spring中托管就可以,接口中的事件可以是Spring中的事件也可以是自定义实现的ApplicationEvent的子类
image_1babluvklnto100k16nd10ohq2q1g.png-21.3kB
ApplicationEventMulticaster
ApplicationEventMulticaster充当事件发布的角色,ApplicationContext通过带调用
初始化
image_1babloov85nv1p5c15l9cc6mrl13.png-79.3kB
添加监听器,这里所有被spring托管的Bean中的ApplicationListener实现都会被注册
image_1babmcsm81t9anu613k7gir132g1t.png-21kB
对于我们自定义的事件需要我们在条件满足的情况下手动触发
@Resource
private ApplicationContext applicationContext;
public void process() {
applicationContext.publishEvent(new DemoEvent(applicationContext));
}
提交事件后,ApplicationEventMulticaster会触发相关的ApplicationListener进行响应
异步
关于异步,给一个线程池就可以,可以配置全局的线程池,这个全局会影响所有的事件,不推荐.推荐在监听器内部添加线程池,多线程响应事件.
监听器
private static ExecutorService executor = Executors.newSingleThreadExecutor();
@Override
public void onApplicationEvent(DemoEvent event) {
executor.execute( do something);
}
