快捷導(dǎo)航

Spring事件監(jiān)聽(tīng)機(jī)制ApplicationEvent方式

更新時(shí)間：2023年09月21日 09:02:52 作者：愛(ài)琴孩

這篇文章主要介紹了Spring事件監(jiān)聽(tīng)機(jī)制ApplicationEvent方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

前言

ApplicationEvent 以及 Listener 是Spring為我們提供的一個(gè)事件監(jiān)聽(tīng)、訂閱的實(shí)現(xiàn)，內(nèi)部實(shí)現(xiàn)原理是觀察者設(shè)計(jì)模式，設(shè)計(jì)初衷也是為了系統(tǒng)業(yè)務(wù)邏輯之間的解耦，提高可擴(kuò)展性以及可維護(hù)性。

ApplicationEvent的小demo

ApplicationEvent本身是抽象類，無(wú)法直接實(shí)例化。一般通過(guò)子類繼承ApplicationEvent

public class MyApplicationEvent extends ApplicationEvent {
    private Student student;
    public Student getStudent() {
        return student;
    }
    public void setStudent(Student student) {
        this.student = student;
    }
    public MyApplicationEvent(Object source) {
        super(source);
    }
    public MyApplicationEvent(Object source, Student student) {
        super(source);
        this.student = student;
    }
}

事件定義好之后，我們注冊(cè)個(gè)事件監(jiān)聽(tīng)器即可。

實(shí)現(xiàn)ApplicationListener接口注冊(cè)監(jiān)聽(tīng)器

@Component
public class MyApplicationListener implements ApplicationListener<MyApplicationEvent> {
    private static final Logger LOGGER = LoggerFactory.getLogger(MyApplicationListener.class);
    @Override
    public void onApplicationEvent(MyApplicationEvent myApplicationEvent) {
        Student student = myApplicationEvent.getStudent();
        LOGGER.info("學(xué)生對(duì)象是={}", JSONObject.toJSONString(student));
    }
}

通過(guò)@EventListener注冊(cè)監(jiān)聽(tīng)器，ApplicationContext.publishEvent 默認(rèn)是同步操作, 并非發(fā)布后不管的異步操作，發(fā)布事件后需要等 @EventListener 執(zhí)行完。

如果需要開(kāi)啟異步操作需要在 @EventListener 上增加 @Async 注解。

@Component
public class AsyncApplicationListener {
    private static final Logger LOGGER = LoggerFactory.getLogger(AsyncApplicationListener.class);
    @EventListener
    @Async
    public void listener(MyApplicationEvent myApplicationEvent) {
        Student student = myApplicationEvent.getStudent();
        LOGGER.info("通過(guò)@EventListener獲取學(xué)生對(duì)象信息={}", JSONObject.toJSONString(student));
    }
}

通過(guò)實(shí)現(xiàn)SmartApplicationListener接口注冊(cè)監(jiān)聽(tīng)器

SmartApplicationListener接口繼承了全局監(jiān)聽(tīng)ApplicationListener，并且泛型對(duì)象使用的ApplicationEvent來(lái)作為全局監(jiān)聽(tīng)，可以理解為使用SmartApplicationListener作為監(jiān)聽(tīng)父接口的實(shí)現(xiàn)，監(jiān)聽(tīng)所有事件發(fā)布。

既然是監(jiān)聽(tīng)所有的事件發(fā)布，那么SmartApplicationListener接口添加了兩個(gè)方法supportsEventType、supportsSourceType來(lái)作為區(qū)分是否是我們監(jiān)聽(tīng)的事件，只有這兩個(gè)方法同時(shí)返回true時(shí)才會(huì)執(zhí)行onApplicationEvent方法。

@Component
public class MySmartApplicationListener implements SmartApplicationListener {
    private static final Logger LOGGER = LoggerFactory.getLogger(MySmartApplicationListener.class);
    @Override
    public boolean supportsEventType(Class<? extends ApplicationEvent> aClass) {
        return aClass == MyApplicationEvent.class;
    }
    @Override
    public boolean supportsSourceType(Class<?> sourceType) {
        return sourceType == ApplicationRunnerTest.class;
    }
    @Override
    public int getOrder() {
        return 0;
    }
    @Override
    public void onApplicationEvent(ApplicationEvent applicationEvent) {
        MyApplicationEvent myApplicationEvent = (MyApplicationEvent) applicationEvent;
        LOGGER.info("通過(guò)MySmartApplicationListener 獲取學(xué)生對(duì)象信息={}",
                JSONObject.toJSONString(myApplicationEvent.getStudent()));
    }
}

可以看到除了上面的方法，還提供了一個(gè)getOrder方法，這個(gè)方法就可以解決執(zhí)行監(jiān)聽(tīng)的順序問(wèn)題，return的數(shù)值越小證明優(yōu)先級(jí)越高，執(zhí)行順序越靠前

發(fā)布事件

在Spring的Bean中，注入ApplicationContext ，通過(guò)ApplicationContext 來(lái)進(jìn)行事件發(fā)布

@Autowired
private ApplicationContext applicationContext;
applicationContext.publishEvent(new MyApplicationEvent(this, new Student("愛(ài)琴孩", 18)));

運(yùn)行結(jié)果

2023-01-28 10:38:39.696 YYZX_Study 13540 [ main] INFO c.e.s.s.MySmartApplicationListener 37: 通過(guò)MySmartApplicationListener 獲取學(xué)生對(duì)象信息={"age":18,"name":"愛(ài)琴孩"}
2023-01-28 10:38:39.696 YYZX_Study 13540 [ main] INFO c.e.study.service.MyApplicationListener 22: 學(xué)生對(duì)象是={"age":18,"name":"愛(ài)琴孩"}
2023-01-28 10:38:39.696 YYZX_Study 13540 [tOrderService-1] INFO c.e.s.service.AsyncApplicationListener 25: 通過(guò)@EventListener獲取學(xué)生對(duì)象信息={"age":18,"name":"愛(ài)琴孩"}