前言

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

　　什么是消息隊(duì)列

　　消息隊(duì)列屬于進(jìn)程間通信的一種方式，使用消息隊(duì)列可以通過(guò)異步方式處理數(shù)據(jù)，借此可以提高系統(tǒng)性能。我們可以把消息當(dāng)作存放數(shù)據(jù)的容器，消息的消費(fèi)者可以從隊(duì)列中獲取數(shù)據(jù)，進(jìn)行處理。常見(jiàn)的消息隊(duì)列有：ActiveMQ，RabbitMQ，Kafka，RocketMQ等。

　　RabbitMQ中用到基本概念

　　Broker：消息隊(duì)列的服務(wù)器實(shí)體。

　　Exchange：消息交換機(jī)，它指定消息按什么規(guī)則，路由到哪個(gè)隊(duì)列。

　　Queue：消息隊(duì)列載體，每個(gè)消息都會(huì)被投入到一個(gè)或多個(gè)隊(duì)列。

　　Binding：綁定，它主要是把exchange和queue按照路由規(guī)則綁定起來(lái)。

　　Routing Key：路由關(guān)鍵字，exchange根據(jù)這個(gè)關(guān)鍵字進(jìn)行消息投遞。

　　vhost：虛擬主機(jī)，一個(gè)broker里可以開(kāi)設(shè)多個(gè)vhost，用作不同用戶的權(quán)限分離。

　　producer：消息生產(chǎn)者，投遞消息的程序。

　　consumer：消息消費(fèi)者，接收消息的程序。

　　channel：消息通道，在客戶端的每個(gè)連接里，可以建立多個(gè)channel，每個(gè)channel代表一個(gè)會(huì)話任務(wù)。

　　RabbitMQ中消息模式

　　1、簡(jiǎn)單隊(duì)列

　　一個(gè)生產(chǎn)者對(duì)應(yīng)一個(gè)消費(fèi)者。

　　2、工作隊(duì)列

　　一個(gè)生產(chǎn)者，多個(gè)消費(fèi)者，一個(gè)消息只能發(fā)給一個(gè)消費(fèi)者，spring中整合rabbitmq時(shí)，默認(rèn)采用公平分發(fā)。

　　3、發(fā)布訂閱模式

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

　　使用該模式需要借助交換機(jī)，生產(chǎn)者將消息發(fā)送到交換機(jī)，再通過(guò)交換機(jī)到達(dá)隊(duì)列。

　　RabbitMQ中有四種交換機(jī)：direct/topic/headers/fanout。默認(rèn)交換機(jī)是direct，發(fā)布與訂閱的實(shí)現(xiàn)使用fanout。

　　使用交換機(jī)時(shí)，每個(gè)消費(fèi)者有自己的隊(duì)列，生產(chǎn)者將消息發(fā)送到交換機(jī)(X)，每個(gè)隊(duì)列都要綁定到交換機(jī)。

　　4、路由模式

　　生產(chǎn)者將消息發(fā)送到direct交換機(jī)(路由模式需要借助直連交換機(jī)實(shí)現(xiàn))，在綁定隊(duì)列和交換機(jī)的時(shí)候有一個(gè)路由key，生產(chǎn)者發(fā)送的消息會(huì)指定一個(gè)路由key，那么消息只會(huì)發(fā)送到相應(yīng)key相同的隊(duì)列，接著監(jiān)聽(tīng)該隊(duì)列的消費(fèi)者消費(fèi)消息。也就是讓消費(fèi)者有選擇性的接收消息。

　　5、主題模式

　　又稱通配符模式。

　　使用直連交換機(jī)可以改善我們的系統(tǒng)，但是它仍有局限性，它不能實(shí)現(xiàn)多重條件的路由。在消息系統(tǒng)中，我們不僅想要訂閱基于路由鍵的隊(duì)列，還想訂閱基于生產(chǎn)消息的源，這時(shí)候可以使用topic交換機(jī)。

　　使用主題交換機(jī)時(shí)，路由鍵的語(yǔ)法形式是采用點(diǎn)分割的有意義的單詞。例如"goods.stock.info"。

　　其中：*星號(hào)代表一個(gè)單詞，#井號(hào)代表0個(gè)或多個(gè)單詞。