Spring Boot 解耦之事件驱动

2021-03-31 本文已影响0人炒酸奶没有酸奶

参考：SpringBoot使用ApplicationEvent&Listener完成业务解耦
参考：Spring Boot 解耦之事件驱动

一、前言

1、1 使用场景

日常开发中，常见的比如用户注册账号操作，当用户注册完毕之后，可能还需要处理以下一些事情：

发送确认邮件
赠送用户积分、成长值
赠送优惠券

问题：

假如以上所有的操作全部都耦合在一个service业务处理代码中，后续操作一直没有完成，那么用户是不是要长时间等待
如果邮件服务器挂了，注册还能成功吗
后期维护起来相关代码也会非常麻烦，甚至会出现一些漏洞等

从上述例子可以看出，当用户注册完毕之后，发布一个命令给第三方的观察者，观察者接收到相关命令之后，就可以来处理之后的相关事件，那么程序就可以解耦各个环节的依赖关系，这就是事件驱动模型，内部实现原理是观察者设计模式。

1、2 事件驱动定义

事件驱动模型也就是我们常说的观察者，或者发布-订阅模型；理解它的几个关键点：

首先是一种对象间的一对多的关系；最简单的如交通信号灯，信号灯是目标（一方），行人注视着信号灯（多方）；
当目标发送改变（发布），观察者（订阅者）就可以接收到改变；
观察者如何处理（如行人如何走，是快走/慢走/不走，目标不会管的），目标无需干涉；所以就松散耦合了它们之间的关系。

spring主要是通过ApplicationEvent以及Listener为我们提供事件监听、订阅等相关事件处理。

二、项目中应用

2、1 搭建springboot项目

略。

2、2 定义事件

/**
 * 自定义订单监听事件，继承了ApplicationEvent，并重载构造函数
 * <p>
 * 构造函数的参数可以任意指定，其中source参数指的是发生事件的对象，而第二个参数是我们自定义的注册事件对象，该对象可以在监听内被获取。
 */
 
@Getter
public class OrderCancelEvent extends ApplicationEvent {

    // 注入订单业务对象
    private OmsOrder omsOrder;

    public OrderCancelEvent(Object source, OmsOrder omsOrder) {
        super(source);
        this.omsOrder = omsOrder;
    }
}

事件是事件驱动的核心，上述OrderCancelEvent就是自定义的一个事件，继承了ApplicationEvent，并重写了其构造函数，第一个参数一般我们在发布事件时使用的是this关键字代替本类对象，而第二个参数则根据具体业务具体定义，主要就是为了使监听器可以监听到相关事件。

2、3 创建事件监听器

事件监听器的创建方式有好多种，eg：@EventListener注解、实现ApplicationListener泛型接口、实现SmartApplicationListener接口等，我们下面来讲解下这三种方式分别如何实现。

@EventListener
使用该注解是最简单的一种方式，只需在方法上加上此注解即可。

/**
 * 用途：消息事件监听器
 * 作者: jingwenhao
 * 时间: 2019/7/26  15:29
 */
@Component
@Slf4j
public class MsgSendListener {

    @Autowired
    private IImsNotificationService notificationService;

    /**
     * 支付成功之后，异步发送消息事件
     *
     * @param event 消息事件
     */
    @EventListener
    @Async
    public void sendMsgAfterPaySucc(MsgOrderPayEvent event) {
        try {
            log.debug("——发送消息事件开始执行——");
            Thread.sleep(3000);// 休息3秒
            // 获取事件实际对象
            Map<String, Object> eventMap = event.getEventMap();
            // 具体的业务逻辑方法
            notificationService.sendMsgAfterPaySucc(eventMap);
            log.debug("——发送消息事件结束——");
        } catch (Exception e) {
             e.printStackTrace();
        }
    }

