2024-05-09    2024-05-25    368 字  1 分钟

一、创建仲裁队列

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

1、创建交换机

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

交换机名称:exchange.quorum.test

image-20231206164511238

2、创建仲裁队列

队列名称:queue.quorum.test

image-20231206164838398

image-20231206165113573

3、绑定交换机

路由键:routing.key.quorum.test

image-20231206164951831

二、测试仲裁队列

1、常规测试

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

①生产者端

1
2
3
4
5
6
7
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

②消费者端

1
2
3
4
5
6
7
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应用

1
2
# 停止rabbit应用
rabbitmqctl stop_app

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

image-20231206170906222

③再次发送消息

收发消息仍然正常