欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot Event實現(xiàn)異步消費機制的示例代碼

 更新時間:2024年04月25日 11:56:40   作者:壹粒麥子  
這篇文章主要介紹了SpringBoot Event實現(xiàn)異步消費機制,ApplicationEvent以及Listener是Spring為我們提供的一個事件監(jiān)聽、訂閱的實現(xiàn),內(nèi)部實現(xiàn)原理是觀察者設(shè)計模式,文中有詳細(xì)的代碼示例供大家參考,需要的朋友可以參考下

SpringBoot Event實現(xiàn)異步消費機制

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

通過 ApplicationEvent 類和 ApplicationListener 接口來提供在 ApplicationContext 中處理事件。如果一個 bean 實現(xiàn) ApplicationListener,那么每次 ApplicationEvent 被發(fā)布到 ApplicationContext 上,那個 bean 會被通知。

(1) ApplicationContext.publishEvent 默認(rèn)是同步操作, 并非異步操作,發(fā)布事件后需要等 @EventListener 執(zhí)行完

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

創(chuàng)建OrderEvent

用于傳遞消息

@Data
public class OrderEvent extends ApplicationEvent {  // 第一步 extends ApplicationEvent

   // 可添加多個字段
    public String message;

  	// 根據(jù)需要添加字段
    public OrderEvent(Object source, String message) {
        // 固定寫法
        super(source);  
        this.message = message;
    }

}

生產(chǎn)者

@RestController
@RequestMapping("order")
public class OrderController {

    // 第一步
    @Autowired
    private ApplicationContext applicationContext;

    @GetMapping("/createOrder/{orderNo}")
    public String createOrder(@PathVariable String orderNo) {
      
      	// 第二步
        applicationContext.publishEvent(new OrderEvent(this, String.format("訂單創(chuàng)建成功,訂單號為:%s", orderNo)));
        return "訂單常見成功";
      
    }
}

監(jiān)聽者

方式一:Event事件監(jiān)聽

事件監(jiān)聽是無序的

@Component   // 第一步
public class GlobalListener {

    private static Logger logger = LoggerFactory.getLogger(GlobalListener.class);

    @EventListener(OrderEvent.class)  // 第二步
    public void createOrder(OrderEvent orderEvent) {
        logger.info("{} 監(jiān)聽器接收到消息,訂單號為:{}", LocalDateTime.now(), orderEvent.getMessage());
    }
}

方式二:實現(xiàn) ApplicationListener接口

事件監(jiān)聽是無序的

@Component		// 第一步
public class OrderListener implements ApplicationListener<OrderEvent> {		// 第一步 implements ApplicationListener<OrderEvent>

    private static Logger logger = LoggerFactory.getLogger(OrderListener.class);

  	// 第三步
    @Override
    public void onApplicationEvent(OrderEvent orderEvent) {
        logger.info("方式二: {} 監(jiān)聽器接收到消息,訂單號為:{}", LocalDateTime.now(), orderEvent.getMessage());
    }
}

方式三:SmartApplicationListener實現(xiàn)有序監(jiān)聽

事件監(jiān)聽是有序的

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.event.SmartApplicationListener;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

@Component  // 第一步
public class SmartOrderListener implements SmartApplicationListener {

    private static Logger logger = LoggerFactory.getLogger(SmartOrderListener.class);

    /**
     * 該方法返回true&supportsSourceType同樣返回true時,才會調(diào)用該監(jiān)聽內(nèi)的onApplicationEvent方法
     *
     * @param aClass 接收到的監(jiān)聽事件類型
     * @return
     */
    @Override
    public boolean supportsEventType(Class<? extends ApplicationEvent> aClass) {
        // 指定只有 OrderEvent 監(jiān)聽類型才會執(zhí)行下面邏輯
        return aClass == OrderEvent.class;
    }

