SpringBoot深入分析讲解监听器模式下
我们来以应用启动事件：ApplicationStartingEvent为例来进行说明：
以启动类的SpringApplication.run方法为入口，跟进SpringApplication的两个同名方法后，我们会看到主要的run方法，方法比较长，在这里只贴出与监听器密切相关的关键的部分：
SpringApplicationRunListeners listeners = getRunListeners(args); listeners.starting();
我们跟进这个starting方法，方法的内容如下：
void starting() {
for (SpringApplicationRunListener listener : this.listeners) {
listener.starting();
}
}这里的listeners已经在getRunListeners方法中完成了加载，加载原理类似于系统初始化器，关于系统初始化器的加载可以参考SpringBoot深入浅出分析初始化器
starting方法逻辑很简单，就是调用SpringApplicationRunListener的starting方法。下面继续分析这个starting方法：
我们进入了EventPublishingRunListener类（SpringApplicationRunListener 的实现类）的starting方法：
@Override
public void starting() {
this.initialMulticaster.multicastEvent(new ApplicationStartingEvent(this.application, this.args));
}这里就使用了广播器，来广播新的ApplicationStartingEvent事件。
我们跟进这个multicastEvent方法：
@Override
public void multicastEvent(ApplicationEvent event) {
multicastEvent(event, resolveDefaultEventType(event));
}继续看同名的方法multicastEvent：
@Override
public void multicastEvent(final ApplicationEvent event, @Nullable ResolvableType eventType) {
ResolvableType type = (eventType != null ? eventType : resolveDefaultEventType(event));
Executor executor = getTaskExecutor();
for (ApplicationListener<?> listener : getApplicationListeners(event, type)) {
if (executor != null) {
executor.execute(() -> invokeListener(listener, event));
}
else {
invokeListener(listener, event);
}
}
}这里的ResolvableType 是对event做了包装，我们不去关注；由于我们没有创建线程池，所以executor是空的。我们重点关注两个部分：
1、getApplicationListeners --> 获取所有关注此事件的监听器（※）；
2、invokeListener --> 激活监听器；
getApplicationListeners （AbstractApplicationEventMulticaster类中）方法，代码如下：
protected Collection<ApplicationListener<?>> getApplicationListeners(
ApplicationEvent event, ResolvableType eventType) {
Object source = event.getSource();
Class<?> sourceType = (source != null ? source.getClass() : null);
ListenerCacheKey cacheKey = new ListenerCacheKey(eventType, sourceType);
// Quick check for existing entry on ConcurrentHashMap...
ListenerRetriever retriever = this.retrieverCache.get(cacheKey);
if (retriever != null) {
return retriever.getApplicationListeners();
}
if (this.beanClassLoader == null ||
(ClassUtils.isCacheSafe(event.getClass(), this.beanClassLoader) &&
(sourceType == null || ClassUtils.isCacheSafe(sourceType, this.beanClassLoader)))) {
// Fully synchronized building and caching of a ListenerRetriever
synchronized (this.retrievalMutex) {
retriever = this.retrieverCache.get(cacheKey);
if (retriever != null) {
return retriever.getApplicationListeners();
}
retriever = new ListenerRetriever(true);
Collection<ApplicationListener<?>> listeners =
retrieveApplicationListeners(eventType, sourceType, retriever);
this.retrieverCache.put(cacheKey, retriever);
return listeners;
}
}
else {
// No ListenerRetriever caching -> no synchronization necessary
return retrieveApplicationListeners(eventType, sourceType, null);
}
}入参中的event就是ApplicationStartingEvent，sourceType是org.springframework.boot.SpringApplication类。ListenerRetriever类型本人将其视作是一个保存监听器的容器。
可以看出，程序首先在缓存里面寻找ListenerRetriever类型的retriever，如果没有找到，加锁再从缓存里面找一次。这里我们缓存里是没有内容的，所以都不会返回。
接下来调用了retrieveApplicationListeners方法，来遍历所有的监听器。retrieveApplicationListeners方法比较长，我们重点关注下supportsEvent(listener, eventType, sourceType)方法，该方法用来判断是否此监听器关注该事件，过程主要包括，判断此类型是否是GenericApplicationListener类型，如果不是，则构造一个代理，代理的目的是，通过泛型解析，最终获得监听器所感兴趣的事件。
如果经过判断，监听器对该事件是感兴趣的，则此监听器会被加入监听器列表中。
protected boolean supportsEvent(
ApplicationListener<?> listener, ResolvableType eventType, @Nullable Class<?> sourceType) {
GenericApplicationListener smartListener = (listener instanceof GenericApplicationListener ?
(GenericApplicationListener) listener : new GenericApplicationListenerAdapter(listener));
return (smartListener.supportsEventType(eventType) && smartListener.supportsSourceType(sourceType));
}当某个事件所有的监听器被收集完毕后，multicastEvent（SimpleApplicationEventMulticaster类）方法会对事件进行传播。即调用监听器的通用触发接口方法：listener.onApplicationEvent(event);这样，就完成了这个事件的传播。
到此这篇关于SpringBoot深入分析讲解监听器模式下的文章就介绍到这了,更多相关SpringBoot监听器模式内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了Springboot之如何统计代码执行耗时时间问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-03-03
今天小编就为大家分享一篇java 读取文件路径空格、"+"和中文的处理方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-07-07
这篇文章主要介绍了使用BigDecimal除法后保留两位小数方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-06-06
Java中documentHelper解析xml获取想要的数据
本文主要介绍了Java中documentHelper解析xml获取想要的数据，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-02-02
在Java 5.0之前启动一个任务是通过调用Thread类的start()方法来实现的，5.0里提供了一个新的任务执行架构使你可以轻松地调度和控制任务的执行，并且可以建立一个类似数据库连接池的线程池来执行任务,下面看一个示例2014-01-01
Stream是Java 8 API添加的一个新的抽象,称为流Stream,本文主要介绍了Java中Steam流的用法详解，具有一定的参考价值，感兴趣的可以了解一下2023-04-04
SpringMVC4.3 HandlerExceptionResolver异常处理源码解析
这篇文章主要为大家介绍了SpringMVC4.3 HandlerExceptionResolver异常处理源码解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪<BR>2023-09-09
这篇文章主要介绍了java中实现list或set转map的方法的相关资料,需要的朋友可以参考下2017-01-01
这篇文章主要为大家介绍了Spring框架学习中Cache抽象详解示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步2021-10-10
在企业级应用开发中,经常需要处理来自不同数据库的数据,为了满足这一需求,我们可以通过配置多个数据源来实现对不同数据库的访问,下面我们来看看具体实现吧2025-01-01
最新评论