180609-Spring之事件驅(qū)動(dòng)機(jī)制的簡(jiǎn)單使用

Hwg 發(fā)布于2019-08-15 18:15 / 2645人閱讀

摘要：文章鏈接之事件驅(qū)動(dòng)機(jī)制的簡(jiǎn)單使用之事件驅(qū)動(dòng)機(jī)制的簡(jiǎn)單使用關(guān)于事件的發(fā)起與相應(yīng)，在客戶端的交互中可算是非常頻繁的事情了，關(guān)于事件的發(fā)布訂閱，在生態(tài)中，可謂是非常有名了，而也提供了事件機(jī)制，本文則主要介紹后端如何在的環(huán)境中，使用事件機(jī)制使用姿

文章鏈接：https://liuyueyi.github.io/hexblog/hexblog/2018/06/09/180609-Spring之事件驅(qū)動(dòng)機(jī)制的簡(jiǎn)單使用/

Spring之事件驅(qū)動(dòng)機(jī)制的簡(jiǎn)單使用

關(guān)于事件的發(fā)起與相應(yīng)，在客戶端的交互中可算是非常頻繁的事情了，關(guān)于事件的發(fā)布訂閱，在Java生態(tài)中，EventBus可謂是非常有名了，而Spring也提供了事件機(jī)制，本文則主要介紹后端如何在Spring的環(huán)境中，使用事件機(jī)制

I. 使用姿勢(shì)

主要借助org.springframework.context.ApplicationEventPublisher#publishEvent(org.springframework.context.ApplicationEvent) 來(lái)發(fā)布事件，而接受方，則直接在處理的方法上，添加 @@EventListener注解即可

1. 事件定義

發(fā)布一個(gè)事件，所以第一件事就是要定義一個(gè)事件，對(duì)Spring而言，要求自定義的事件繼承自ApplicationEvent類, 一個(gè)簡(jiǎn)單的demo如下

public class NotifyEvent extends ApplicationEvent {
    @Getter
    private String msg;

    public NotifyEvent(Object source, String msg) {
        super(source);
        this.msg = msg;
    }
}

2. 發(fā)布事件

發(fā)布時(shí)間則比較簡(jiǎn)單，直接拿到ApplicationContext實(shí)例，執(zhí)行publish方法即可，如下面給出一個(gè)簡(jiǎn)單的發(fā)布類

@Component
public class NotifyPublisher implements ApplicationContextAware {
    private ApplicationContext apc;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.apc = applicationContext;
    }
    
    // 發(fā)布一個(gè)消息
    public void publishEvent(int status, String msg) {
        if (status == 0) {
            apc.publishEvent(new NotifyEvent(this, msg));
        } else {
            apc.publishEvent(new NewNotifyEvent(this, msg, ((int) System.currentTimeMillis() / 1000)));
        }
    }
}

3. 事件監(jiān)聽器

在方法上添加注解即可，如下

@Component
public class NotifyQueueListener {

    @EventListener
    public void consumerA(NotifyEvent notifyEvent) {
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("A: " + Thread.currentThread().getName() + " | " + notifyEvent.getMsg());
    }

    @EventListener
    public void consumerB(NewNotifyEvent notifyEvent) {
        System.out.println("B: " + Thread.currentThread().getName() + " | " + notifyEvent.getMsg());
    }


    @EventListener
    public void consumerC(NotifyEvent notifyEvent) {
        System.out.println("C: " + Thread.currentThread().getName() + " | " + notifyEvent.getMsg());
    }
}

II. 疑問(wèn)及解答 1. 發(fā)布與監(jiān)聽器的關(guān)聯(lián)

上面給出了使用的姿勢(shì)，看起來(lái)并不復(fù)雜，也比較容易使用，但是一個(gè)問(wèn)題需要在使用之前弄明白了，發(fā)布事件和監(jiān)聽器是怎么關(guān)聯(lián)起來(lái)的呢？

根據(jù)方法的參數(shù)類型執(zhí)行

那么如果發(fā)布者，推送的是一個(gè)NotifyEvent類型的事件，那么接收者是怎樣的呢？

參數(shù)為NotifyEvent以及其子類的監(jiān)聽器，都可以接收到消息

測(cè)試用例如下:

NewNotifyEvent 繼承自上面的NotifyEvent

public class NewNotifyEvent extends NotifyEvent {
    @Getter
    private int version;

    public NewNotifyEvent(Object source, String msg) {
        super(source, msg);
    }
    public NewNotifyEvent(Object source, String msg, int version) {
        super(source, msg);
        this.version = version;
    }
}

然后借助上面的消息發(fā)布者發(fā)送一個(gè)消息

@Test
public void testPublishEvent() throws InterruptedException {
    notifyPublisher.publishEvent(1, "新的發(fā)布事件! NewNotify");
    System.out.println("---------");
    notifyPublisher.publishEvent(0, "舊的發(fā)布事件! Notify");
}

