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

标签:Spring,@EventListener,异步,condition
0
投稿

猜你喜欢

  • C语言深入浅出解析二叉树

    2022-05-12 11:28:21
  • java虚拟机学习笔记进阶篇

    2022-01-07 04:53:06
  • Android实现多媒体录音笔

    2022-03-26 17:25:00
  • C# SynchronizationContext以及Send和Post使用解读

    2023-10-16 04:27:28
  • jpa实现多对多的属性时查询的两种方法

    2022-01-14 00:47:45
  • Java中Function的使用及说明

    2023-08-12 03:04:29
  • Android设备间实现蓝牙(Bluetooth)共享上网

    2023-02-21 14:25:36
  • 关于springboot 配置文件中属性变量引用方式@@解析

    2023-12-08 21:50:03
  • SpringBoot实现启动项目后立即执行的方法总结

    2022-07-31 15:01:16
  • Java实现浏览器端大文件分片上传

    2021-09-17 09:20:26
  • Java利用openoffice将doc、docx转为pdf实例代码

    2023-08-07 23:44:34
  • 基于javassist进行动态编程过程解析

    2021-12-03 07:23:19
  • SpringBoot获取yml和properties配置文件的内容

    2022-12-02 18:26:08
  • Java提示缺少返回语句的解决办法

    2021-08-04 19:42:03
  • Spring拦截器HandlerInterceptor接口代码解析

    2022-09-05 10:51:04
  • Android编程实现的首页左右滑动切换功能示例

    2022-10-15 07:20:17
  • json格式数据分析工具PageElement类分享(仿Session写法)

    2023-09-16 16:04:32
  • Java 生产者/消费者问题实例详解

    2023-02-26 01:23:36
  • java多线程中执行多个程序的实例分析

    2023-03-11 18:21:58
  • Java多线程下的其他组件之CyclicBarrier、Callable、Future和FutureTask详解

    2023-01-31 14:08:39
  • asp之家 软件编程 m.aspxhome.com