rabbitmq 仲裁队列
发布时间：
更新时间：
🕒 阅读时间：2 min read
👀 阅读量：Loading...
一、创建仲裁队列
仲裁队列通过 Raft 协议，实现了不同节点间队列消息数据的复制，使得在 创建这个队列的节点 宕机时，其他节点仍然可以使用该队列进行服务.
说明：鉴于仲裁队列的功能，肯定是需要在前面集群的基础上操作！
1、创建交换机
和仲裁队列绑定的交换机没有特殊，我们还是创建一个direct交换机即可
交换机名称：exchange.quorum.test
2、创建仲裁队列
队列名称：queue.quorum.test
3、绑定交换机
路由键：routing.key.quorum.test
二、测试仲裁队列
1、常规测试
像使用经典队列一样发送消息、消费消息
①生产者端
public static final String EXCHANGE_QUORUM_TEST = "exchange.quorum.test";public static final String ROUTING_KEY_QUORUM_TEST = "routing.key.quorum.test";
@Testpublic void testSendMessageToQuorum() { rabbitTemplate.convertAndSend(EXCHANGE_QUORUM_TEST, ROUTING_KEY_QUORUM_TEST, "message test quorum ~~~");}
②消费者端
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应用
# 停止rabbit应用rabbitmqctl stop_app②查看仲裁队列对应的节点情况
③再次发送消息
收发消息仍然正常
留言评论