简介
说明
本文介绍RabbitMQ的Quorum Queue(仲裁队列)的用法。
官网网址
Quorum Queues — RabbitMQ
创建仲裁队列
法1:在控制台创建
在任意控制台添加一个队列,选择队列类型为Quorum类型。

在任意控制台查看队列:
可以看到,仲裁队列的 + 2字样。代表这个队列有2个镜像节点。
因为仲裁队列默认的镜像数为5。如果你的集群有7个节点,那么镜像数肯定是5;而我们集群只有3个节点,因此镜像数量就是3。
法2:使用Java代码创建
仲裁队列本身就是一个普通的队列,集群搭建好了以后,只要创建quorum类型的就行了
@Bean
public Queue quorumQueue() {
return QueueBuilder
.durable("quorum.queue") // 持久化
.quorum() // 仲裁队列
.build();
}
发送与接收消息
通过quonum队列发送接收消息和普通队列是一样的操作。