ApplicationListener

简介

ApplicationListener：监听容器中发布的事件。

实例

MyApplicationListener.java

@Component
public class MyApplicationListener implements ApplicationListener<ApplicationEvent> {

    //当容器中发布此事件以后，方法触发
    @Override
    public void onApplicationEvent(ApplicationEvent event) {
        // TODO Auto-generated method stub
        System.out.println("收到事件："+event);
    }

}

配置类

@ComponentScan("com.atguigu.ext")
@Configuration
public class ExtConfig {
    
    @Bean
    public Blue blue(){
        return new Blue();
    }

}

测试类

    @Test
    public void test01(){
        AnnotationConfigApplicationContext applicationContext  = new AnnotationConfigApplicationContext(ExtConfig.class);
        
        
        //发布事件；
        applicationContext.publishEvent(new ApplicationEvent(new String("我发布的时间")) {
        });
        
        applicationContext.close();
    }

原理

监听 ApplicationEvent 及其下面的子事件：
步骤：
1）、写一个监听器（ApplicationListener实现类）来监听某个事件（ApplicationEvent及其子类）
@EventListener;
原理：使用EventListenerMethodProcessor处理器来解析方法上的@EventListener；
2）、把监听器加入到容器；
3）、只要容器中有相关事件的发布，我们就能监听到这个事件；ContextRefreshedEvent：容器刷新完成（所有bean都完全创建）会发布这个事件；ContextClosedEvent：关闭容器会发布这个事件；
4）、发布一个事件：applicationContext.publishEvent()；

发布事件的原理：
ContextRefreshedEvent、IOCTest_Ext$1[source=我发布的时间]、ContextClosedEvent；
1）、ContextRefreshedEvent事件：a、容器创建对象：refresh()；b、finishRefresh();容器刷新完成会发布ContextRefreshedEvent事件
2）、自己发布事件；
3）、容器关闭会发布ContextClosedEvent；

【事件发布流程】：
publishEvent(new ContextRefreshedEvent(this));
1）、获取事件的多播器（派发器）：getApplicationEventMulticaster()
2）、multicastEvent派发事件；
3）、获取到所有的ApplicationListener；
for (final ApplicationListener<?> listener : getApplicationListeners(event, type)) {
a）、如果有Executor，可以支持使用Executor进行异步派发；Executor executor = getTaskExecutor();
b）、否则，同步的方式直接执行listener方法；invokeListener(listener, event); 拿到listener回调onApplicationEvent方法；