问题描述
我正在使用一个Spring项目,其中有一个JMS事件侦听器实现,用于处理来自队列的消息。
确切地说,我正在使用SQS(AWS)队列。
一切正常。
我的意思是: 我没有为并发配置任何东西,但我希望有更多线程作为侦听器,以提高有关从队列处理消息的性能(速度)。
我正在考虑是否可以配置ThreadPool(TaskExecutor),并在有关消息处理的方法上添加@Async注释。
因此,我将在侦听器中使用onMessage方法,在此方法中,在验证消息后,我将调用此异步方法。
我正在网上寻找它,发现可以直接在侦听器上配置并发值。
我很困惑,有很多可能的方法可以做到这一点,我无法理解最佳方法。
这些等效的解决方案吗?
解决方法
请勿使用@Async
-仅增加侦听器容器的并发性,spring-jms会自动为您处理它。