前言

RabbitMQ是基于AMQP協議(Advanced Message Queue Protocol)的消息中間件。

什么是消息隊列

消息隊列屬于進程間通信的一種方式，使用消息隊列可以通過異步方式處理數據，借此可以提高系統性能。我們可以把消息當作存放數據的容器，消息的消費者可以從隊列中獲取數據，進行處理。常見的消息隊列有：ActiveMQ，RabbitMQ，Kafka，RocketMQ等。

RabbitMQ中用到基本概念

Broker：消息隊列的服務器實體。

Exchange：消息交換機，它指定消息按什么規則，路由到哪個隊列。

Queue：消息隊列載體，每個消息都會被投入到一個或多個隊列。

Binding：綁定，它主要是把exchange和queue按照路由規則綁定起來。

Routing Key：路由關鍵字，exchange根據這個關鍵字進行消息投遞。

vhost：虛擬主機，一個broker里可以開設多個vhost，用作不同用戶的權限分離。

producer：消息生產者，投遞消息的程序。

consumer：消息消費者，接收消息的程序。

channel：消息通道，在客戶端的每個連接里，可以建立多個channel，每個channel代表一個會話任務。

RabbitMQ中消息模式

1、簡單隊列

一個生產者對應一個消費者。

2、工作隊列

一個生產者，多個消費者，一個消息只能發給一個消費者，spring中整合rabbitmq時，默認采用公平分發。

3、發布訂閱模式

傳遞一個消息到多個消費者中，借助該模式可以發布的消息將被廣播給所有接收者。

　　使用該模式需要借助交換機，生產者將消息發送到交換機，再通過交換機到達隊列。

RabbitMQ中有四種交換機：direct/topic/headers/fanout。默認交換機是direct，發布與訂閱的實現使用fanout。

使用交換機時，每個消費者有自己的隊列，生產者將消息發送到交換機(X)，每個隊列都要綁定到交換機。

4、路由模式

生產者將消息發送到direct交換機(路由模式需要借助直連交換機實現)，在綁定隊列和交換機的時候有一個路由key，生產者發送的消息會指定一個路由key，那么消息只會發送到相應key相同的隊列，接著監聽該隊列的消費者消費消息。也就是讓消費者有選擇性的接收消息。

5、主題模式

又稱通配符模式。

使用直連交換機可以改善我們的系統，但是它仍有局限性，它不能實現多重條件的路由。在消息系統中，我們不僅想要訂閱基于路由鍵的隊列，還想訂閱基于生產消息的源，這時候可以使用topic交換機。

使用主題交換機時，路由鍵的語法形式是采用點分割的有意義的單詞。例如"goods.stock.info"。

其中：*星號代表一個單詞，#井號代表0個或多個單詞。

本文來自千鋒教育，轉載請注明出處。

總結

以上是生活随笔為你收集整理的Java教程之RabbitMQ介绍的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。