今天我们来聊一聊Spring的监听器，来了解Spring的监听器是如何使用的，以及使用原理，接下来从监听器的使用以及原理分析两部分来详细说明：

监听器实现

直接上代码，做一个简易的实现，我们需要几个类，首先是我们的配置类，监听器类以及测试类；

监听器类：

需要实现ApplicationListener这个接口，然后加入未实现的方法，写入我们的监听内容。

import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;

public class MyListener implements ApplicationListener<ApplicationEvent>{

   public void onApplicationEvent(ApplicationEvent arg0) {

           System.out.println("监听====="+arg0);

   }

}

配置类：

将我们的监听器类加入到我们的bean容器当中。

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class ListenerConfig {

@Bean
public MyListener myListener(){

return new MyListener();
}

}

测试类：

通过容器的publishEvent方法，我们可以加入我们的自定义事件。

import org.junit.Test;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

import com.wjs.listener.ListenerConfig;

public class TestListener {

   @Test
   public void test(){


       AnnotationConfigApplicationContext annotationConfigApplicationContext = new AnnotationConfigApplicationContext(ListenerConfig.class);

       annotationConfigApplicationContext.publishEvent(new ApplicationEvent("新建的事件-----") {
       });

       annotationConfigApplicationContext.close();
   }

}

测试的结果：

原理分析

从以上的测试结果我们发现监听器已经生效，监测到了容器的创建刷新事件、我们通过容器的publishEvent方法新加的自定义事件，以及我们容器关闭的事件，我们来分析下它的实现原理，断点跟进，

1、还是容器创建的时候，调用容器创建的refresh方法————>finishRefresh()方法，在这个方法里执行了我们发布最后事件的方法publishEvent(new ContextRefreshedEvent(this))，进行事件的发布。

2、publishEvent发布事件方法中主要做的一件事就是拿到我们的派发器（getApplicationEventMulticaster()），然后派发事件（multicastEvent）。

Spring学习笔记-监听器

3、进入派发事件方法，首先for循环拿到所有的监听器，如果有excutor，则可以进行异步事件派发，否则，同步方式的话，直接执行listener方法，invokeListener(listener, event);也就到了我们的目标方法，invokeListener------doInvokeListener--onApplicationEvent，到此一个事件的监听过程就实现了。