Spring @EventListener 异步中使用condition的问题及处理
@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就是参数的数组,直接用下标取就好了。
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。
相关文章
Spring Boot与RabbitMQ结合实现延迟队列的示例
本篇文章主要介绍了Spring Boot与RabbitMQ结合实现延迟队列的示例,具有一定的参考价值,感兴趣的小伙伴们可以参考一下2017-11-11
Spring Boot 实现Restful webservice服务端示例代码
这篇文章主要介绍了Spring Boot 实现Restful webservice服务端示例代码,非常不错,具有参考借鉴价值,需要的朋友可以参考下2017-11-11
RocketMQ ConsumeQueue与IndexFile实时更新机制源码解析
这篇文章主要为大家介绍了RocketMQ ConsumeQueue与IndexFile实时更新机制源码解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-05-05


最新评论