1.创建本地事件和事件监听器

/**
 * 事件类
 */
public class MyEventA extends ApplicationEvent {

    private static final long serialVersionUID = 1L;

    public MyEventA(Object source) {
        super(source);
        System.out.println("MyEventA 构造方法被执行了...");
    }

    public void out(String name){
        System.out.println("MyEventA .... out方法执行了"+name);
    }
}

/**
 * 监听器
 */
public class MyListenerA implements ApplicationListener<MyEventA> {

    @Override
    public void onApplicationEvent(MyEventA event) {
        System.out.println("======MyListenerA 监听器触发了...");
        // 执行事件中的特定方法
        event.out("AAAAA");
    }
}

2 触发发送事件

public class TestListenerController {

    @Autowired
    private ApplicationContext mApplicationContext;
    
    @GetMapping("/testlistener")
    public String testPublishEvent(){
        System.out.println("====>get");
        mApplicationContext.publishEvent(new MyEventA(new Object()));
        return "";
    }
}

3 添加注册器到spring.factories

图1

4 项目启动时候会将listener 实例化到内存中

走到SpringApplication的构造方法中，会走到getSpringFactoriesInstances方法中，实例化listener类型的类，通过setListeners方法保存在内存中

图2

图3

5. 执行Controller方法

http://localhost:8081/testlistener

会执行mApplicationContext.publishEvent(new MyEventA(new Object()));

图4

执行到SimpleApplicationEventMulticaster类中的multicastEvent

图5

执行SimpleApplicationEventMulticaster父类AbstractApplicationEventMulticaster中的getApplicationListeners方法找到匹配的listener，在执行到retrieveApplicationListeners方法

图6

图7

执行GenericApplicationListenerAdapter类中supportsEventType方法

declaredEventType.isAssignableFrom(eventType))将需要监听的对象和发送的事件对象匹配，匹配成功将此listener，也就是之前声明的MyListenerA实例化对象，添加到发送列表

图8

最好执行图5中的invokeListener(listener, event)，将事件发送到对应的监听器

综上流程可以看出，spring的事件发送接收是一种观察者模式，即注册监听模式，当应用启动的时候，根据spring.factories文件，将监听器实例化后保存在内存中，到有触发动作是，根据发送的事件类型，从所有初始化的监听器中找到匹配的监听器，在发送事件对象