当前位置：首页 > article >正文

【Spring】聊聊@EventListener注解原理

article 2024/12/3 19:02:31

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就是一种方式，当然各个框架也一般提供一定的预留拓展点，来实现不同的功能。

查看全文

http://www.kler.cn/a/420248.html