SpringBoot創(chuàng)建監(jiān)聽(tīng)器的方法示例
監(jiān)聽(tīng)器的作用
- 解耦:通過(guò)監(jiān)聽(tīng)器,可以將
事件發(fā)送者
和事件處理者
解耦,使得兩者之間的依賴(lài)關(guān)系降低。 - 事件驅(qū)動(dòng):監(jiān)聽(tīng)器允許程序以
事件驅(qū)動(dòng)
的方式運(yùn)行,即當(dāng)特定事件發(fā)生時(shí),自動(dòng)觸發(fā)相應(yīng)的處理邏輯。 - 跨組件通信:在不同組件或模塊之間,可以通過(guò)監(jiān)聽(tīng)器實(shí)現(xiàn)通信和協(xié)作。
在Spring Boot中,可以通過(guò)實(shí)現(xiàn) Spring 提供的監(jiān)聽(tīng)器接口或注解來(lái)創(chuàng)建監(jiān)聽(tīng)器。Spring提供了多種類(lèi)型的監(jiān)聽(tīng)器,包括 ApplicationListener 用于監(jiān)聽(tīng)?wèi)?yīng)用事件, @EventListener 注解用于監(jiān)聽(tīng)特定事件等。
ApplicationEvent 是Spring框架中的一個(gè)核心類(lèi),用于在應(yīng)用程序中 發(fā)布和監(jiān)聽(tīng)事件 。它是所有Spring事件的 基類(lèi) ,一個(gè)抽象類(lèi),可以被繼承來(lái)創(chuàng)建自定義的事件。事件可以在應(yīng)用程序中的不同組件之間進(jìn)行傳遞和通信。
ApplicationEvent 攜帶一個(gè) Object 對(duì)象,可以被發(fā)布,事件監(jiān)聽(tīng)者監(jiān)聽(tīng)到這個(gè)事件后,會(huì)觸發(fā)自定義邏輯(操作Object對(duì)象)。是實(shí)現(xiàn)事件驅(qū)動(dòng)編程的重要機(jī)制,通過(guò)事件和監(jiān)聽(tīng)器的協(xié)作,可以實(shí)現(xiàn)不同組件之間的解耦和高效通信。
實(shí)現(xiàn) ApplicationListener 監(jiān)聽(tīng)事件
1、創(chuàng)建 CustomEvent
事件類(lèi)
import org.springframework.context.ApplicationEvent; public class CustomEvent extends ApplicationEvent { // CustomEvent需要繼承自ApplicationEvent private String message; public CustomEvent(Object source, String message) { super(source); this.message = message; } public String getMessage() { return message; } }
2、自定義監(jiān)聽(tīng)器,監(jiān)聽(tīng)事件類(lèi)
import org.springframework.context.ApplicationEvent; import org.springframework.context.ApplicationListener; import org.springframework.stereotype.Component; @Component public class CustomEventListener implements ApplicationListener<CustomEvent> { @Override public void onApplicationEvent(CustomEvent event) { // 當(dāng)CustomEvent事件被發(fā)布時(shí),這個(gè)方法會(huì)被調(diào)用 System.out.println("監(jiān)聽(tīng)事件成功 - " + event.getMessage()); // 在這里編寫(xiě)處理事件的邏輯 // 比如對(duì)消息進(jìn)行合規(guī)處理 } }
3、觸發(fā)監(jiān)聽(tīng)事件
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationContext; import org.springframework.stereotype.Component; @Component public class EventPublisher { private final ApplicationContext applicationContext; @Autowired public EventPublisher(ApplicationContext applicationContext) { this.applicationContext = applicationContext; } public void publishCustomEvent(String message) { // 發(fā)布CustomEvent CustomEvent customEvent = new CustomEvent(this, message); applicationContext.publishEvent(customEvent); } }
當(dāng) publishCustomEvent 方法被調(diào)用并發(fā)布 CustomEvent 時(shí),所有實(shí)現(xiàn)了 ApplicationListener<CustomEvent> 的監(jiān)聽(tīng)器都會(huì)收到通知,并執(zhí)行onApplicationEvent方法。
使用 @EventListener 注解監(jiān)聽(tīng)事件
如果你想要使用注解來(lái)創(chuàng)建監(jiān)聽(tīng)器,可以使用@EventListener注解:
import org.springframework.context.event.EventListener; import org.springframework.stereotype.Component; @Component public class AnnotationBasedEventListener { @EventListener public void handleCustomEvent(CustomEvent event) { // 當(dāng)CustomEvent事件被發(fā)布時(shí),這個(gè)方法會(huì)被調(diào)用 System.out.println("監(jiān)聽(tīng)事件成功 - " + event.getMessage()); // 在這里編寫(xiě)處理事件的邏輯 // 比如對(duì)消息進(jìn)行合規(guī)處理 } }
使用 @EventListener
注解可以簡(jiǎn)化監(jiān)聽(tīng)器的創(chuàng)建過(guò)程,并且可以在 方法級(jí)別上
指定需要監(jiān)聽(tīng)的事件類(lèi)型。
無(wú)論是通過(guò)實(shí)現(xiàn)接口還是使用注解,Spring Boot都提供了以實(shí)現(xiàn)事件驅(qū)動(dòng)的應(yīng)用程序邏輯。
到此這篇關(guān)于SpringBoot創(chuàng)建監(jiān)聽(tīng)器的方法示例的文章就介紹到這了,更多相關(guān)SpringBoot創(chuàng)建監(jiān)聽(tīng)器內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
springsecurity?登錄認(rèn)證流程分析一(ajax)
這篇文章主要介紹了springsecurity?登錄認(rèn)證一(ajax篇),本文通過(guò)實(shí)例代碼圖文相結(jié)合給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧2024-08-08詳解Java類(lèi)庫(kù)的概念以及import的使用方法
這篇文章主要介紹了詳解Java類(lèi)庫(kù)的概念以及import的使用方法,是Java入門(mén)學(xué)習(xí)中的基礎(chǔ)知識(shí),需要的朋友可以參考下2015-09-09Mybatis工具類(lèi)JdbcTypeInterceptor運(yùn)行時(shí)自動(dòng)添加jdbcType屬性
今天小編就為大家分享一篇關(guān)于Mybatis工具類(lèi)JdbcTypeInterceptor運(yùn)行時(shí)自動(dòng)添加jdbcType屬性,小編覺(jué)得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來(lái)看看吧2018-12-12Hadoop?MapReduce實(shí)現(xiàn)單詞計(jì)數(shù)(Word?Count)
這篇文章主要為大家詳細(xì)介紹了如何利用Hadoop實(shí)現(xiàn)單詞計(jì)數(shù)(Word?Count)的MapReduce,文中的示例代碼講解詳細(xì),感興趣的可以跟隨小編一起學(xué)習(xí)一下2023-05-05基于Zookeeper實(shí)現(xiàn)服務(wù)注冊(cè)和服務(wù)發(fā)現(xiàn)功能
無(wú)論是采用SOA還是微服務(wù)架構(gòu),都需要使用服務(wù)注冊(cè)和服務(wù)發(fā)現(xiàn)組件,本文將基于 Zookeeper 實(shí)現(xiàn)服務(wù)注冊(cè)和服務(wù)發(fā)現(xiàn)功能,如果跟我一樣有同樣的困惑,希望可以通過(guò)本文了解其他組件如何使用 Zookeeper 作為注冊(cè)中心的工作原理2023-09-09防止SpringMVC攔截器攔截js等靜態(tài)資源文件的解決方法
本篇文章主要介紹了防止SpringMVC攔截器攔截js等靜態(tài)資源文件的解決方法,具有一定的參考價(jià)值,有興趣的同學(xué)可以了解一下2017-09-09Java插入修改刪除數(shù)據(jù)庫(kù)數(shù)據(jù)的基本方法
這篇文章主要介紹了Java插入修改刪除數(shù)據(jù)庫(kù)數(shù)據(jù)的基本方法,是Java入門(mén)學(xué)習(xí)中的基礎(chǔ)知識(shí),需要的朋友可以參考下2015-10-10