异步 @RabbitListener 返回类型

@RabbitListener（和 @RabbitHandler）方法可以指定异步返回类型 CompletableFuture<?> 和 Mono<?>，让回复异步发送。ListenableFuture<?> 不再受支持；它已被 Spring Framework 弃用。

监听器容器工厂必须配置为 AcknowledgeMode.MANUAL，以便消费者线程不会确认消息；相反，异步完成将在异步操作完成时确认或拒绝消息。当异步结果以错误完成时，消息是否重新排队取决于抛出的异常类型、容器配置和容器错误处理程序。默认情况下，消息将重新排队，除非容器的 defaultRequeueRejected 属性设置为 false（默认情况下为 true）。如果异步结果以 AmqpRejectAndDontRequeueException 完成，则不会重新排队消息。如果容器的 defaultRequeueRejected 属性为 false，则可以通过将 future 的异常设置为 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 挂起函数）的侦听器上配置了 RabbitListenerErrorHandler，则在发生故障后调用错误处理程序。有关此错误处理程序及其用途的更多信息，请参见 处理异常。