|
此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 spring-cloud-stream 4.3.0！ |
使用 RabbitMQ Binder 重试
在绑定程序中启用重试时，侦听器容器线程将在配置的任何回退期内挂起。 当需要对单个使用者进行严格排序时，这可能很重要。但是，对于其他用例，它会阻止在该线程上处理其他消息。 使用活页夹重试的替代方法是设置死信，并在死信队列 （DLQ） 上设置生存时间，以及在 DLQ 本身上设置死信配置。 有关此处讨论的属性的更多信息，请参阅“RabbitMQ Binder 属性”。 您可以使用以下示例配置来启用此功能：
-
设置
autoBindDlq自true. 活页夹创建 DLQ。 或者，您可以在deadLetterQueueName. -
设置
dlqTtl到您要在重新投放之间等待的回退时间。 -
将
dlqDeadLetterExchange到默认交易所。 来自 DLQ 的过期消息将路由到原始队列，因为默认的deadLetterRoutingKey是队列名称 （destination.group). 设置为默认交换是通过设置没有值的属性来实现的，如下一个示例所示。
要强制消息为死信，请抛出AmqpRejectAndDontRequeueException或将requeueRejected自false（默认值）并抛出任何异常。
循环无休止地继续下去，这对于暂时性问题来说很好，但您可能想在尝试几次后放弃。
幸运的是，RabbitMQ 提供了x-death标头，可让您确定发生了多少个周期。
要在放弃后确认消息，请抛出一个ImmediateAcknowledgeAmqpException.