Spring ApplicationContext的事件机制是什么？在Nacos中如何应用？-阿里云开发者社区

Spring ApplicationContext的事件机制是什么？在Nacos中如何应用？

2022-10-24 101

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： Spring ApplicationContext的事件机制是什么？在Nacos中如何应用？

一、概述

>1 ApplicationContext简述

官方如是描述：
在这里插入图片描述

1） ApplicationContext是Spring中的核心接口和容器，允许容器通过应用程序上下文环境创建、获取、管理bean。
2）在构建容器的时候，创建对象采用的策略是 立即加载的方式，即只要一读取完配置文件就立即创建配置文件中配置的对象。

>2 ApplicationContext事件机制简述

ApplicationContext.publishEvent（事件机制）是Spring提供的解耦的一种方式,采用观察者设计模式；我们可以使用 MQ或线程池来代替它。

ApplicationContext中的事件处理是通过ApplicationEvent事件类和ApplicationListener事件监听器接口提供的；

事件机制的3要素：事件发布者（ApplicationContext）、事件（ApplicationEvent）、事件监听器（EventListener / ApplicationListener）；

>3 事件触发 && 监听处理过程

（1）通过ApplicationContext的publishEvent()方法将事件发布到ApplicationListener（EventListener的子类） / EventListener; 通知事件监听器处理事件；

（2）事件监听器通过实现的ApplicationListener#onApplicationEvent()方法处理事件；

总结： ApplicationEvent事件 --> ApplicationContext.publishEvent()发布事件 --> 触发EventListener/ ApplicationListener监听器 --> 监听器执行内部onApplicationEvent(ApplicationEvent e)方法。

所以，只需要在容器中注册实现了ApplicationListener的Bean，当ApplicationContext发布事件时，事件会被监听器自动捕获。

>4 注意点

(1) ApplicationContext.publishEvent 默认是同步操作, 并非发布后不管的异步操作，发布事件后需要等 EventListener / ApplicationListener 执行完；

(2) 如果需要开启异步操作 需要在EventListener / ApplicationListener子类上增加 @Async 注解。

二、在Nacos中的应用（事件机制的使用）

我们从要发布的事件、发布事件、处理事件三个方面来看。

>1 要发布的事件

自定义的事件只需继承ApplicationEvent即可。

public class ServiceChangeEvent extends ApplicationEvent {
    
    private Service service;
    
    public ServiceChangeEvent(Object source, Service service) {
        super(source);
        this.service = service;
    }
    
    public Service getService() {
        return service;
    }
}

>2 发布事件

如果想让Spring Bean在业务过程发布指定容器事件，需要先让Bean获得ApplicationContext容器的引用，然后将指定容器事件Event交由ApplicationContext发布。

在Nacos中，UdpPushService类中持有ApplicationContext容器的引用：
在这里插入图片描述

UdpPushService类中将ServiceChangeEvent事件交由ApplicationContext发布：

this.applicationContext.publishEvent(new ServiceChangeEvent(this, service));

>3 处理事件

实现ApplicationListener接口的onApplicationEvent()方法，在该方法中做事件处理；

@Component
@SuppressWarnings("PMD.ThreadPoolCreationRule")
public class UdpPushService implements ApplicationContextAware, ApplicationListener<ServiceChangeEvent> {
    @Override
    public void onApplicationEvent(ServiceChangeEvent event) {
        // todo 处理业务逻辑
        // If upgrade to 2.0.X, do not push for v1.
        if (ApplicationUtils.getBean(UpgradeJudgement.class).isUseGrpcFeatures()) {
            return;
        }
        .......
                    // 发送UDP请求
                    udpPush(ackEntry);
        .......
}