Springboot事件监听

Springboot事件监听中主要有以下对象：

1、事件（event）可以封装和传递监听器中要处理的参数，如对象或字符串，并作为监听器中监听的目标。
2、监听器（listener）具体根据事件发生的业务处理模块，这里可以接收处理事件中封装的对象或字符串。
3、事件发布者（publisher）事件发生的触发者

1、事件对象

@Data
public class WorkEvent{


    /**
     * ID
     */
    public Long idNo;
    /**
     * 当前流程状态
     */
    public Integer state;
    /**
     * 申请理由
     */
    public String contents;

}

2、事件

public class WorkApplicationEvent extends ApplicationEvent {
    public WorkApplicationEvent(WorkEvent workEvent) {
        super(workEvent);
    }
}

3、监听器

@Component
public class MsgListener {

    @SneakyThrows // 该注解可以省略代码中一些抛异常或者try catch操作（建议少用，此处写个简单的小demo偷懒）
    @Async // 开启异步监听
    @EventListener(WorkApplicationEvent.class)
    public void sendMsg(WorkApplicationEvent workApplicationEvent) {
        // 具体监听的业务逻辑
        WorkEvent workEvent = (WorkEvent)workApplicationEvent.getSource();
        if (workEvent.getState() == 1) {
            Thread.sleep(1000);
            System.out.println(workEvent.getContents());
        } else {
            throw new RuntimeException("抛出异常，观察后续执行情况");
        }
    }
}

4、事件发布者

@Service
public class TestServiceImpl implements TestService {

    @Autowired
    private ApplicationEventPublisher applicationEventPublisher;

    @Override
    public String testEvent(Integer id) {
        WorkEvent workEvent = new WorkEvent();
        workEvent.setState(id);
        workEvent.setContents("监听事件为：WorkEvent");
        WorkApplicationEvent event = new WorkApplicationEvent(workEvent);
        System.out.println("推送监听事件");
        // 发布事件
        applicationEventPublisher.publishEvent(event); 
        System.out.println("已推送成功");
        return "推送成功";
    }
}

5、Controller

@RestController
public class TestController {

    @Autowired
    private TestService testService;

    @GetMapping("/test/{id}")
    public String getTest(@PathVariable("id") Integer id) {
        return testService.testEvent(id);
    }

}

6、整体项目结构

注意，主启动类上需要添加注解：@EnableAsync开启异步

运行效果

执行：http://localhost:8080/test/1

执行：http://localhost:8080/test/2

不使用异步访问：http://localhost:8080/test/2

接下来想聊聊为什么用异步操作

原因有二：

1、因为Springboot的事件监听默认是会在主线程执行的，如果监听业务出现Exception，则会导致整个流程报错阻塞，无法往下继续执行。就好比我本来是想告诉你我今天买彩票赚了10块钱，告诉你这个消息的目的是为了想你听到我的消息之后采取一些措施，比如让你远离博彩（让你也去买一张）。但是我只负责把消息传递给你，而你收到我的消息后做了什么事情我并不关心，这就是异步。但是比如说你收到我的消息后，你也去买了一张彩票结果发现没中奖，于是你把我中来的十块钱抢走了，这就可以理解为非异步。这种设计可能会违背我们这段代码的逻辑导致业务处理出错。

2、监听耗时问题，如果监听业务处理事件非常久，不采用异步处理会阻塞主业务流程。

但是比如说你收到我的消息后，你也去买了一张彩票结果发现没中奖，于是你把我中来的十块钱抢走了，这就可以理解为非异步。这种设计可能会违背我们这段代码的逻辑导致业务处理出错。

2、监听耗时问题，如果监听业务处理事件非常久，不采用异步处理会阻塞主业务流程。

如果不想用异步操作的话，可以去掉@Async注解和启动类的@EnableAsync就可以了。

文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/147323.html