Spring @EventListener 异步中使用condition的问题及处理

 更新时间:2021年12月28日 14:29:09   作者:蒙蒙大川  
这篇文章主要介绍了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就是参数的数组,直接用下标取就好了。

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • SpringBoot实现文件断点续传功能详解

    SpringBoot实现文件断点续传功能详解

    在处理大文件传输或网络不稳定的情况下,文件断点续传功能显得尤为重要,本文将详细介绍如何使用Spring Boot实现文件的断点续传功能,需要的可以了解下
    2025-04-04
  • Spring Boot与RabbitMQ结合实现延迟队列的示例

    Spring Boot与RabbitMQ结合实现延迟队列的示例

    本篇文章主要介绍了Spring Boot与RabbitMQ结合实现延迟队列的示例,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-11-11
  • SpringBoot异步实现 的8种方式

    SpringBoot异步实现 的8种方式

    在同步操作中,执行到 发送短信 的时候,我们必须等待这个方法彻底执行完才能执行 赠送积分 这个操作,如果 赠送积分 这个动作执行时间较长,发送短信需要等待,这就是典型的同步场景,这篇文章主要介绍了SpringBoot异步实现 的8种方式,需要的朋友可以参考下
    2023-11-11
  • Spring Boot 实现Restful webservice服务端示例代码

    Spring Boot 实现Restful webservice服务端示例代码

    这篇文章主要介绍了Spring Boot 实现Restful webservice服务端示例代码,非常不错,具有参考借鉴价值,需要的朋友可以参考下
    2017-11-11
  • java发送邮件示例讲解

    java发送邮件示例讲解

    这篇文章主要为大家详细介绍了java发送邮件示例的全过程,温习邮件协议,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-03-03
  • Java使用Apache POI操作Excel详解

    Java使用Apache POI操作Excel详解

    在Java中操作Excel是日常工作中经常遇到的问题,而Apache Poi是一种流行且广泛使用的方式,它提供了各种库和工具,所以本文就来详细如何使用Apache Poi来进行Excel文件操作吧
    2023-06-06
  • SpringBoot 多线程事务回滚的实现

    SpringBoot 多线程事务回滚的实现

    本文是基于springboot的@Async注解开启多线程,并通过自定义注解和AOP实现的多线程事务,避免繁琐的手动提交/回滚事务,感兴趣的可以了解一下
    2024-02-02
  • Spring boot动态修改日志级别的方法

    Spring boot动态修改日志级别的方法

    我们经常会遇到业务想看debug日志的问题,但是debug日志频繁打印会对日志查看有影响,且日志多对系统也会有一定的压力,因此,如果可以在需要的时候动态临时调整下日志的级别则是比较完美的,spring boot已经支持这种功能,需要的朋友可以参考下
    2022-12-12
  • RocketMQ ConsumeQueue与IndexFile实时更新机制源码解析

    RocketMQ ConsumeQueue与IndexFile实时更新机制源码解析

    这篇文章主要为大家介绍了RocketMQ ConsumeQueue与IndexFile实时更新机制源码解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-05-05
  • Java多线程中Lock的使用小结

    Java多线程中Lock的使用小结

    jdk1.5 以后,提供了各种锁,本文主要介绍了Java多线程中Lock的使用小结,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-04-04

最新评论