仲裁队列通过 Raft 协议，实现了不同节点间队列消息数据的复制，使得在 创建这个队列的节点 宕机时，其他节点仍然可以使用该队列进行服务.

说明：鉴于仲裁队列的功能，肯定是需要在前面集群的基础上操作！

1、创建交换机

和仲裁队列绑定的交换机没有特殊，我们还是创建一个direct交换机即可

交换机名称：exchange.quorum.test

image-20231206164511238

2、创建仲裁队列

队列名称：queue.quorum.test

image-20231206164838398

image-20231206165113573

3、绑定交换机

路由键：routing.key.quorum.test

image-20231206164951831

二、测试仲裁队列

1、常规测试

像使用经典队列一样发送消息、消费消息

①生产者端

public static final String EXCHANGE_QUORUM_TEST = "exchange.quorum.test";
public static final String ROUTING_KEY_QUORUM_TEST = "routing.key.quorum.test";

@Test
public void testSendMessageToQuorum() {
    rabbitTemplate.convertAndSend(EXCHANGE_QUORUM_TEST, ROUTING_KEY_QUORUM_TEST, "message test quorum ~~~");
}

image-20231206170401658

②消费者端

public static final String QUEUE_QUORUM_TEST = "queue.quorum.test";

@RabbitListener(queues = {QUEUE_QUORUM_TEST})
public void quorumMessageProcess(String data, Message message, Channel channel) throws IOException {
    log.info("消费端：" + data);
    channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
}

image-20231206170424609

2、高可用测试

①停止某个节点的rabbit应用

# 停止rabbit应用
rabbitmqctl stop_app

②查看仲裁队列对应的节点情况

image-20231206170906222

③再次发送消息

收发消息仍然正常