Spring @EventListener 异步中使用condition的问题及处理
作者:蒙蒙大川 发布时间:2023-07-07 21:42:16
@EventListener 异步中使用condition的问题
@EventListener是spring在4.2+推出的更好的使用spring事件架构的方式,并且异步方式也很好设定
但是在spring4.2.7版本上使用eventlistener的condition 的使用需要注意以下情况可能失效:
condition 使用例子如
@EventListener(condition = "#event.isAsync")
1. 需要对同一个事件进行区分同步异步
2. 使用condition来进行过滤
例如:
需要对事件用condition进行区分同步异步
@Async
@EventListener(condition = "#event.isAsync")
public void handleOrderCreatedEventAsync(TestEvent event) {
}
@EventListener(condition = "#event.isAsync == false")
public void handleOrderCreatedEvent(TestEvent event) {
}
修正的做法,是使用两个事件区分即
@Async
@EventListener
public void handleOrderCreatedEventAsync(TestEventAsync event) {
}
@EventListener
public void handleOrderCreatedEvent(TestEvent event) {
}
还不清楚,在更高的版本上是否已经有进一步的修正,待以后研究
Spring事件的condition使用说明
在开发中使用了spring的事件机制,但是发现了一个问题:如果多个发布的事件对象是同一个类型,而除了使用了这个事件类型作为参数的事件处理方法还是多个,那就无法区分到底要执行哪个处理方法了,除非你想每个处理方法都执行。
如下是我的事件处理代码声明
@Async
@EventListener
public void handleExport(ExportExcelMessage<DTO> exportMsg){
}
这里的业务场景是异步导出Excel。直接用@EventListener来声明事件处理方法。
在controller中我如此调用
publisher.publish(new ExportExcelMessage<>(reqDTO));
ExportExcelMessage是个事件对象,包含事件基本属性,reqDTO就是查询条件数据了。
开始感觉没有问题。后来突然有一个相同类型入参(reqDTO)的导出功能。
这样处理方法就有问题了。出现处理方法的重复执行。
随便上网一查,简单,EventListener直接加condition属性就搞定。网上是这样的;
@EventListener(condition="#exportMsg.source=='xxx'")
其中这个source就是ExportExcelMessage类的的一个属性,用来区分到底是谁发起的事件。
使用SPel表达式,直接引用的方法的参数名,单我试验是不行的,异常显示exportMsg应该是个null。
估计应该能在方法参数上加注解来处理吧,就像Contrller的@WebParam一样,但我一时也没找到。
最后,直接看人家的代码注释,。。。。自己笨的可以了。
如下就解决了
@EventListener(condition = "#root.args[0].source == 'xxx'")
root.args就是参数的数组,直接用下标取就好了。
来源:https://www.cnblogs.com/zuochanzi/p/9572310.html


猜你喜欢
- 统计输入的行数标准库保证输入文本流以行序列的形式出现,每一行均以换行符结束。因此,统计行数等价于统计换行符的个数。#include <
- The error simply says, “you've made changes in files in your works
- 在application.xml加上以下配置mybatis-plus.configuration.map-underscore-to-cam
- Form1主窗体:public delegate void SetVisiableHandler();//定义委托类型private voi
- 前言在JDK当中给我们提供的各种并发工具当中,比如ReentrantLock等等工具的内部实现,经常会使用到一个工具,这个工具就是LockS
- 在winform程序中给form添加了keyup事件,但是程序却不响应键盘事件,解决办法是重写Form基类的ProcessCmdKey(re
- 先给大家介绍下Java获取上月份最后一天日期8位。代码如下所示:/** * 获取上个月的最后一天23点59分59
- 本文实例讲述了Android开发Wifi的基础知识。分享给大家供大家参考。具体如下:Android提供了WifiManager这个类,通过这
- SpringMVC RESTFul访问首页实现一、新建 index.html在 webapp\WEB-INF\templates 下新建首页
- StopWatch是位于org.springframework.util包下的一个工具类,通过它可方便的对程序部分代码进行计时(ms级别),
- 什么是进程?当一个程序被打开运行时,它就是一个进程。在进程中包括线程,进程可以由一个或多个线程组成。什么是线程?线程是程序执行流的最小单元。
- android root权限破解分析许多机友新购来的Android机器没有破解过Root权限,无法使用一些需要高权限的软件,以及进行一些高权
- spring security中遇到的问题1.An Authentication object was not found in the S
- 1. 简介直到4g时代,流量依然是宝贵的东西。而移动网络传输中,最占流量的一种载体:图片,成为了我们移动开发者不得不关注的一个问题。我们关注
- Bean Searcher 号称 任何复杂的查询都可以 一行代码搞定,但 Mybatis Plus 似乎也有类似的动态查询功能,它们有怎样的
- Android 如何修改APK的默认名称用Android Studio 打包App时生成的名称默认是 app-release.apk(已签名
- 前言本文基于 RxJava 和 Retrofit 库,设计并实现了一种用于大文件分块上传的工具,并对其进行了全面的拆解分析。抛砖引玉,对同样
- 1. Mybatis的@param注解自定义对象也用@param注解注:使用@param注解,mapper.xml 不加parameterT
- 1.拉取centos镜像docker pull centos:72.基于拉取到的镜像运行一个容器docker run -it --name
- 如何接收Post请求Body里的参数ApiPost测试数据{ "list": [