Spring 监听器listener原理

阿里云国内75折 回扣 微信号:monov8
阿里云国际,腾讯云国际,低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号:monov8 飞机:@monov6

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文件将监听器实例化后保存在内存中到有触发动作是根据发送的事件类型从所有初始化的监听器中找到匹配的监听器在发送事件对象

阿里云国内75折 回扣 微信号:monov8
阿里云国际,腾讯云国际,低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号:monov8 飞机:@monov6
标签: Spring