    /**
     * 超时订单关闭，异步发送消息事件
     *
     * @param event 消息事件
     */
    @EventListener
    @Async
    public void sendMsgAfterAutoCancel(MsgOrderCancelEvent event) {
        try {
            log.debug("——发送消息事件开始执行——");
            Thread.sleep(3000);// 休息3秒
            Map<String, Object> eventMap = event.getEventMap();
            notificationService.sendMsgAfterAutoCancel(eventMap);
            log.debug("——发送消息事件结束——");
        } catch (Exception e) {
             e.printStackTrace();
        }
    }
}

实现ApplicationListener泛型接口

@Component
public class RegisterListener implements ApplicationListener<UserRegisterEvent>
{
    /**
     * 实现监听
     * @param userRegisterEvent
     */
    @Override
    public void onApplicationEvent(UserRegisterEvent userRegisterEvent) {
        //获取注册用户对象
        UserBean user = userRegisterEvent.getUser();

        //../省略逻辑

        //输出注册用户信息
        System.out.println("注册信息，用户名："+user.getName()+"，密码："+user.getPassword());
    }
}

这里直接复制了博客上的写法，这种写法主要是实现了ApplicationListener接口，并将事先定义好的事件作为泛型对象传递了过去，UserRegisterEvent事件发布时监听程序会自动调用onApplicationEvent方法并且将UserRegisterEvent对象作为参数传递。

实现SmartApplicationListener

/**
 * 订单超时自动关闭监听任务
 */
@Component
@Slf4j
public class OrderAutoCloseListener implements SmartApplicationListener {

    @Autowired
    private IOmsOrderService orderService;//注入订单业务接口

    /**
     * 该方法返回true&supportsSourceType同样返回true时，才会调用该监听内的onApplicationEvent方法
     *
     * @param aClass 接收到的监听事件类型
     * @return
     */
    @Override
    public boolean supportsEventType(Class<? extends ApplicationEvent> aClass) {
        //只有OrderEvent监听类型才会执行下面逻辑
        return aClass == OrderCancelEvent.class;
    }

    /**
     * 该方法返回true&supportsEventType同样返回true时，才会调用该监听内的onApplicationEvent方法
     *
     * @param aClass
     * @return
     */
    @Override
    public boolean supportsSourceType(Class<?> aClass) {
        //只有在OmsOrderServiceImpl内发布的UserRegisterEvent事件时才会执行下面逻辑
        return aClass == OmsOrderServiceImpl.class;
    }