    /**
     * 該方法返回true&supportsEventType同樣返回true時,才會調(diào)用該監(jiān)聽內(nèi)的onApplicationEvent方法
     *
     * @param sourceType
     * @return
     */
    @Override
    public boolean supportsSourceType(Class<?> sourceType) {
        //只有在 OrderService 內(nèi)發(fā)布的 OrderEvent 事件時才會執(zhí)行下面邏輯,這里沒有,下面是案列
        // return aClass == OrderService.class;
        return SmartApplicationListener.super.supportsSourceType(sourceType);
    }

    /**
     * supportsEventType & supportsSourceType 兩個方法返回true時調(diào)用該方法執(zhí)行業(yè)務(wù)邏輯
     *
     * @param applicationEvent 具體監(jiān)聽實例,這里是 OrderEvent
     */
    @Override
    public void onApplicationEvent(ApplicationEvent applicationEvent) {

        //轉(zhuǎn)換事件類型
        OrderEvent orderEvent = (OrderEvent) applicationEvent;
        String message = orderEvent.getMessage();
        logger.info("方式三(有序): {} 監(jiān)聽器接收到消息,訂單號為:{}", LocalDateTime.now(), orderEvent.getMessage());
    }

    @Override
    public int getOrder() {
        return 0;
    }

}

以上就是SpringBoot Event實現(xiàn)異步消費機制的示例代碼的詳細(xì)內(nèi)容,更多關(guān)于SpringBoot Event異步消費機制的資料請關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • Java容器HashMap與HashTable詳解

    Java容器HashMap與HashTable詳解

    本文主要介紹HashMap 和 Hashtable的工作原理和使用方法,有興趣的朋友可以參考
    2017-04-04
  • 通俗易懂學(xué)習(xí)java并發(fā)工具類-Semaphore,Exchanger

    通俗易懂學(xué)習(xí)java并發(fā)工具類-Semaphore,Exchanger

    這篇文章主要介紹了java并發(fā)工具類-Semaphore,Exchanger,java并發(fā)工具類有很多,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,下面小編帶大家來一起學(xué)習(xí)一下吧
    2019-06-06
  • Springboot整合log4j2日志全解總結(jié)

    Springboot整合log4j2日志全解總結(jié)

    這篇文章主要介紹了Springboot整合log4j2日志全解總結(jié),小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-12-12
  • Java獲取精確到秒的時間戳方法

    Java獲取精確到秒的時間戳方法

    這篇文章主要為大家詳細(xì)介紹了Java獲取精確到秒的時間戳方法,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2017-12-12
  • java?安全ysoserial?URLDNS利用鏈分析

    java?安全ysoserial?URLDNS利用鏈分析

    這篇文章主要為大家介紹了java?安全ysoserial?URLDNS利用鏈分析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-10-10
  • idea 查看一個類的所有子類以及子類的子類并以層級關(guān)系顯示

    idea 查看一個類的所有子類以及子類的子類并以層級關(guān)系顯示

    這篇文章主要介紹了idea 查看一個類的所有子類以及子類的子類并以層級關(guān)系顯示,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-02-02
  • Java 實現(xiàn)簡易教務(wù)管理系統(tǒng)的代碼

    Java 實現(xiàn)簡易教務(wù)管理系統(tǒng)的代碼

    這篇文章主要介紹了Java 實現(xiàn)簡易教務(wù)管理系統(tǒng)的代碼,本文通過實例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2020-07-07
  • 幾種常見mybatis分頁實現(xiàn)方式

    幾種常見mybatis分頁實現(xiàn)方式

    這篇文章主要介紹了幾種常見mybatis分頁實現(xiàn)方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-11-11
  • springboot異步、定時、郵件任務(wù)方式

    springboot異步、定時、郵件任務(wù)方式

    這篇文章主要介紹了springboot異步、定時、郵件任務(wù)方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-05-05
  • JAVA簡單實現(xiàn)MD5注冊登錄加密實例代碼

    JAVA簡單實現(xiàn)MD5注冊登錄加密實例代碼

    本篇文章主要介紹了JAVA簡單實現(xiàn)MD5注冊登錄加密實例代碼,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-03-03

最新評論