建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
SpringApplicationEvent事件實(shí)現(xiàn)本地事件驅(qū)動(dòng)
一、介紹
Spring內(nèi)置了簡便的事件機(jī)制，可以非常方便的實(shí)現(xiàn)事件驅(qū)動(dòng)，核心類包括
創(chuàng)新互聯(lián)專注于沙市網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗(yàn)。 熱誠為您提供沙市營銷型網(wǎng)站建設(shè)，沙市網(wǎng)站制作、沙市網(wǎng)頁設(shè)計(jì)、沙市網(wǎng)站官網(wǎng)定制、小程序制作服務(wù)，打造沙市網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供沙市網(wǎng)站排名全網(wǎng)營銷落地服務(wù)。
- 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);
}
3、測(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ī)制使用起來簡單方便，可以對(duì)程序進(jìn)行有效解耦。
雖然可以發(fā)送任意類型的對(duì)象，但是在實(shí)際業(yè)務(wù)中容易產(chǎn)生混亂，建議根據(jù)實(shí)際業(yè)務(wù)，定義好各類事件，并在監(jiān)聽方法中實(shí)現(xiàn)異步處理。
文章標(biāo)題：SpringApplicationEvent事件實(shí)現(xiàn)本地事件驅(qū)動(dòng)
文章起源：http://m.fisionsoft.com.cn/article/cciihss.html
