天天看點

RabbitMQ高可用--Quorum Queue(仲裁隊列)的用法

簡介

說明

        本文介紹RabbitMQ的Quorum Queue(仲裁隊列)的用法。

官網網址

​​Quorum Queues — RabbitMQ​​

建立仲裁隊列

法1:在控制台建立

在任意控制台添加一個隊列,選擇隊列類型為Quorum類型。

RabbitMQ高可用--Quorum Queue(仲裁隊列)的用法

在任意控制台檢視隊列:

RabbitMQ高可用--Quorum Queue(仲裁隊列)的用法

        可以看到,仲裁隊列的 + 2字樣。代表這個隊列有2個鏡像節點。

        因為仲裁隊列預設的鏡像數為5。如果你的叢集有7個節點,那麼鏡像數肯定是5;而我們叢集隻有3個節點,是以鏡像數量就是3。

RabbitMQ高可用--Quorum Queue(仲裁隊列)的用法

法2:使用Java代碼建立

仲裁隊列本身就是一個普通的隊列,叢集搭建好了以後,隻要建立quorum類型的就行了

@Bean
public Queue quorumQueue() {
    return QueueBuilder
        .durable("quorum.queue") // 持久化
        .quorum() // 仲裁隊列
        .build();
}      

發送與接收消息

通過quonum隊列發送接收消息和普通隊列是一樣的操作。 

其他網址