设计模式之发布订阅模式(5) Spring Events源码解析

之前讲了 深入Spring Events事件驱动模型 ，发现一些小伙伴不满足于仅仅会用，还对事件驱动(Event Driven)的原理很感兴趣，因此我们这篇文章就带大家看下Spring事件驱动的核心源码。

对于事件驱动，你可以跟生活中的实际场景联系一下，就很容易理解了。

比如你去宾馆开房，第二天早上6点要去赶飞机，就打电话给前台，前台记录了你的房间号和叫醒时间，第二天早上，前台就在指定的时间挨个给需要叫醒的顾客打电话，叫他们起床。

在这个故事里，你就是一个 监听器 ，前台就是一个 广播器 ，而 早上6点提供叫醒服务 就是一个事件。当这些早上六点被叫醒的 监听器 们起床以后，有的去了机场，有的去了火车站，这就是对同一个事件不同的监听器进行了不同的逻辑处理。

事件监听器源码

你只要记住事件驱动中的三个角色，就很容易理解事件驱动的本质了，它们分别是： 事件监听器 、 事件广播器 和 事件 。

事件监听器

我们的 事件监听器 都实现了 ApplicationListener 接口，这个接口中只有一个方法 void onApplicationEvent(E event) ，用于处理监听到的事件。至于监听到事件以后怎么办，就是你的自由发挥余地了。

事件广播器

Spring通过 事件广播器 ApplicationEventMulticaster 接口将事件分配给专门的监听器。

ApplicationEventMulticaster 接口定义了3种方法：

1. 添加监听器：

void addApplicationListener(ApplicationListener<?> var1);

void addApplicationListenerBean(String var1);
复制代码

2. 删除监听器：

void removeApplicationListener(ApplicationListener<?> var1);

void removeApplicationListenerBean(String var1);

void removeAllListeners();
复制代码

3. 将事件发送到已注册的监听器：

void multicastEvent(ApplicationEvent var1);

void multicastEvent(ApplicationEvent var1, @Nullable ResolvableType var2);
复制代码

AbstractApplicationEventMulticaster 实现了基本的添加和删除监听器的方法。

在实现类 SimpleApplicationEventMulticaster 的源码里，你可以看到事件是被 ApplicationEventMulticaster 的 multicastEvent(ApplicationEvent event) 方法发送到每个已注册的监听器的。

@Override
public void multicastEvent(final ApplicationEvent event, @Nullable ResolvableType eventType) {
	ResolvableType type = (eventType != null ? eventType : resolveDefaultEventType(event));
  //根据eventType获取所有该类型事件已注册的监听器集合并遍历
	for (final ApplicationListener<?> listener : getApplicationListeners(event, type)) {
    //获取线程池
		Executor executor = getTaskExecutor();
		if (executor != null) {
      //如果有线程池则并发触发监听器的方法
			executor.execute(() -> invokeListener(listener, event));
		}
		else {
      //没有线程池则依次执行
			invokeListener(listener, event);
		}
	}
}
复制代码

到这里你应该明白SpringEvents事件驱动的原理了：

以Spring容器为基础，通过一个集合保存事件与事件监听器之间的对应关系（想想之前讲的发布者/订阅者），然后当发布事件的时候，根据事件类型获取该事件所有的订阅者，最后通过同步或异步的方式通知到每个监听器并执行监听方法。

So easy !