SpringBoot中使用SpringEvent业务解耦神器实现监听发布事件同步异步执行任务

场景

SpringBoot中使用单例模式+ScheduledExecutorService实现异步多线程任务(若依源码学习)：

SpringBoot中使用单例模式+ScheduledExecutorService实现异步多线程任务(若依源码学习)-CSDN博客

设计模式-观察者模式在Java中的使用示例-环境监测系统：

设计模式-观察者模式在Java中的使用示例-环境监测系统_java observer使用-CSDN博客

开发过程中，业务逻辑可能非常复杂，核心业务 + N个子业务。

如果都放到一块儿去做，代码可能会很长，耦合度不断攀升。

还有一些业务场景不需要在一次请求中同步完成，比如邮件发送、短信发送等。

MQ 可以解决这个问题，但 MQ 重，非必要不提升架构复杂度。

针对这些问题，我们了解一下 Spring Event。

Spring Event（Application Event）其实就是一个观察者设计模式，

一个 Bean 处理完成任务后希望通知其它 Bean 或者说一个 Bean 想观察监听另一个Bean 的行为。

注：

博客：
霸道流氓气质-CSDN博客

实现

1、以下订单时同步校验订单价格和异步发送邮件通知为例

通过使用时间发布订阅的形式进行解耦。

同步校验订单价格实现

首先自定义事件，该事件携带订单id

public class OrderProductEvent {private String orderId;public OrderProductEvent(String orderId){this.orderId = orderId;}public String getOrderId() {return orderId;}public void setOrderId(String orderId) {this.orderId = orderId;}
}

2、定义监听器

使用@EventListener注解监听并处理事件

import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.util.concurrent.TimeUnit;@Component
public class OrderProductListener {@EventListener(OrderProductEvent.class)public void checkPrice(OrderProductEvent event){String orderId = event.getOrderId();System.out.println("校验订单价格开始:"+ LocalDateTime.now());try {TimeUnit.SECONDS.sleep(2);System.out.println("校验订单:"+orderId+"价格完成"+LocalDateTime.now());} catch (InterruptedException e) {e.printStackTrace();}}
}

3、定义发布者

通过applicationEventPublisher.publishEvent发布事件

首先新建订单Service接口

public interface OrderService {String buyOrder(String orderId);
}

接口实现

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;@Service
public class OrderServiceImpl implements OrderService{@Autowiredprivate ApplicationEventPublisher applicationEventPublisher;@Overridepublic String buyOrder(String orderId) {//其它业务省略//校验订单价格-同步进行applicationEventPublisher.publishEvent(new OrderProductEvent(orderId));return "下单成功";}
}

4、编写单元测试

import lombok.SneakyThrows;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import java.time.LocalDateTime;
import java.util.concurrent.TimeUnit;@RunWith(SpringRunner.class)
@SpringBootTest(classes = RuoYiApplication.class,webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class SpringEventTest {@Autowiredprivate OrderService orderService;@Test@SneakyThrowspublic void getDictLable() {System.out.println("下订单开始:"+ LocalDateTime.now());String s = orderService.buyOrder("0001");System.out.println(s);//执行其他业务TimeUnit.SECONDS.sleep(5);System.out.println("下订单结束:"+ LocalDateTime.now());}
}

5、单元测试运行结果

6、Spring Event 异步实现

有些业务场景不需要在一次请求中同步完成，比如邮件发送、短信发送等。

自定义发送邮件事件

import lombok.AllArgsConstructor;@AllArgsConstructor
public class MsgEvent {public String orderId;public String getOrderId() {return orderId;}public void setOrderId(String orderId) {this.orderId = orderId;}
}

7、定义监听器

import lombok.SneakyThrows;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.util.concurrent.TimeUnit;@Component
public class MsgListener {@Async@SneakyThrows@EventListener(MsgEvent.class)public void sendMsg(MsgEvent event){String orderId = event.getOrderId();System.out.println("订单"+orderId+"开始发送邮件"+ LocalDateTime.now());TimeUnit.SECONDS.sleep(2);System.out.println("订单"+orderId+"发送邮件完成"+ LocalDateTime.now());}
}

需要添加@Async注解

并且需要在启动类上添加@EnableAsync注解

@SpringBootApplication(exclude = { DataSourceAutoConfiguration.class })
@EnableAsync
public class RuoYiApplication
{public static void main(String[] args){SpringApplication.run(RuoYiApplication.class, args);
}

8、同样在上面发布者中添加发布事件

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;@Service
public class OrderServiceImpl implements OrderService{@Autowiredprivate ApplicationEventPublisher applicationEventPublisher;@Overridepublic String buyOrder(String orderId) {//其它业务省略//校验订单价格-同步进行applicationEventPublisher.publishEvent(new OrderProductEvent(orderId));//发送邮件-异步进行applicationEventPublisher.publishEvent(new MsgEvent(orderId));return "下单成功";}
}

9、单元测试同上，运行结果