使用Spring的ApplicationEvent實(shí)現(xiàn)本地事件驅(qū)動(dòng)的實(shí)現(xiàn)方法
一、介紹
Spring內(nèi)置了簡(jiǎn)便的事件機(jī)制,可以非常方便的實(shí)現(xiàn)事件驅(qū)動(dòng),核心類包括
- ApplicationEvent,具體事件內(nèi)容,事件抽象基類,可繼承該類自定義具體事件
- ApplicationEventPublisher,事件發(fā)布器,可以發(fā)布ApplicationEvent,也可以發(fā)布普通的Object對(duì)象
- ApplicationListener,事件監(jiān)聽器,可以使用注解
@EventListener - TransactionalEventListener,事務(wù)事件監(jiān)聽,可監(jiān)聽事務(wù)提交前、提交后、事務(wù)回滾、事務(wù)完成(成功或失?。?/li>
二、使用示例
不定義事件,直接發(fā)布Object對(duì)象,同步
1、定義發(fā)送事件對(duì)象
public class UserEntity {
private long id;
private String name;
private String msg;
}
2、定義事件監(jiān)聽器
可以添加條件condition,限制監(jiān)聽具體的事件
@Slf4j
@Component
public class RegisterListener {
@EventListener(condition = "#entity.id != null and #entity.async==false ")
public void handlerEvent(UserEntity entity) {
try {
// 休眠5秒
TimeUnit.SECONDS.sleep(5);
} catch (InterruptedException e) {
e.printStackTrace();
}
log.info("handlerEvent: {}", entity);
}
}
3、定義發(fā)送接口以及實(shí)現(xiàn)類
public interface IRegisterService {
public void register(String name);
}
@Service
public class RegisterServiceImpl implements IRegisterService {
@Resource
private ApplicationEventPublisher applicationEventPublisher;
@Override
public void register(String name) {
UserEntity entity = new UserEntity();
entity.setName(name);
entity.setId(1L);
entity.setMsg("新用戶注冊(cè)同步調(diào)用");
applicationEventPublisher.publishEvent(entity);
}
}
4、測(cè)試Controller類,進(jìn)行測(cè)試
@Slf4j
@Controller
public class TestController {
@Resource
private IRegisterService registerService;
@RequestMapping("test")
@ResponseBody
public void test1(String name) {
registerService.register(name);
log.info("執(zhí)行同步調(diào)用結(jié)束");
}
}
在瀏覽器中輸入地址:http://localhost/test?name=nik
控制臺(tái)輸出:
handlerEvent: UserEntity(id=1, name=nik, msg=新用戶注冊(cè)同步調(diào)用)
執(zhí)行同步調(diào)用結(jié)束
三、異步發(fā)布示例
1、在啟動(dòng)類添加異步注解 @EnableAsync
2、在監(jiān)聽方法上添加注解 @Async
@Async
@EventListener(condition = "#entity.name != null and #entity.async ")
public void handlerEventAsync(UserEntity entity) {
try {
TimeUnit.SECONDS.sleep(5);
} catch (InterruptedException e) {
e.printStackTrace();
}
log.info("handlerEventAsync: {}", entity);
}
3、在service中添加異步發(fā)送方法
@Override
public void registerAsyn(String name) {
UserEntity entity = new UserEntity();
entity.setName(name);
entity.setId(1L);
entity.setMsg("新用戶注冊(cè)異步調(diào)用");
entity.setAsync(true);
applicationEventPublisher.publishEvent(entity);
}
4、測(cè)試
@RequestMapping("test")
@ResponseBody
public void test(String name) {
registerService.registerAsyn(name);
log.info("執(zhí)行異步調(diào)用結(jié)束");
}
控制臺(tái)輸出:
執(zhí)行異步調(diào)用結(jié)束
handlerEventAsync: UserEntity(id=1, name=nik, msg=新用戶注冊(cè)異步調(diào)用)
四、在事務(wù)提交后發(fā)布事件示例
比如,用戶注冊(cè)成功后給用戶發(fā)送成功短信,那么注冊(cè)成功必然是注冊(cè)方法事務(wù)提交成功后才代表成功。
Spring提供了注解@TransactionalEventListener監(jiān)聽事務(wù)事件,在@EventListener基礎(chǔ)上增加了屬性phase,包含以下四個(gè)值:
AFTER_COMMIT,事務(wù)提交成功后,默認(rèn)BEFORE_COMMIT,事務(wù)提交前AFTER_ROLLBACK,事務(wù)回滾后AFTER_COMPLETION,事務(wù)完成,AFTER_COMMIT或AFTER_ROLLBACK
1、自定義事務(wù)處理事件
public class RegisterCommitEvent extends ApplicationEvent {
@Getter
@Setter
private String msg;
@Getter
@Setter
private String name;
public RegisterCommitEvent(UserEntity source) {
super(source);
this.msg = source.getMsg();
this.name = source.getName();
}
}
2、在處理方法上添加事務(wù)注解,@Transactional
@Override
@Transactional
public void registerCommit(String name) {
UserEntity entity = new UserEntity();
entity.setName(name);
entity.setMsg("新用戶注冊(cè)事務(wù)提交事件");
RegisterCommitEvent registerEvent = new RegisterCommitEvent(entity);
userDao.save(entity);
// 發(fā)送事件
applicationEventPublisher.publishEvent(registerEvent);
}
3、添加事務(wù)事件監(jiān)聽
@Async
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void handlerEventCmmit(RegisterCommitEvent event) {
try {
TimeUnit.SECONDS.sleep(5);
} catch (InterruptedException e) {
e.printStackTrace();
}
log.info("handlerEventCmmit: {}", event);
}
4、測(cè)試
@RequestMapping("test")
@ResponseBody
public void test(String name) {
registerService.registerCommit(name);
log.info("執(zhí)行事務(wù)調(diào)用結(jié)束");
}
控制臺(tái)輸出:
執(zhí)行事務(wù)調(diào)用結(jié)束
handlerEventCmmit: RegisterCommitEvent[source=UserEntity(id=0, name=nik, msg=新用戶注冊(cè)事務(wù)提交事件)]
總結(jié)
Spring ApplicationEvent事件處理機(jī)制使用起來(lái)簡(jiǎn)單方便,可以對(duì)程序進(jìn)行有效解耦。
雖然可以發(fā)送任意類型的對(duì)象,但是在實(shí)際業(yè)務(wù)中容易產(chǎn)生混亂,建議根據(jù)實(shí)際業(yè)務(wù),定義好各類事件,并在監(jiān)聽方法中實(shí)現(xiàn)異步處理。
到此這篇關(guān)于使用Spring的ApplicationEvent實(shí)現(xiàn)本地事件驅(qū)動(dòng)的實(shí)現(xiàn)方法的文章就介紹到這了,更多相關(guān)Spring ApplicationEvent本地事件驅(qū)動(dòng)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Springboot Cucumber測(cè)試配置介紹詳解
這篇文章主要介紹了Springboot Cucumber測(cè)試配置介紹詳解,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來(lái)看看吧2018-04-04
java非公平鎖知識(shí)點(diǎn)實(shí)例詳解
在本篇文章里小編給大家整理了一篇關(guān)于java非公平鎖知識(shí)點(diǎn)實(shí)例詳解,有興趣的朋友們可以學(xué)習(xí)參考下。2021-10-10
基于jmeter實(shí)現(xiàn)跨線程組傳遞token過程圖解
這篇文章主要介紹了基于jmeter實(shí)現(xiàn)跨線程組傳遞token,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-04-04
通過spring boot 設(shè)置tomcat解決 post參數(shù)限制問題
這篇文章主要介紹了通過spring boot 設(shè)置tomcat解決 post參數(shù)限制問題,需要的朋友可以參考下2019-05-05
Java實(shí)現(xiàn)簡(jiǎn)單的抽牌游戲
這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)簡(jiǎn)單的抽牌游戲,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2020-04-04
Java線程的start方法回調(diào)run方法的操作技巧
面試過程中經(jīng)常會(huì)被面試官問到為什么我們調(diào)用start()方法時(shí)會(huì)執(zhí)行run()方法,為什么不能直接調(diào)用run()方法,問的一頭霧水,今天小編給大家介紹下Java線程的start方法回調(diào)run方法的操作技巧,需要的朋友參考下吧2017-11-11
java實(shí)現(xiàn)單鏈表中是否有環(huán)的方法詳解
本篇文章介紹了,用java實(shí)現(xiàn)單鏈表中是否有環(huán)的方法詳解。需要的朋友參考下2013-05-05
java使用WatchService監(jiān)控文件夾示例
本篇文章主要介紹了java使用WatchService監(jiān)控文件夾示例的資料,這里整理了詳細(xì)的代碼,有需要的小伙伴可以參考下。2017-02-02

