SpringBoot Event實(shí)現(xiàn)異步消費(fèi)機(jī)制的示例代碼
SpringBoot Event實(shí)現(xiàn)異步消費(fèi)機(jī)制
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ù)性。
通過(guò) ApplicationEvent 類(lèi)和 ApplicationListener 接口來(lái)提供在 ApplicationContext 中處理事件。如果一個(gè) bean 實(shí)現(xiàn) ApplicationListener,那么每次 ApplicationEvent 被發(fā)布到 ApplicationContext 上,那個(gè) bean 會(huì)被通知。
(1) ApplicationContext.publishEvent 默認(rèn)是同步操作, 并非異步操作,發(fā)布事件后需要等 @EventListener 執(zhí)行完
(2) 如果需要開(kāi)啟異步操作 需要在 @EventListener 上 增加 @Async 注解。
創(chuàng)建OrderEvent
用于傳遞消息
@Data public class OrderEvent extends ApplicationEvent { // 第一步 extends ApplicationEvent // 可添加多個(gè)字段 public String message; // 根據(jù)需要添加字段 public OrderEvent(Object source, String message) { // 固定寫(xiě)法 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)建成功,訂單號(hào)為:%s", orderNo))); return "訂單常見(jiàn)成功"; } }
監(jiān)聽(tīng)者
方式一:Event事件監(jiān)聽(tīng)
事件監(jiān)聽(tīng)是無(wú)序的
@Component // 第一步 public class GlobalListener { private static Logger logger = LoggerFactory.getLogger(GlobalListener.class); @EventListener(OrderEvent.class) // 第二步 public void createOrder(OrderEvent orderEvent) { logger.info("{} 監(jiān)聽(tīng)器接收到消息,訂單號(hào)為:{}", LocalDateTime.now(), orderEvent.getMessage()); } }
方式二:實(shí)現(xiàn) ApplicationListener接口
事件監(jiān)聽(tīng)是無(wú)序的
@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)聽(tīng)器接收到消息,訂單號(hào)為:{}", LocalDateTime.now(), orderEvent.getMessage()); } }
方式三:SmartApplicationListener實(shí)現(xiàn)有序監(jiān)聽(tīng)
事件監(jiān)聽(tīng)是有序的
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時(shí),才會(huì)調(diào)用該監(jiān)聽(tīng)內(nèi)的onApplicationEvent方法 * * @param aClass 接收到的監(jiān)聽(tīng)事件類(lèi)型 * @return */ @Override public boolean supportsEventType(Class<? extends ApplicationEvent> aClass) { // 指定只有 OrderEvent 監(jiān)聽(tīng)類(lèi)型才會(huì)執(zhí)行下面邏輯 return aClass == OrderEvent.class; } /** * 該方法返回true&supportsEventType同樣返回true時(shí),才會(huì)調(diào)用該監(jiān)聽(tīng)內(nèi)的onApplicationEvent方法 * * @param sourceType * @return */ @Override public boolean supportsSourceType(Class<?> sourceType) { //只有在 OrderService 內(nèi)發(fā)布的 OrderEvent 事件時(shí)才會(huì)執(zhí)行下面邏輯,這里沒(méi)有,下面是案列 // return aClass == OrderService.class; return SmartApplicationListener.super.supportsSourceType(sourceType); } /** * supportsEventType & supportsSourceType 兩個(gè)方法返回true時(shí)調(diào)用該方法執(zhí)行業(yè)務(wù)邏輯 * * @param applicationEvent 具體監(jiān)聽(tīng)實(shí)例,這里是 OrderEvent */ @Override public void onApplicationEvent(ApplicationEvent applicationEvent) { //轉(zhuǎn)換事件類(lèi)型 OrderEvent orderEvent = (OrderEvent) applicationEvent; String message = orderEvent.getMessage(); logger.info("方式三(有序): {} 監(jiān)聽(tīng)器接收到消息,訂單號(hào)為:{}", LocalDateTime.now(), orderEvent.getMessage()); } @Override public int getOrder() { return 0; } }
以上就是SpringBoot Event實(shí)現(xiàn)異步消費(fèi)機(jī)制的示例代碼的詳細(xì)內(nèi)容,更多關(guān)于SpringBoot Event異步消費(fèi)機(jī)制的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
通俗易懂學(xué)習(xí)java并發(fā)工具類(lèi)-Semaphore,Exchanger
這篇文章主要介紹了java并發(fā)工具類(lèi)-Semaphore,Exchanger,java并發(fā)工具類(lèi)有很多,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,下面小編帶大家來(lái)一起學(xué)習(xí)一下吧2019-06-06idea 查看一個(gè)類(lèi)的所有子類(lèi)以及子類(lèi)的子類(lèi)并以層級(jí)關(guān)系顯示
這篇文章主要介紹了idea 查看一個(gè)類(lèi)的所有子類(lèi)以及子類(lèi)的子類(lèi)并以層級(jí)關(guān)系顯示,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-02-02Java 實(shí)現(xiàn)簡(jiǎn)易教務(wù)管理系統(tǒng)的代碼
這篇文章主要介紹了Java 實(shí)現(xiàn)簡(jiǎn)易教務(wù)管理系統(tǒng)的代碼,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-07-07幾種常見(jiàn)mybatis分頁(yè)實(shí)現(xiàn)方式
這篇文章主要介紹了幾種常見(jiàn)mybatis分頁(yè)實(shí)現(xiàn)方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-11-11springboot異步、定時(shí)、郵件任務(wù)方式
這篇文章主要介紹了springboot異步、定時(shí)、郵件任務(wù)方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-05-05JAVA簡(jiǎn)單實(shí)現(xiàn)MD5注冊(cè)登錄加密實(shí)例代碼
本篇文章主要介紹了JAVA簡(jiǎn)單實(shí)現(xiàn)MD5注冊(cè)登錄加密實(shí)例代碼,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-03-03