小米官宣：2023年上半年出貨量中國第一！
今日早間，小米電視官方微博帶來消息，稱2023年小米電視上半年出貨量達(dá)到了中國第一，同時還表示小米電視的巨屏風(fēng)暴即將開始。“公布一個好消息2023年#小米電視上半年出貨量中國
事件監(jiān)聽和發(fā)布是Spring Framework中的一種機(jī)制，用于實(shí)現(xiàn)松散耦合的組件之間的通信。下面是事件監(jiān)聽和發(fā)布的詳細(xì)過程：
事件發(fā)布的過程：
事件監(jiān)聽的過程：
Spring Framework中的ApplicationEventPublisher接口用于發(fā)布和訂閱應(yīng)用程序事件。事件是一種機(jī)制，用于在應(yīng)用程序中實(shí)現(xiàn)松散耦合的組件通信。當(dāng)某些事件發(fā)生時，發(fā)布者可以通知所有已注冊的監(jiān)聽器，并執(zhí)行相應(yīng)的操作。下面是ApplicationEventPublisher的詳細(xì)用法說明和示例代碼：
創(chuàng)建自定義事件類：
首先，需要創(chuàng)建一個自定義事件類，繼承自ApplicationEvent。這個事件類將包含希望在應(yīng)用程序中發(fā)布的事件的信息。
import org.springframework.context.ApplicationEvent;public class MyCustomEvent extends ApplicationEvent { private String message; public MyCustomEvent(Object source, String message) { super(source); this.message = message; } public String getMessage() { return message; }}創(chuàng)建事件發(fā)布者：
事件發(fā)布者通常是Spring容器中的一個Bean，它使用ApplicationEventPublisher來發(fā)布事件。可以注入ApplicationEventPublisher接口以在需要時發(fā)布事件。
import org.springframework.context.ApplicationEventPublisher;import org.springframework.stereotype.Component;@Componentpublic class MyEventPublisher { private final ApplicationEventPublisher eventPublisher; public MyEventPublisher(ApplicationEventPublisher eventPublisher) { this.eventPublisher = eventPublisher; } public void publishCustomEvent(String message) { MyCustomEvent customEvent = new MyCustomEvent(this, message); eventPublisher.publishEvent(customEvent); }}創(chuàng)建事件監(jiān)聽器：
事件監(jiān)聽器負(fù)責(zé)處理事件。可以創(chuàng)建一個或多個事件監(jiān)聽器，每個監(jiān)聽器可以處理不同類型的事件。
import org.springframework.context.ApplicationListener;import org.springframework.stereotype.Component;@Componentpublic class MyEventListener implements ApplicationListener<MyCustomEvent> { @Override public void onApplicationEvent(MyCustomEvent event) { String message = event.getMessage(); // 處理事件 System.out.println("Received custom event with message: " + message); }}使用事件發(fā)布者發(fā)布事件：
在需要發(fā)布事件的地方，可以調(diào)用事件發(fā)布者的方法來觸發(fā)事件。
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.context.ConfigurableApplicationContext;@SpringBootApplicationpublic class MyApplication { public static void main(String[] args) { ConfigurableApplicationContext context = SpringApplication.run(MyApplication.class, args); MyEventPublisher eventPublisher = context.getBean(MyEventPublisher.class); eventPublisher.publishCustomEvent("Hello, Spring Boot Events!"); }}當(dāng)運(yùn)行MyApplication時，事件發(fā)布者將發(fā)布一個自定義事件，然后事件監(jiān)聽器將收到事件并執(zhí)行相應(yīng)的操作。
也可以創(chuàng)建同步和異步事件監(jiān)聽器，以便在事件發(fā)生時執(zhí)行不同的操作。同步監(jiān)聽器會在事件發(fā)布線程中直接執(zhí)行，而異步監(jiān)聽器則會將事件處理委托給另一個線程池，以實(shí)現(xiàn)并發(fā)處理。下面是同步和異步事件監(jiān)聽的示例說明：
import org.springframework.context.ApplicationListener;import org.springframework.stereotype.Component;@Componentpublic class MySyncEventListener implements ApplicationListener<MyCustomEvent> { @Override public void onApplicationEvent(MyCustomEvent event) { String message = event.getMessage(); // 模擬一個長時間運(yùn)行的操作 try { Thread.sleep(2000); // 模擬2秒的處理時間 } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("Synchronous Event Listener - Received custom event with message: " + message); }}在這個示例中，MySyncEventListener是一個同步事件監(jiān)聽器。它在onApplicationEvent()方法中執(zhí)行了一個模擬的長時間運(yùn)行的操作（2秒）。
要創(chuàng)建異步事件監(jiān)聽器，需要使用@Async注解來標(biāo)記監(jiān)聽器方法，然后配置一個TaskExecutorbean，以便Spring可以在異步線程池中執(zhí)行監(jiān)聽器方法。以下是一個示例：
import org.springframework.context.ApplicationListener;import org.springframework.scheduling.annotation.Async;import org.springframework.stereotype.Component;@Componentpublic class MyAsyncEventListener implements ApplicationListener<MyCustomEvent> { @Async @Override public void onApplicationEvent(MyCustomEvent event) { String message = event.getMessage(); // 模擬一個長時間運(yùn)行的操作 try { Thread.sleep(2000); // 模擬2秒的處理時間 } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("Asynchronous Event Listener - Received custom event with message: " + message); }}在這個示例中，MyAsyncEventListener是一個異步事件監(jiān)聽器。它的onApplicationEvent()方法被標(biāo)記為@Async，并且在方法內(nèi)模擬了一個長時間運(yùn)行的操作。
要配置異步事件監(jiān)聽器，需要執(zhí)行以下步驟：
在Spring Boot應(yīng)用程序的主類上使用@EnableAsync注解以啟用異步支持。
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.scheduling.annotation.EnableAsync;@SpringBootApplication@EnableAsyncpublic class MyApplication { public static void main(String[] args) { SpringApplication.run(MyApplication.class, args); }}在配置類或主類中定義一個TaskExecutor bean，以配置異步線程池。
import org.springframework.context.annotation.Bean;import org.springframework.core.task.TaskExecutor;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;@Beanpublic TaskExecutor taskExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(5); // 設(shè)置核心線程數(shù) executor.setMaxPoolSize(10); // 設(shè)置最大線程數(shù) executor.setQueueCapacity(25); // 設(shè)置隊(duì)列容量 executor.setThreadNamePrefix("MyAsyncThread-"); executor.initialize(); return executor;}通過以上配置，MyAsyncEventListener將會在異步線程中處理事件，而不會阻塞主線程。
請注意，異步監(jiān)聽器的配置可能因應(yīng)用程序的需求而有所不同。我們可以根據(jù)需要調(diào)整線程池的大小和其他參數(shù)。
示例中完整代碼，可以從下面網(wǎng)址獲取：
https://gitee.com/jlearning/wechatdemo.git
https://github.com/icoderoad/wxdemo.git
本文鏈接：http://www.tebozhan.com/showinfo-26-16513-0.htmlSpringboot 框架中事件監(jiān)聽和發(fā)布機(jī)制詳細(xì)介紹
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請聯(lián)系：2376512515@qq.com 津ICP備18001702號
津公網(wǎng)安備 12010102000574號