Spring的事件和監(jiān)聽器-同步與異步詳解
Spring的事件和監(jiān)聽器-同步與異步
Application下抽象子類ApplicationContextEvent的下面有4個(gè)已經(jīng)實(shí)現(xiàn)好的事件
ContextClosedEvent(容器關(guān)閉時(shí))ContextRefreshedEvent(容器刷新是)ContextStartedEvent(容器啟動時(shí)候)ContextStoppedEvent(容器停止的時(shí)候)
同樣,這四個(gè)事件都繼承了ApplicationEvent,如果我們想自定義事件,也可以通過繼承ApplicationEvent來實(shí)現(xiàn)
1、首先新建StartWorkflowEvent.java,
繼承ApplicationEvent抽象類
public class StartWorkflowEvent extends ApplicationEvent {
//存放構(gòu)造器送入的值
private String msg;
//構(gòu)造器參數(shù)可以隨意設(shè)置,這里為了方便調(diào)試,設(shè)置為字符串
public StartWorkflowEvent (String msg) {
super(msg);
this.msg=msg;
}
//自定義一個(gè)方法,這個(gè)方法也可以隨意寫,這里也是測試用
public void myevent(){
System.out.println("********My event**************");
System.out.println(msg);
System.out.println("*******************************");
}
}
2、新建一個(gè)監(jiān)聽器StartWorkflowListener.java
實(shí)現(xiàn)ApplicationListener<StartWorkflowEvent>
/**
* 發(fā)起流程事件監(jiān)聽
*/
@Component("startWorkflowListener")
public class StartWorkflowListener implements ApplicationListener<StartWorkflowEvent> {
@Autowired
private OaWorkflowHepler oaWorkflowHepler;
//@Async注解異步調(diào)用時(shí)使用, 異步調(diào)用時(shí), 需要在xml配置文件中添加 <task:annotation-driven />
// @Async
@Override
public void onApplicationEvent(StartWorkflowEvent event) {
oaWorkflowHepler.start(event.getMsg());
}
}
3、創(chuàng)建一個(gè)事件發(fā)布類EventPublisher.java
/**
* 發(fā)布事件
*/
@Component("eventPublisher")
public class EventPublisher {
@Autowired
private ApplicationContext applicationContext;
/**
* 發(fā)布事件
* @param event
*/
public void publishEvent(ApplicationEvent event) {
applicationContext.publishEvent(event);
}
}
4、相關(guān)的配置
<task:annotation-driven />配置:
executor:指定一個(gè)缺省的executor給@Async使用。
例子:
<task:annotation-driven executor="asyncExecutor" />
<task:executor />配置參數(shù):
id:當(dāng)配置多個(gè)executor時(shí),被@Async("id")指定使用;也被作為線程名的前綴。core size:最小的線程數(shù),缺?。?max size:最大的線程數(shù),缺?。篒nteger.MAX_VALUEqueue-capacity:當(dāng)最小的線程數(shù)已經(jīng)被占用滿后,新的任務(wù)會被放進(jìn)queue里面,當(dāng)這個(gè) queue的capacity也被占滿之后,pool里面會創(chuàng)建新線程處理這個(gè)任務(wù),直到總線程數(shù)達(dá)到了max size,這時(shí)系統(tǒng)會拒絕這個(gè)任務(wù)并拋出TaskRejectedException異常(缺省配置的情況下,可以通過rejection-policy 來決定如何處理這種情況)。缺省值為:Integer.MAX_VALUEkeep-alive:超過core size的那些線程,任務(wù)完成后,再經(jīng)過這個(gè)時(shí)長(秒)會被結(jié)束掉rejection-policy:當(dāng)pool已經(jīng)達(dá)到max size的時(shí)候,如何處理新任務(wù)ABORT(缺?。簰伋鯰askRejectedException異常,然后不執(zhí)行DISCARD:不執(zhí)行,也不拋出異常DISCARD_OLDEST:丟棄queue中最舊的那個(gè)任務(wù)CALLER_RUNS:不在新線程中執(zhí)行任務(wù),而是有調(diào)用者所在的線程來執(zhí)行
Spring事件、異步監(jiān)聽
使用事件的模式可以對系統(tǒng)進(jìn)行解耦,事件源發(fā)布一個(gè)事件,
事件監(jiān)聽器可以消費(fèi)這個(gè)事件,而事件源不用關(guān)注發(fā)布的事件有哪些監(jiān)聽器,
這可以對系統(tǒng)進(jìn)行解耦

public class Mains extends ApplicationEvent {
public Mains(Object name) {
super(name);
System.out.println(String.format("Hi,我是被監(jiān)聽的%s!",name));
}
}
@Component
public class ListenerMains {
//@Async // 開啟異步就無法使用@Order(0)進(jìn)行排序了
@Order(0)
@EventListener(Mains.class)
public void listener(Mains mains){
System.out.println("這是第一個(gè)監(jiān)聽類 "+mains.getSource());
}
//@Async
@Order(1)
@EventListener(Mains.class)
public void listener2(Mains mains){
System.out.println("這是第二個(gè)監(jiān)聽類 "+mains.getSource());
}
//@Async
@Order(2)
@EventListener(Mains.class)
public void listener3(Mains mains){
System.out.println("這是第三個(gè)監(jiān)聽類 "+mains.getSource());
}
}
public class TestController {
@Autowired
GetAccessToken getAccessToken;
@Autowired
ApplicationEventPublisher publisher;
@RequestMapping("test")
public Object get() {
publisher.publishEvent(new Mains("哈哈哈哈"));
}
}
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
SpringBoot整合Prometheus如何實(shí)現(xiàn)資源監(jiān)控
本文介紹了如何使用Prometheus監(jiān)控SpringBoot應(yīng)用,Prometheus是一個(gè)開源的監(jiān)控和告警工具,SpringBootActuator提供了監(jiān)控和管理SpringBoot應(yīng)用的工具,通過添加依賴、配置Actuator和Prometheus,可以實(shí)現(xiàn)對SpringBoot應(yīng)用的實(shí)時(shí)監(jiān)控2024-12-12
MyBatis 添加元數(shù)據(jù)自定義元素標(biāo)簽的實(shí)現(xiàn)代碼
這篇文章主要介紹了MyBatis 添加元數(shù)據(jù)自定義元素標(biāo)簽的實(shí)現(xiàn)代碼,本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-07-07
Spring?Boot應(yīng)用程序中如何使用Keycloak詳解
這篇文章主要為大家介紹了Spring?Boot應(yīng)用程序中如何使用Keycloak詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-05-05
Java中的阻塞隊(duì)列BlockingQueue使用詳解
這篇文章主要介紹了Java中的阻塞隊(duì)列BlockingQueue使用詳解,阻塞隊(duì)列是一種線程安全的數(shù)據(jù)結(jié)構(gòu),用于在多線程環(huán)境下進(jìn)行數(shù)據(jù)交換,它提供了一種阻塞的機(jī)制,當(dāng)隊(duì)列為空時(shí),消費(fèi)者線程將被阻塞,直到隊(duì)列中有數(shù)據(jù)可供消費(fèi),需要的朋友可以參考下2023-10-10
Java中的stream流的概念解析及實(shí)際運(yùn)用總結(jié)
流是指傳輸時(shí)的數(shù)據(jù),Java為流準(zhǔn)備了很多內(nèi)置類,尤其是IO輸入輸出流非常常用,這里我們來看一下Java中的stream流的概念解析及實(shí)際運(yùn)用總結(jié)2016-06-06
詳談Enumeration接口和Iterator接口的區(qū)別
下面小編就為大家?guī)硪黄斦凟numeration接口和Iterator接口的區(qū)別。小編覺得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-08-08
java Servlet 實(shí)現(xiàn)動態(tài)驗(yàn)證碼圖片示例
這篇文章主要介紹了java Servlet 實(shí)現(xiàn)動態(tài)驗(yàn)證碼圖片示例的資料,這里整理了詳細(xì)的代碼,有需要的小伙伴可以參考下。2017-02-02

