配置RabbitMQ仲裁队列

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

仲裁队列是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：限制仲裁队列的内存中的最大总消息大小（字节数）。