最近在项目中引入了一个事务提交后的监听器,现对这些功能做一个阶段性的总结:
什么是监听器?
- 就是用来监听程序执行的。监听器可以做什么事？可以监听程序执行，使程序在不同的阶段做不同的事情，并且与程序主业务逻辑解耦.
- web监听器就是Servlet中特殊的类，他们能帮助开发者监听web中的特定事件，比如ServletContext、HttpSession、ServletRequest的创建和销毁；变量的创建、销毁和修改等。可以在某些动作前后增加处理，实现监控等等。Spring 监听器包含一下模块：
发布器（ApplicationEventPublisher）：用来在业务逻辑中发布事件。广播器（ApplicationEventMulticaster）：用来把发布的事件广播给支持当前事件的监听器。监听器（ApplicationListener）：用来监听自己感兴趣的事件，当程序发布事件时，可以执行一些相应的业务逻辑。ApplicationListener定义了onApplicationEvent方法，监听器监听到事件发布后执行onApplicationEvent方法。事件（ApplicationEvent）：用来定义事件。Spring的监听器执行步骤：
小知识：Spring boot项目启动时会扫描项目中的监听器并加载到广播器中，所以广播器广播的时候能获取到所有的监听器。 Spring boot识别项目中的监听器规则是：@EventListener注解标注的方法，ApplicationListener接口的实现类。
代码语言：javascript复制程序在执行时调用SpringBoot的发布器（ApplicationEventPublisher）发布事件（ApplicationEvent）发布器（ApplicationEventPublisher）调用广播器（ApplicationEventMulticaster）把事件广播给支持当前事件的监听器（ApplicationListener）。通俗的话描述，就是广播器根据发布的事件，从所有的监听器中筛选出支持当前事件的监听器。执行监听器。Spring boot的监听器必须实现ApplicationListener接口并重写onApplicationEvent(Eevent)方法。执行监听器就是广播器筛选出符合条件的监听器后执行onApplicationEvent方法。对于网上查询的一些监听器的应用,很多都是根据上下文初始化一些数据,做一些统计等,而针对于监听事务提交后触发事件这一个,springboot提供了一个@TransactionalEventListener
具体的实现如下:
- 需要我们创建3个类,对应的分别是 事件, 监听器, 发布器,
//发布器中实现ApplicationEventPublisherAware接口,同时初始化ApplicationEventPublisher
@Slf4j
@Component
public class cachePublisher implements ApplicationEventPublisherAware {
//spring boot的事件发布器
private ApplicationEventPublisher applicationEventPublisher;
@Override
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
this.applicationEventPublisher = applicationEventPublisher;
}
/**
* Desc: 发布事件，根据发布缓存事件的参数类型先构造对应的Event对象再发布事件 <br>
* date: 2022/9/3
* @param event
* @return void
*/
public void publishEvent(Object event){
applicationEventPublisher.publishEvent(new RefreshCacheEvent(this,(RefreshCache)event));
}
}- 事件继承ApplicationEvent 声明事件的类型,同时监听器中通过入参的类型确定是哪一种事件监听
public class RefreshCacheEvent extends ApplicationEvent {
private final RefreshCache refreshCache;
public RefreshCache getRefreshCache() {
return refreshCache;
}
public RefreshEvent(Object source, RefreshCache refreshCache) {
super(source);
Assert.notNull(refreshCache, "refreshCache must not be null");
this.refreshCache = refreshCache;
}
}- 监听器采用注解方式实现,@TransactionalEventListener 中间制定了监听器生效的时间,事件的类型,发生异常后如何处理
@Slf4j
@Component
@ConditionalOnBean(name={"refreshCacheService"})
public class RefreshCacheListener {
@Resource
private RefreshCacheService refreshCacheService;
/***
* Desc: 门户缓存刷新事件 <br>
* @TransactionalEventListener 注解表示此监听器是一个事务监听器，在事件发布方事务的对应阶段执行此监听器事件。
* phase 表示事务的阶段
* classes 表示监听的事件类型
* fallbackExecution 没有事务运行是否处理此事件，默认false
*/
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT,
classes = {RefreshCacheEvent.class},
fallbackExecution = true)
public void onApplicationEvent(RefreshCacheEvent event){
//发送刷新缓存的消息
refreshCacheService.sendMessage(event.getRefreshCache().getType());
}
}使用的地方注入 RefreshPublisher
代码语言：javascript复制refreshCachePublisher.publishEvent(refreshSingleJournalCache);
