仲裁队列

使用场景

仲裁队列（Quorum Queues）提供队列复制的能力，保障数据的高可用和安全性。使用仲裁队列可以在RabbitMQ节点间进行队列数据的复制，在一个节点宕机时，队列依旧可以正常运行。

仲裁队列适用于队列长时间存在，对队列容错和数据安全要求高，对延迟和队列特性要求相对低的场景。在可能出现消息大量堆积的场景，不推荐使用仲裁队列，因为仲裁队列的写入放大会造成成倍的磁盘占用。

仲裁队列的消息会优先保存在内存中，使用仲裁队列时，建议定义队列最大长度和最大内存占用，在消息堆积超过阈值时从内存转移到磁盘，以免造成内存高水位。

更多关于仲裁队列的说明，请参考Quorum Queues。

分布式消息服务RabbitMQ版3.8.35版本才提供仲裁队列特性。

仲裁队列与镜像队列的差异

仲裁队列是RabbitMQ 3.8版本引入的队列类型，它与镜像队列拥有类似的功能，为RabbitMQ提供高可用的队列。镜像队列有一些设计上的缺陷，这也是RabbitMQ提供仲裁队列的原因。

镜像队列主要的缺陷在于消息同步的性能低。

• 镜像队列包含一个主队列和多个从队列，当生产者向主队列发送一条消息，主队列会将消息同步给从队列，所有的从队列都保存消息后，主队列才会向生产者发送确认。
• RabbitMQ使用集群部署时，如果其中一个节点故障下线，待它消除故障重新上线后，它保存的所有从队列的数据都会丢失。此时运维人员需要选择是否同步主队列的数据到从队列中，如果不同步数据，会增加消息丢失的风险。如果同步数据，同步时队列是阻塞的，无法对其进行操作。当队列中存在大量堆积消息时，同步会导致队列几分钟、几小时或者更长时间不可用。

配置方法

在声明队列时，将队列的“x-queue-type”参数设置为“quorum”。此参数只能在声明队列时设置，不能通过Policy设置。

仲裁队列默认的复制因子是5。

• 以下示例演示在Java客户端设置仲裁队列。

  ConnectionFactory factory = newConnectionFactory();
  factory.setRequestedHeartbeat(30);
  factory.setHost(HOST);
  factory.setPort(PORT);
  factory.setUsername(USERNAME);
  factory.setPassword(PASSWORD);
  
  finalConnection connection = factory.newConnection();
  finalChannel channel = connection.createChannel();
  // 创建队列参数Map
  Map<String, Object> arguments = newHashMap<>();
  arguments.put("x-queue-type", "quorum");
  // 声明仲裁队列
  channel.queueDeclare("test-quorum-queue", true, false, false, arguments);

• 以下示例演示在RabbitMQ WebUI页面设置仲裁队列。
  图1 设置仲裁队列
  

  设置完成后，在“Queues”页面查看队列类型是否为“quorum”，如图2所示。“Node”中的“+2”表示该队列有2个副本，蓝色表示这两个副本消息同步已经完成，如果为红色则表示部分消息还未同步。

  图2 查看队列类型
  

  在“Queues”页面，单击队列名称，进入队列详情页。查看当前仲裁队列主副本所在节点和在线副本所在节点。

  图3 队列详情页
  

设置仲裁队列的长度

通过配置Policy或者队列属性的方式可以限制仲裁队列的长度和在内存中保存的长度。

• x-max-length：仲裁队列最大消息数。如果超过则丢弃消息，或者发送到死信交换器。
• x-max-length-bytes：仲裁队列最大总消息大小（字节数）。如果超过则丢弃消息，或者发送到死信交换器。
• x-max-in-memory-length：限制仲裁队列的内存中最大消息数量。
• x-max-in-memory-bytes：限制仲裁队列的内存中的最大总消息大小（字节数）。