RabbitMQ 绑定器参考指南

本指南介绍了 Spring Cloud Stream 绑定器的 RabbitMQ 实现。它包含有关其设计、使用和配置选项的信息，以及有关 Stream Cloud Stream 概念如何映射到 RabbitMQ 特定构造的信息。

使用

要使用 RabbitMQ 绑定器，您可以将其添加到您的 Spring Cloud Stream 应用程序中，方法是使用以下 Maven 坐标

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>

或者，您可以使用 Spring Cloud Stream RabbitMQ 启动器，如下所示

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>

RabbitMQ 绑定器概述

以下简化图显示了 RabbitMQ 绑定器的工作方式

默认情况下，RabbitMQ 绑定器实现将每个目标映射到一个 TopicExchange。对于每个消费者组，一个 Queue 被绑定到该 TopicExchange。每个消费者实例都有一个与其组的 Queue 对应的 RabbitMQ Consumer 实例。对于分区生产者和消费者，队列以分区索引为后缀，并使用分区索引作为路由键。对于匿名消费者（没有 group 属性的消费者），使用一个自动删除队列（具有随机的唯一名称）。

通过使用可选的 autoBindDlq 选项，您可以配置绑定器以创建和配置死信队列 (DLQ)（以及死信交换 DLX，以及路由基础设施）。默认情况下，死信队列的名称为目标名称，后缀为 .dlq。如果启用了重试（maxAttempts > 1），则在重试耗尽后，失败的消息将被传递到 DLQ。如果禁用了重试（maxAttempts = 1），则应将 requeueRejected 设置为 false（默认值），以便将失败的消息路由到 DLQ，而不是重新排队。此外，republishToDlq 使绑定器将失败的消息发布到 DLQ（而不是拒绝它）。此功能允许在消息头中添加其他信息（例如 x-exception-stacktrace 头中的堆栈跟踪）。有关截断堆栈跟踪的信息，请参阅 frameMaxHeadroom 属性。此选项不需要启用重试。您可以在只尝试一次后重新发布失败的消息。从 1.2 版本开始，您可以配置重新发布消息的传递模式。请参阅 republishDeliveryMode 属性。

如果流监听器抛出 ImmediateAcknowledgeAmqpException，则会绕过 DLQ，消息将被简单地丢弃。从 2.1 版本开始，无论 republishToDlq 的设置如何，这都是正确的；以前只有在 republishToDlq 为 false 时才如此。

将 requeueRejected 设置为 true（republishToDlq=false）会导致消息被重新排队并不断重新传递，这可能不是您想要的，除非失败的原因是暂时的。通常，您应该通过将 maxAttempts 设置为大于 1 或将 republishToDlq 设置为 true 来在绑定器中启用重试。

从 3.1.2 版本开始，如果消费者被标记为 transacted，发布到 DLQ 将参与事务。这允许事务在发布失败时回滚（例如，如果用户无权发布到死信交换）。此外，如果连接工厂配置了发布者确认或返回，发布到 DLQ 将等待确认并检查返回的消息。如果收到否定确认或返回消息，绑定器将抛出 AmqpRejectAndDontRequeueException，允许代理处理发布到 DLQ，就像 republishToDlq 属性为 false 一样。

有关这些属性的更多信息，请参见 RabbitMQ 绑定器属性。

框架没有提供任何标准机制来消费死信消息（或将它们重新路由回主队列）。一些选项在 死信队列处理 中描述。

当在 Spring Cloud Stream 应用程序中使用多个 RabbitMQ 绑定器时，重要的是禁用 'RabbitAutoConfiguration' 以避免 RabbitAutoConfiguration 中的相同配置应用于两个绑定器。您可以使用 @SpringBootApplication 注解排除该类。

从 2.0 版本开始，RabbitMessageChannelBinder 将 RabbitTemplate.userPublisherConnection 属性设置为 true，以便非事务性生产者避免消费者死锁，这可能会在缓存的连接由于代理上的 内存警报 而被阻塞时发生。

目前，multiplex 消费者（一个监听多个队列的单个消费者）仅支持消息驱动的消费者；轮询消费者只能从单个队列中检索消息。

配置选项

本节包含特定于 RabbitMQ 绑定器和绑定通道的设置。

有关一般绑定配置选项和属性，请参见 Spring Cloud Stream 核心文档。

章节摘要