一、Spring事件監聽介紹
Spring對事件監聽是通過事件型別、事件型別監聽和事件發布器3個部分來完成的
// 1. 自定義訂單事件
public class OrderEvent extends ApplicationEvent {
...
}
// 2. 定義訂單監聽器
@Component
public class OrderListener implements ApplicationListener<OrderEvent> {
@Override
public void onApplicationEvent(OrderEvent event) {
// 生成訂單、洗掉購物車、扣減庫存
```
}
}
// 3. 通過applicationEventPublisher發布事件
@Resource
private ApplicationEventPublisher applicationEventPublisher;
private void saveOrder(MallUserVO mallUserVO, Long couponUserId, List<ShopCatVO> shopcatVOList, String orderNo) {
// 訂單檢查
```
// 生成訂單號
String orderNo = NumberUtil.genOrderNo();
// 發布訂單事件，在事件監聽中處理下單邏輯
applicationEventPublisher.publishEvent(new OrderEvent(orderNo, mallUserVO, couponUserId, shopcatVOList));
// 所有操作成功后，將訂單號回傳
return orderNo;
```
}
上面的代碼已經是將訂單的保存邏輯從下單介面解耦到訂單監聽器中了，但是Spring使用默認自帶的SimpleApplicationEventMulticaster事件監聽發布類是同步通知事件監聽器的，這里會阻塞下單主執行緒，影響介面回應時長，
二、使用異步的事件監聽發布類
由于默認的
SimpleApplicationEventMulticaster類是同步呼叫，這里可以從2個方面入手：
- 從事件監聽器：將事件監聽器的事件觸發方法改為異步執行，例如加入將生成訂單、洗掉購物車、扣減庫存邏輯放入執行緒池，或者是在
onApplicationEvent放上上加上@Async注解，表示該方法異步執行，- 通過修改默認事件監聽發布類的
taskExecutor屬性，這樣可以使用已有的件監聽發布類來優化相關邏輯
/**
* 系統啟動時執行
*/
@Component
public class SpringBeanStartupRunner implements ApplicationRunner {
@Override
public void run(ApplicationArguments args) throws Exception {
// 設定spring默認的事件監聽為異步執行
SimpleApplicationEventMulticaster multicaster = SpringContextUtil.getBean(SimpleApplicationEventMulticaster.class);
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
5,
10,
60L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<>(500),
new CustomizableThreadFactory("newbee—event-task"),
new ThreadPoolExecutor.CallerRunsPolicy()
);
multicaster.setTaskExecutor(threadPoolExecutor);
}
}
在系統啟動時反射修改
SimpleApplicationEventMulticaster類的taskExecutor屬性，從而讓SimpleApplicationEventMulticaster類支持異步事件通知
三、事件監聽機制的代碼思考
通過事件監聽機制，我們將下單邏輯拆分成如下步驟：
- 訂單檢查
- 生成訂單號
- 發布訂單事件，在事件監聽中處理訂單保存邏輯
- 所有操作成功后，將訂單號回傳
每個步驟都是各自獨立不互相影響，后期引入訊息佇列，對代碼的改動也是很少，只需將事件發布和事件監聽的代碼換成訊息佇列的訊息發送和訊息監聽即可，
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/458379.html
標籤：其他
上一篇：Apache Flink系列-①什么是Apache Flink？
下一篇：GO環境配置