您好,登錄后才能下訂單哦!
本篇內(nèi)容介紹了“怎么使用Spring的ApplicationEvent實(shí)現(xiàn)本地事件驅(qū)動”的有關(guān)知識,在實(shí)際案例的操作過程中,不少人都會遇到這樣的困境,接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧!希望大家仔細(xì)閱讀,能夠?qū)W有所成!
Spring內(nèi)置了簡便的事件機(jī)制,可以非常方便的實(shí)現(xiàn)事件驅(qū)動,核心類包括
ApplicationEvent,具體事件內(nèi)容,事件抽象基類,可繼承該類自定義具體事件
ApplicationEventPublisher,事件發(fā)布器,可以發(fā)布ApplicationEvent,也可以發(fā)布普通的Object對象
ApplicationListener,事件監(jiān)聽器,可以使用注解@EventListener
TransactionalEventListener,事務(wù)事件監(jiān)聽,可監(jiān)聽事務(wù)提交前、提交后、事務(wù)回滾、事務(wù)完成(成功或失?。?/p>
不定義事件,直接發(fā)布Object對象,同步
1、定義發(fā)送事件對象
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("新用戶注冊同步調(diào)用"); applicationEventPublisher.publishEvent(entity); } }
4、測試Controller類,進(jìn)行測試
@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
控制臺輸出:
handlerEvent: UserEntity(id=1, name=nik, msg=新用戶注冊同步調(diào)用)
執(zhí)行同步調(diào)用結(jié)束
1、在啟動類添加異步注解 @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("新用戶注冊異步調(diào)用"); entity.setAsync(true); applicationEventPublisher.publishEvent(entity); }
4、測試
@RequestMapping("test") @ResponseBody public void test(String name) { registerService.registerAsyn(name); log.info("執(zhí)行異步調(diào)用結(jié)束"); }
控制臺輸出:
執(zhí)行異步調(diào)用結(jié)束
handlerEventAsync: UserEntity(id=1, name=nik, msg=新用戶注冊異步調(diào)用)
比如,用戶注冊成功后給用戶發(fā)送成功短信,那么注冊成功必然是注冊方法事務(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("新用戶注冊事務(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、測試
@RequestMapping("test") @ResponseBody public void test(String name) { registerService.registerCommit(name); log.info("執(zhí)行事務(wù)調(diào)用結(jié)束"); }
控制臺輸出:
執(zhí)行事務(wù)調(diào)用結(jié)束
handlerEventCmmit: RegisterCommitEvent[source=UserEntity(id=0, name=nik, msg=新用戶注冊事務(wù)提交事件)]
“怎么使用Spring的ApplicationEvent實(shí)現(xiàn)本地事件驅(qū)動”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注億速云網(wǎng)站,小編將為大家輸出更多高質(zhì)量的實(shí)用文章!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。