前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >下单流程解耦新方案-你知道Spring事件监听机制吗

下单流程解耦新方案-你知道Spring事件监听机制吗

原创
作者头像
wayn
发布2022-04-17 01:11:29
2660
发布2022-04-17 01:11:29
举报
文章被收录于专栏:wayn的程序开发

一、Spring 事件监听介绍

Spring 对事件监听是通过事件类型、事件类型监听和事件发布器 3 个部分来完成的

代码语言:java
复制
// 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 个方面入手: 1. 从事件监听器:将事件监听器的事件触发方法改为异步执行,例如加入将生成订单、删除购物车、扣减库存逻辑放入线程池,或者是在onApplicationEvent放上上加上@Async注解,表示该方法异步执行。 2. 通过修改默认事件监听发布类的taskExecutor属性,这样可以使用已有的件监听发布类来优化相关逻辑

代码语言:java
复制
/**
 * 系统启动时執行
 */
@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类支持异步事件通知

三、事件监听机制的代码思考

通过事件监听机制,我们将下单逻辑拆分成如下步骤: 1. 订单检查

生成订单号

发布订单事件,在事件监听中处理订单保存逻辑

所有操作成功后,将订单号返回

每个步骤都是各自独立不互相影响,后期引入消息队列,对代码的改动也是很少,只需将事件发布和事件监听的代码换成消息队列的消息发送和消息监听即可。

最后贴一下实战项目地址newbeemall

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 一、Spring 事件监听介绍
  • 二、使用异步的事件监听发布类
  • 三、事件监听机制的代码思考
相关产品与服务
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档