一、创建仲裁队列
说明：鉴于仲裁队列的功能，肯定是需要在前面集群的基础上操作！
1、创建交换机
和仲裁队列绑定的交换机没有特殊，我们还是创建一个direct交换机即可
交换机名称：exchange.quorum.test
2、创建仲裁队列
队列名称：queue.quorum.test
3、绑定交换机
路由键：routing.key.quorum.test
二、测试仲裁队列
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 ~~~");
}
|
②消费者端
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);
}
|
2、高可用测试
①停止某个节点的rabbit应用
1
2
| # 停止rabbit应用
rabbitmqctl stop_app
|
②查看仲裁队列对应的节点情况
③再次发送消息
收发消息仍然正常