輸出結(jié)果如下，對(duì)于NewNotifyEvent, 參數(shù)類型為NotifyEvent的consumerA, consumerC都可以接收到

A: main | 新的發(fā)布事件! NewNotify
C: main | 新的發(fā)布事件! NewNotify
B: main | 新的發(fā)布事件! NewNotify
---------
A: main | 舊的發(fā)布事件! Notify
C: main | 舊的發(fā)布事件! Notify

2. 消息接收的順序

上面消息處理是串行的，那么先后順序怎么確定？ (下面的答案不確定，有待深入源碼驗(yàn)證！?。。?/p>

先掃描到的bean先處理

同一個(gè)bean中，按精確匹配，先后定義順序進(jìn)行

3. 異步消費(fèi)

對(duì)于異步消費(fèi)，即在消費(fèi)者方法上添加一個(gè)@Async注解，并需要在配置文件中，開啟異步支持

@Async
@EventListener
public void processNewNotifyEvent(NewNotifyEvent newNotifyEvent) {
    System.out.println("new notifyevent: " + newNotifyEvent.getMsg() + " : " + newNotifyEvent.getVersion());
}

配置支持

@Configuration
@EnableAsync
public class AysncListenerConfig implements AsyncConfigurer {
    /**
     * 獲取異步線程池執(zhí)行對(duì)象
     *
     * @return
     */
    @Override
    public Executor getAsyncExecutor() {
        return new ThreadPoolExecutor(5, 10, 1, TimeUnit.MINUTES, new LinkedBlockingQueue(),
                new DefaultThreadFactory("test"), new ThreadPoolExecutor.CallerRunsPolicy());
    }
}

III. 其他 一灰灰Blog： https://liuyueyi.github.io/he...

一灰灰的個(gè)人博客，記錄所有學(xué)習(xí)和工作中的博文，歡迎大家前去逛逛

聲明

盡信書則不如，已上內(nèi)容，純屬一家之言，因個(gè)人能力有限，難免有疏漏和錯(cuò)誤之處，如發(fā)現(xiàn)bug或者有更好的建議，歡迎批評(píng)指正，不吝感激

微博地址: 小灰灰Blog

QQ：一灰灰/3302797840

掃描關(guān)注

GPU云服務(wù)器云服務(wù)器事件機(jī)制事件冒泡機(jī)制事件注冊(cè)機(jī)制 extjs 事件機(jī)制

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/69711.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

Hwg

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

tensorflow對(duì)應(yīng)的cuda版本

閱讀 2088·2023-04-25 14:50
刷題日記Day2 | 構(gòu)造二叉樹

閱讀 2933·2021-11-17 09:33
Safari的CSS HACK方法

閱讀 2643·2019-08-30 13:07
前端每日實(shí)戰(zhàn)：154# 視頻演示如何創(chuàng)作一個(gè)眼冒金星的動(dòng)畫效果

閱讀 2868·2019-08-29 16:57
IPhoneX網(wǎng)頁(yè)布局簡(jiǎn)介

閱讀 931·2019-08-29 15:26
js中的0就是false，非0就是true。

閱讀 3583·2019-08-29 13:08
前端之CSS基礎(chǔ)學(xué)習(xí)

閱讀 2024·2019-08-29 12:32
9、 TypeScript 之函數(shù)返回值類型

閱讀 3417·2019-08-26 13:57

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

180609-Spring之事件驅(qū)動(dòng)機(jī)制的簡(jiǎn)單使用

相關(guān)文章

**初窺JavaScript事件機(jī)制的實(shí)現(xiàn)（一）—— Node.js事件驅(qū)動(dòng)實(shí)現(xiàn)概覽**

**Nodejs高性能原理(上) --- 異步非阻塞事件驅(qū)動(dòng)模型**

Netty源碼解析

架構(gòu)師必收藏的干貨?。?！

**vue總結(jié)系列--數(shù)據(jù)驅(qū)動(dòng)和響應(yīng)式**

發(fā)表評(píng)論

0條評(píng)論

Hwg

男|高級(jí)講師

TA的文章

tensorflow對(duì)應(yīng)的cuda版本

刷題日記Day2 | 構(gòu)造二叉樹

Safari的CSS HACK方法

前端每日實(shí)戰(zhàn)：154# 視頻演示如何創(chuàng)作一個(gè)眼冒金星的動(dòng)畫效果

IPhoneX網(wǎng)頁(yè)布局簡(jiǎn)介

js中的0就是false，非0就是true。

前端之CSS基礎(chǔ)學(xué)習(xí)

9、 TypeScript 之函數(shù)返回值類型

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

180609-Spring之事件驅(qū)動(dòng)機(jī)制的簡(jiǎn)單使用

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！