實(shí)際業(yè)務(wù)開發(fā)過程中捷绑，業(yè)務(wù)邏輯可能非常復(fù)雜，核心業(yè)務(wù) + N個(gè)子業(yè)務(wù)氢妈。如果都放到一塊兒去做粹污，代碼可能會(huì)很長(zhǎng)，耦合度不斷攀升首量，維護(hù)起來也麻煩壮吩，甚至頭疼进苍。還有一些業(yè)務(wù)場(chǎng)景不需要在一次請(qǐng)求中同步完成，比如郵件發(fā)送鸭叙、短信發(fā)送等觉啊。
MQ 確實(shí)可以解決這個(gè)問題，但 MQ 重啊沈贝，非必要不提升架構(gòu)復(fù)雜度杠人。
針對(duì)這些問題，我們了解一下 Spring Event宋下。
Spring Event 同步使用
Spring Event（Application Event）其實(shí)就是一個(gè)觀察者設(shè)計(jì)模式嗡善，一個(gè) Bean 處理完成任務(wù)后希望通知其它 Bean 或者說一個(gè) Bean 想觀察監(jiān)聽另一個(gè)Bean 的行為。
Spring Event 用來解耦業(yè)務(wù)真的賊好用学歧！
1. 自定義事件
定義事件罩引，繼承 ApplicationEvent 的類成為一個(gè)事件類
/**
* @author Strive
* @date 2022/4/22 18:00
* @description
*/
@Data
@ToString
public class OrderProductEvent extends ApplicationEvent {
/** 該類型事件攜帶的信息 */
private String orderId;
public OrderProductEvent(Object source, String orderId) {
super(source);
this.orderId = orderId;
}
}
2. 定義監(jiān)聽器
監(jiān)聽并處理事件，實(shí)現(xiàn) ApplicationListener 接口或者使用 @EventListener 注解
/**
* 實(shí)現(xiàn) ApplicationListener 接口撩满，并指定監(jiān)聽的事件類型
*
* @author Strive
* @date 2022/4/24 09:09
* @description
*/
@Slf4j
@Component
public class OrderProductListener implements ApplicationListener<OrderProductEvent> {
/** 使用 onApplicationEvent 方法對(duì)消息進(jìn)行接收處理 */
@SneakyThrows
@Override
public void onApplicationEvent(OrderProductEvent event) {
String orderId = event.getOrderId();
long start = System.currentTimeMillis();
Thread.sleep(2000);
long end = System.currentTimeMillis();
log.info("{}：校驗(yàn)訂單商品價(jià)格耗時(shí)：({})毫秒", orderId, (end - start));
}
}
3. 定義發(fā)布者
發(fā)布事件蜒程，通過 ApplicationEventPublisher 發(fā)布事件
/**
* @author Strive
* @date 2022/4/24 09:25
* @description
*/
@Slf4j
@Service
@RequiredArgsConstructor
public class OrderService {
/** 注入ApplicationContext用來發(fā)布事件 */
private final ApplicationContext applicationContext;
/**
* 下單
*
* @param orderId 訂單ID
*/
public String buyOrder(String orderId) {
long start = System.currentTimeMillis();
// 1.查詢訂單詳情
// 2.檢驗(yàn)訂單價(jià)格 （同步處理）
applicationContext.publishEvent(new OrderProductEvent(this, orderId));
// 3.短信通知（異步處理）
long end = System.currentTimeMillis();
log.info("任務(wù)全部完成绅你，總耗時(shí)：({})毫秒", end - start);
return "購(gòu)買成功";
}
}
4.單測(cè)執(zhí)行
@SpringBootTest
public class OrderServiceTest {
@Autowired private OrderService orderService;
@Test
public void buyOrderTest() {
orderService.buyOrder("732171109");
}
}
執(zhí)行結(jié)果如下：
2022-04-24 10:13:17.535 INFO 44272 --- [ main] c.c.m.e.listener.OrderProductListener : 732171109：校驗(yàn)訂單商品價(jià)格耗時(shí)：(2008)毫秒
2022-04-24 10:13:17.536 INFO 44272 --- [ main] c.c.mingyue.event.service.OrderService : 任務(wù)全部完成伺帘，總耗時(shí)：(2009)毫秒
Spring Event 異步使用
有些業(yè)務(wù)場(chǎng)景不需要在一次請(qǐng)求中同步完成，比如郵件發(fā)送忌锯、短信發(fā)送等伪嫁。
1. 自定義事件
@Data
@AllArgsConstructor
public class MsgEvent {
/** 該類型事件攜帶的信息 */
public String orderId;
}
2. 定義監(jiān)聽器
推薦使用 @EventListener 注解
@Slf4j
@Component
public class MsgListener {
@SneakyThrows
@EventListener(MsgEvent.class)
public void sendMsg(MsgEvent event) {
String orderId = event.getOrderId();
long start = System.currentTimeMillis();
log.info("開發(fā)發(fā)送短信");
log.info("開發(fā)發(fā)送郵件");
Thread.sleep(4000);
long end = System.currentTimeMillis();
log.info("{}：發(fā)送短信、郵件耗時(shí)：({})毫秒", orderId, (end - start));
}
}
3. 定義發(fā)布者
/**
* 下單
* @param orderId 訂單ID
*/
public String buyOrder(String orderId) {
long start = System.currentTimeMillis();
// 1.查詢訂單詳情
// 2.檢驗(yàn)訂單價(jià)格 （同步處理）
applicationContext.publishEvent(new OrderProductEvent(this, orderId));
// 3.短信通知（異步處理）
applicationContext.publishEvent(new MsgEvent(orderId));
long end = System.currentTimeMillis();
log.info("任務(wù)全部完成偶垮，總耗時(shí)：({})毫秒", end - start);
return "購(gòu)買成功";
}
4. 單測(cè)執(zhí)行（同步）
@Test
public void buyOrderTest() {
orderService.buyOrder("732171109");
}
執(zhí)行結(jié)果如下：
2022-04-24 10:24:13.905 INFO 54848 --- [ main] c.c.m.e.listener.OrderProductListener : 732171109：校驗(yàn)訂單商品價(jià)格耗時(shí)：(2004)毫秒
2022-04-24 10:24:13.906 INFO 54848 --- [ main] c.c.mingyue.event.listener.MsgListener : 開發(fā)發(fā)送短信
2022-04-24 10:24:13.907 INFO 54848 --- [ main] c.c.mingyue.event.listener.MsgListener : 開發(fā)發(fā)送郵件
2022-04-24 10:24:17.908 INFO 54848 --- [ main] c.c.mingyue.event.listener.MsgListener : 732171109：發(fā)送短信张咳、郵件耗時(shí)：(4002)毫秒
2022-04-24 10:24:17.908 INFO 54848 --- [ main] c.c.mingyue.event.service.OrderService : 任務(wù)全部完成，總耗時(shí)：(6008)毫秒
5.開啟異步
啟動(dòng)類增加 @EnableAsync 注解
@EnableAsync
@SpringBootApplication
public class MingYueSpringbootEventApplication {
public static void main(String[] args) {
SpringApplication.run(MingYueSpringbootEventApplication.class, args);
}
}
Listener 類需要開啟異步的方法增加 @Async 注解
@Async
@SneakyThrows
@EventListener(MsgEvent.class)
public void sendMsg(MsgEvent event) {
String orderId = event.getOrderId();
long start = System.currentTimeMillis();
log.info("開發(fā)發(fā)送短信");
log.info("開發(fā)發(fā)送郵件");
Thread.sleep(4000);
long end = System.currentTimeMillis();
log.info("{}：發(fā)送短信似舵、郵件耗時(shí)：({})毫秒", orderId, (end - start));
}
6.單測(cè)執(zhí)行（異步）
發(fā)送短信的線程顯示 task-1脚猾，主線程結(jié)束后（總耗時(shí)：(2017)毫秒）控制臺(tái)停止打印了
2022-04-24 10:30:59.002 INFO 59448 --- [ main] c.c.m.e.listener.OrderProductListener : 732171109：校驗(yàn)訂單商品價(jià)格耗時(shí)：(2009)毫秒
2022-04-24 10:30:59.009 INFO 59448 --- [ main] c.c.mingyue.event.service.OrderService : 任務(wù)全部完成，總耗時(shí)：(2017)毫秒
2022-04-24 10:30:59.028 INFO 59448 --- [ task-1] c.c.mingyue.event.listener.MsgListener : 開發(fā)發(fā)送短信
2022-04-24 10:30:59.028 INFO 59448 --- [ task-1] c.c.mingyue.event.listener.MsgListener : 開發(fā)發(fā)送郵件
最后說一句（別白嫖砚哗，求關(guān)注）
陳某每一篇文章都是精心輸出龙助，已經(jīng)寫了3個(gè)專欄，整理成PDF蛛芥，獲取方式如下：
- 《Spring Cloud 進(jìn)階》PDF：關(guān)注公眾號(hào)：【Java后端面試官】回復(fù)關(guān)鍵詞 Spring Cloud 進(jìn)階 獲忍崮瘛！
- 《Spring Boot 進(jìn)階》PDF：關(guān)注公眾號(hào)：【Java后端面試官】回復(fù)關(guān)鍵詞 Spring Boot進(jìn)階 獲冉鍪纭称勋！
- 《Mybatis 進(jìn)階》PDF：關(guān)注公眾號(hào)：【Java后端面試官】回復(fù)關(guān)鍵詞 Mybatis 進(jìn)階 獲取涯竟！
如果這篇文章對(duì)你有所幫助汰聋，或者有所啟發(fā)的話丹弱，幫忙點(diǎn)贊泉蝌、在看、轉(zhuǎn)發(fā)蝇庭、收藏，你的支持就是我堅(jiān)持下去的最大動(dòng)力捡硅！
本文由mdnice多平臺(tái)發(fā)布