    /**
     * supportsEventType & supportsSourceType 两个方法返回true时调用该方法执行业务逻辑
     *
     * @param applicationEvent 具体监听实例，这里是orderEvent
     */
    @Override
    @Async
    public void onApplicationEvent(ApplicationEvent applicationEvent) {
        log.debug("————订单超时关闭事件开始准备，倒计时1分钟");
        ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
        //转换事件类型
        OrderCancelEvent orderCancelEvent = (OrderCancelEvent) applicationEvent;
        //获取订单对象
        OmsOrder order = orderCancelEvent.getOmsOrder();
        Runnable payTimeoutTask = new Runnable() {
            @Override
            public void run() {
                //执行订单超时，系统取消订单操作
                orderService.cancelOrderAutoById(order.getId());
            }
        };
        executor.schedule(payTimeoutTask, 2, TimeUnit.MINUTES);
        try {
            //每分钟检查任务是否完成，完成后关闭任务线程
            executor.awaitTermination(1, TimeUnit.MINUTES); 
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        executor.shutdown();
        log.debug("————订单超时关闭事件执行结束");
    }

    public void SyncAndAsync() throws ExecutionException, InterruptedException {
        AsyncTaskExecutor executor = new SimpleAsyncTaskExecutor();
        System.out.println("First");
        //Future<String> future = executor.submit(new CallableTask("Second")); //同步
        executor.execute(new RunnableTask("go!"));
        //System.out.println(future.get());
        System.out.println("Third");
    }

    class RunnableTask implements Runnable{
        private String parameter;
        public RunnableTask(String parameter) {
            super();
            this.parameter = parameter;
        }
        @Override
        public void run() {
            try {
                Thread.sleep(5 * 1000);
                System.out.println(parameter+ "Second");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    class CallableTask implements Callable<String> {
        private String parameter;
        public CallableTask(String parameter) {
            super();
            this.parameter = parameter;
        }
        @Override
        public String call() throws Exception {
            Thread.sleep(5 * 1000);
            return parameter+ " finished!";
        }
    }

    /**
     * 同步情况下监听执行的顺序
     *
     * @return
     */
    @Override
    public int getOrder() {
        return 0;
    }
}

SmartApplicationListener接口继承了全局监听ApplicationListener，并且泛型对象使用的ApplicationEvent来作为全局监听，可以理解为使用SmartApplicationListener作为监听父接口的实现，监听所有事件发布。
既然是监听所有的事件发布，那么SmartApplicationListener接口添加了两个方法supportsEventType、supportsSourceType来作为区分是否是我们监听的事件，只有这两个方法同时返回true时才会执行onApplicationEvent方法。

可以看到除了上面的方法，还提供了一个getOrder方法，这个方法就可以解决执行监听的顺序问题，return的数值越小证明优先级越高，执行顺序越靠前。

2、4 使用@Async实现异步监听

@Aysnc其实是Spring内的一个组件，可以完成对类内单个或者多个方法实现异步调用，这样可以大大的节省等待耗时。内部实现机制是线程池任务ThreadPoolTaskExecutor，通过线程池来对配置@Async的方法或者类做出执行动作。

2、5 具体业务场景

订单创建时，发布超时未支付自动关闭事件:

@Service
public class OrderService
{
    @Autowired
    private ApplicationContext applicationContext;

    /**
     * 生成订单
     * @param order 订单对象
     */
    public void generateOrder(OmsOrder order)
    {
        //....省略逻辑

        //发布订单超时关闭事件
       applicationContext.publishEvent(new OrderCancelEvent(this, order));
    }
}

成功付款时，发布推送消息事件:

 @Service
public class OrderService
{
    @Autowired
    private ApplicationContext applicationContext;

    /**
     * 支付订单
     * @param order 订单对象
     */
    public void pay(OmsOrder order)
    {
        //....省略逻辑

       // 发送支付成功消息事件
      Map<String, Object> eventMap = Maps.newHashMap();
      eventMap.put("order", order);
      applicationContext.publishEvent(new MsgOrderPayEvent(this, eventMap));
    }
}

2.6 拓展

上述2.5中描述了一个场景：订单创建时，发布超时未支付自动关闭事件，在这里，介绍几种电商项目中如何处理超时未支付自动关闭订单的方案：

第一种：数据库加两个字段, 一个字段标记: 是否付款,一个字段标记：过期时间，查询时去判断是否付款和超时，然后更新状态。但是这种方案导致占用商品资源。
第二种：定时任务一直扫描，扫描到满足条件的就进行更新操作。但是这种方案导致不能准确处理订单状态。
第三种：TODO 依赖于第三方框架，比如框架Quartz、rabbitMQ等，不太懂，就不解释了哈。

我目前是这样处理超时未支付自动关闭：当订单创建完成时，发布超时未支付自动关闭事件，同时系统中还有一个每1分钟执行一次的扫描超时未支付订单的定时任务，两种方案结合目前是可以解决上述问题。采用异步事件和定时任务结合的方案，有以下好处：

更加准确的处理超时未支付订单，及时释放库存
防止系统宕机导致的进程丢失，原有的事件任务无法执行，通过定时任务可以有效解决此问题

三、小结

使用事件驱动模型可以大大降低我们实际项目中的代码耦合，降低了前后端交互的响应耗时，而且还减少了后期业务变更引起的代码调整的难度。具体使用步骤如下：

定义事件
创建事件监听器
业务代码中发布事件