1.一个Demo出发
在平时的开发中，其实编写同步线程代码是比较容易的，但是如何将一些操作和另外一些操作进行解除耦合，而事件方式 是一种很好的解耦合方式，比如当一个用户注销一个APP之后，需要发送一些短信 让他引流回来。
核心流程 其实就是 1.定义一个事件 2.事件发布器 3.事件监听器
1.1 定义一个事件
public class UserCloseEvent extends ApplicationEvent {
private static final long serialVersionUID = 1L;
private String msg ;
public UserCloseEvent(Object source, String msg) {
super(source);
this.msg = msg;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
}
1.2 发布事件
@Component
public class MyTestEventPubLisher {
@Autowired
private ApplicationEventPublisher applicationEventPublisher;
public void pushUserCloseListener(String msg) {
applicationEventPublisher.publishEvent(new UserCloseEvent(this, msg));
}
}
1.3 监听器
@EventListener
public void listening3 (UserCloseEvent event) {
System.out.println("注解监听器===>UserCloseEvent->发送了一个注销用户的召回申请WA"+event.getClass().getName());
}
我们来分析一下 整体的原理，首先定义一个事件，这就是一个普通的对象，第二个就是发布事件，以及事件监听器是怎么感知到 要执行动作。 了解了这个流程之后，就可以很清楚的明白整体的原理。
2. Spring原理流程解析
熟悉Spring源码 bean生命周期的，应该都知道 preInstantiateSingletons 方法，一共是两个对bean的操作，第一部分其实就是实例化、初始化 bean的过程，第二部分，针对的是实现了 实现了 SmartInitializingSingleton 的子类的初始化方法。
2.1 @EventListener 注册为bean的过程
和事件相关的实现类就是图中的 EventListenerMethodProcessor
可以看到实现了该接口
public class EventListenerMethodProcessor implements SmartInitializingSingleton, xxx {
好了，梳理下具体的过程 其实就是在所有bean进行初始化完成之后，然后在针对注解做解析工作，封装成Listener。
2.2 事件触发的流程
这里其实就是根据执行的类型和listener进行匹配，如果是就开始顺序执行，当然也可以使用线程池异步执行。因为前面已经封装了带有注解的方法的信息，所以最终会通过反射的方式执行方法。
3 造轮子的EventBus
其实针对Guava的EventBus 核心流程
1.定义注解类 @ Subscribe
2.针对提供一个事件控制类EventBus 内部持有 ObserverRegistry 提供一个根据注册和执行事件的方法。主要存储一个map，key是事件类型，value是一个COW set，对应的就是封装的ObserverAction(Class,method) 主要用于后续的反射执行方法。
总结
其实对于一个框架来说，提供的功能是否易用，非常重要，并且不能和业务代码进行强耦合。所以虽然我们平时的工作是针对CRUD，但是总有一些非业务功能开发，比如一些基础架构的工作，监控、耗时、日志等一些通用功能，一定要使用非侵入业务的方式，AOP就是一种方式，当然各个框架也一般提供一定的预留拓展点，来实现不同的功能。
