异步 @RabbitListener
返回类型
@RabbitListener
(和 @RabbitHandler
)方法可以指定异步返回类型 CompletableFuture<?>
和 Mono<?>
,从而允许异步发送回复。
ListenableFuture<?>
不再受支持;它已被 Spring Framework 弃用。
监听器容器工厂必须配置 AcknowledgeMode.MANUAL
,以便消费者线程不会确认消息;相反,异步完成将在异步操作完成时确认或拒绝消息。
当异步结果因错误而完成时,消息是否重新入队取决于抛出的异常类型、容器配置和容器错误处理器。
默认情况下,消息将被重新入队,除非容器的 defaultRequeueRejected
属性设置为 false
(默认为 true
)。
如果异步结果因 AmqpRejectAndDontRequeueException
而完成,则消息不会重新入队。
如果容器的 defaultRequeueRejected
属性为 false
,您可以通过将未来的异常设置为 ImmediateRequeueException
来覆盖此设置,并且消息将重新入队。
如果在监听器方法中发生阻止创建异步结果对象的异常,您必须捕获该异常并返回适当的返回对象,这将导致消息被确认或重新入队。
从 2.2.21、2.3.13、2.4.1 版本开始,当检测到异步返回类型时,AcknowledgeMode
将自动设置为 MANUAL
。
此外,带有致命异常的传入消息将单独进行否定确认,而之前任何未确认的消息也都会被否定确认。
从 3.0.5 版本开始,@RabbitListener
(和 @RabbitHandler
)方法可以标记为 Kotlin suspend
,并且整个处理过程和回复生成(可选)发生在相应的 Kotlin 协程上。
所有提到的关于 AcknowledgeMode.MANUAL
的规则仍然适用。
类路径中必须存在 org.jetbrains.kotlinx:kotlinx-coroutines-reactor
依赖项才能允许 suspend
函数调用。
同样从 3.0.5 版本开始,如果为具有异步返回类型(包括 Kotlin suspend 函数)的监听器配置了 RabbitListenerErrorHandler
,则在失败后会调用错误处理器。
有关此错误处理器及其用途的更多信息,请参阅 处理异常。