【一】相关源代码类
（1）spring的事件发布监听机制的核心管理类：org.springframework.context.event.SimpleApplicationEventMulticaster.
=>该类的初始化是放在项目加载时，在ioc容器xml配置文件解析加载完毕后，注册bean创建前后置处理实现类（BeanPostProcessor 接口实现），beanFactory配置处理（BeanFactoryPostProcessor接口实现）后，初始化该事件发布监听机制的核心类。
public void refresh() throws BeansException, IllegalStateException {
synchronized (this.startupShutdownMonitor) {
// Prepare this context for refreshing.
prepareRefresh();
// 解析xml配置文件
ConfigurableListableBeanFactory beanFactory = obtainFreshBeanFactory();
// Prepare the bean factory for use in this context.
prepareBeanFactory(beanFactory);
try {
// 注册未来bean实例化的前后置处理的PostProcessor接口实现
postProcessBeanFactory(beanFactory);
//执行所有实现BeanFactoryPostProcessor接口实现，对beanFactory进行处理
invokeBeanFactoryPostProcessors(beanFactory);
// 注册未来bean实例化的前后置处理的PostProcessor接口实现
registerBeanPostProcessors(beanFactory);
// 注册未来bean实例化的前后置处理的PostProcessor接口实现
initMessageSource();
// 实例化spring事件发布监听机制的核心类，SimpleApplicationEventMulticaster
initApplicationEventMulticaster();
// Initialize other special beans in specific context subclasses.
onRefresh();
// 注册事件监听器
registerListeners();
// 实例化非懒加载的bean,完成ioc容器中bean的实例化和反转依赖，并在内部实现动态代理相关的操作
finishBeanFactoryInitialization(beanFactory);
// Last step: publish corresponding event.
finishRefresh();
}
catch (BeansException ex) {
logger.warn("Exception encountered during context initialization - cancelling refresh attempt", ex);
// Destroy already created singletons to avoid dangling resources.
destroyBeans();
// Reset 'active' flag.
cancelRefresh(ex);
// Propagate exception to caller.
throw ex;
}
}
}
（2）spring的事件发布监听机制的监听器类的接口：org.springframework.context.ApplicationListener<E extends ApplicationEvent>
=>监听器的定义必须实现该接口。
=>所监听的事件也必须继承org.springframework.context.ApplicationEvent的抽象类
=>在初始化管理类后，会注册监听器。会从beanFactory里得到所有实现ApplicationListener接口的bean的名字，并注册到ListenerRetriever的属性applicationListenerBeans集合中。
（3）spring的事件发布监听机制的事件的基础类：org.springframework.context.ApplicationEvent
=>事件的事件类必须继承该基类
=>定义监听器的同时，必须定义相关的事件类。
（4）spring的事件发布监听机制的存储事件监听的类：org.springframework.context.event.AbstractApplicationEventMulticaster.ListenerRetriever
=>该类内部存储了一个n个事件对应的多个监听器
=>属性Set<ApplicationListener<?>> applicationListeners 存储的是事件监听器的实例
=>属性Set<String> applicationListenerBeans 存储的事件监听器在ioc容器中的beanNames
（5）spring的事件发布监听机制的存储事件体的类：org.springframework.context.event.AbstractApplicationEventMulticaster.ListenerCacheKey
=>一个事件体的class类型+事件源（事件体内存储的数据）的class类型决定由那些监听监听器处理该事件
=>属性Class<?> eventType 存储的事件体的class类型
=>属性Class<?> sourceType 存储的事件源的class类型（事件体内数据）
【二】设计思想
（1）通过事件体，拿到事件类的cls1类型，和事件源（事件体内部存储的数据类）的cls类型
（2）然后在IOC容器中所有实现ApplicationListener接口的事件监听器中进行匹配。找到所有适合该事件的事件监听器集合。将事件监听集合形成ListenerRetriever对象。
=>从IOC容器中的一个个事件监听器实现类的范型填充类的类型（也就是事件体的 类型）cls2
=>Listener可能是代理对象（因为@Async注解），Listenner的ioc在实例化阶段，会被spring创建成代理对象。spring内部也会做处理，得到代理对象代理的targetClass，也就是Listenner的真实类型。
=>看当前事件体的类型cls1是否是事件监听器的范型填充类的类型cls2的子类或本身。如果是，则表示这个事件监听器匹配该事件。
（3）将该事件体，的事件类的cls1类型+事件源的cls类型。形成ListenerCacheKey对象，以此为key，以事件监听集合ListenerRetriever对象作为value，存储在AbstractApplicationEventMulticaster类中private final Map<ListenerCacheKey, ListenerRetriever> retrieverCache = new ConcurrentHashMap<ListenerCacheKey, ListenerRetriever>(64);属性中作为cache，方便下次匹配，不再从ioc容器中重新匹配。
【三】事件缓冲，扩展。hasMap中以对象作为key。需要重写hasCode方法，equals方法
private static class ListenerCacheKey {
private final Class<?> eventType;
private final Class<?> sourceType;
public ListenerCacheKey(Class<?> eventType, Class<?> sourceType) {
this.eventType = eventType;
this.sourceType = sourceType;
}
@Override
public boolean equals(Object other) {
if (this == other) {
return true;
}
ListenerCacheKey otherKey = (ListenerCacheKey) other;
return ObjectUtils.nullSafeEquals(this.eventType, otherKey.eventType) &&
ObjectUtils.nullSafeEquals(this.sourceType, otherKey.sourceType);
}
@Override
public int hashCode() {
return ObjectUtils.nullSafeHashCode(this.eventType) * 29 + ObjectUtils.nullSafeHashCode(this.sourceType);
}
}