RabbitMQ簡(jiǎn)介

AMQP，即Advanced Message Queuing Protocol，高級(jí)消息隊(duì)列協(xié)議，是應(yīng)用層協(xié)議的一個(gè)開放標(biāo)準(zhǔn)，為面向消息的中間件設(shè)計(jì)。消息中間件主要用于組件之間的解耦，消息的發(fā)送者無(wú)需知道消息使用者的存在，反之亦然。AMQP的主要特征是面向消息、隊(duì)列、路由（包括點(diǎn)對(duì)點(diǎn)和發(fā)布/訂閱）、可靠性、安全。
RabbitMQ是一個(gè)開源的AMQP實(shí)現(xiàn)，服務(wù)器端用Erlang語(yǔ)言編寫，支持多種客戶端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX。用于在分布式系統(tǒng)中存儲(chǔ)轉(zhuǎn)發(fā)消息，在易用性、擴(kuò)展性、高可用性等方面表現(xiàn)不俗。

RabbitMQ基本概念

1.Message
消息，消息是不具名的，它由消息頭和消息體組成。消息體是不透明的，而消息頭則由一系列的可選屬性組成，這些屬性包括routing-key（路由鍵）、priority（相對(duì)于其他消息的優(yōu)先權(quán)）、delivery-mode（指出該消息可能需要持久性存儲(chǔ)）等。
2.Publisher
消息的生產(chǎn)者，也是一個(gè)向交換器發(fā)布消息的客戶端應(yīng)用程序。
3.Exchange
交換器，用來(lái)接收生產(chǎn)者發(fā)送的消息并將這些消息路由給服務(wù)器中的隊(duì)列。
4.Binding
綁定，用于消息隊(duì)列和交換器之間的關(guān)聯(lián)。一個(gè)綁定就是基于路由鍵將交換器和消息隊(duì)列連接起來(lái)的路由規(guī)則，所以可以將交換器理解成一個(gè)由綁定構(gòu)成的路由表。
5.Queue
消息隊(duì)列，用來(lái)保存消息直到發(fā)送給消費(fèi)者。它是消息的容器，也是消息的終點(diǎn)。一個(gè)消息可投入一個(gè)或多個(gè)隊(duì)列。消息一直在隊(duì)列里面，等待消費(fèi)者連接到這個(gè)隊(duì)列將其取走。
6.Connection
網(wǎng)絡(luò)連接，比如一個(gè)TCP連接。
7.Channel
信道，多路復(fù)用連接中的一條獨(dú)立的雙向數(shù)據(jù)流通道。信道是建立在真實(shí)的TCP連接內(nèi)地虛擬連接，AMQP 命令都是通過(guò)信道發(fā)出去的，不管是發(fā)布消息、訂閱隊(duì)列還是接收消息，這些動(dòng)作都是通過(guò)信道完成。因?yàn)閷?duì)于操作系統(tǒng)來(lái)說(shuō)建立和銷毀 TCP 都是非常昂貴的開銷，所以引入了信道的概念，以復(fù)用一條 TCP 連接。
8.Consumer
消息的消費(fèi)者，表示一個(gè)從消息隊(duì)列中取得消息的客戶端應(yīng)用程序。
9.Virtual Host
虛擬主機(jī)，表示一批交換器、消息隊(duì)列和相關(guān)對(duì)象。虛擬主機(jī)是共享相同的身份認(rèn)證和加密環(huán)境的獨(dú)立服務(wù)器域。每個(gè) vhost 本質(zhì)上就是一個(gè) mini 版的 RabbitMQ 服務(wù)器，擁有自己的隊(duì)列、交換器、綁定和權(quán)限機(jī)制。vhost 是 AMQP 概念的基礎(chǔ)，必須在連接時(shí)指定，RabbitMQ 默認(rèn)的 vhost 是 / 。
10.Broker
表示消息隊(duì)列服務(wù)器實(shí)體。

Exchange 類型

Exchange分發(fā)消息時(shí)根據(jù)類型的不同分發(fā)策略有區(qū)別，目前共四種類型：direct、fanout、topic、headers 。下面只講前三種模式。
1.Direct模式
消息中的路由鍵（routing key）如果和 Binding 中的 binding key 一致， 交換器就將消息發(fā)到對(duì)應(yīng)的隊(duì)列中。路由鍵與隊(duì)列名完全匹配
2.Topic模式

topic 交換器通過(guò)模式匹配分配消息的路由鍵屬性，將路由鍵和某個(gè)模式進(jìn)行匹配，此時(shí)隊(duì)列需要綁定到一個(gè)模式上。它將路由鍵和綁定鍵的字符串切分成單詞，這些單詞之間用點(diǎn)隔開。它同樣也會(huì)識(shí)別兩個(gè)通配符：符號(hào)“#”和符號(hào)“”。#匹配0個(gè)或多個(gè)單詞，匹配一個(gè)單詞。

3.Fanout模式x
每個(gè)發(fā)到 fanout 類型交換器的消息都會(huì)分到所有綁定的隊(duì)列上去。fanout 交換器不處理路由鍵，只是簡(jiǎn)單的將隊(duì)列綁定到交換器上，每個(gè)發(fā)送到交換器的消息都會(huì)被轉(zhuǎn)發(fā)到與該交換器綁定的所有隊(duì)列上。很像子網(wǎng)廣播，每臺(tái)子網(wǎng)內(nèi)的主機(jī)都獲得了一份復(fù)制的消息。fanout 類型轉(zhuǎn)發(fā)消息是最快的。

SpringBoot整合RabbitMQ

在 pom.xml 中添加 spring-boot-starter-amqp的依賴

在 application.yml文件中配置rabbitmq相關(guān)內(nèi)容

使用Direct模式

1.配置隊(duì)列

2.創(chuàng)建一個(gè)User實(shí)體類

3.接收者

4.發(fā)送者

5.測(cè)試，訪問(wèn)http://localhost:8080/sendDirectQueue，查看日志輸出

6.日志輸出

注意：發(fā)送者與接收者的Queue名字一定要相同，否則接收收不到消息

使用Topic模式

1.配置隊(duì)列

2.創(chuàng)建一個(gè)User實(shí)體類（和上面一樣）

3.接收者

4.發(fā)送者

5.測(cè)試，訪問(wèn)http://localhost:8080/sendTopic，查看日志輸出

6.日志輸出

由日志記錄可以看出lzc.message可以被receiveTopic1和receiveTopic2所接收，而lzc.lzc只能被receiveTopic2接收。

使用Fanout模式

1.配置隊(duì)列

2.創(chuàng)建一個(gè)User實(shí)體類（和上面一樣）

3.接收者

4.發(fā)送者

5.測(cè)試，訪問(wèn)http://localhost:8080/sendFanout，查看日志輸出

6.日志輸出

由日志輸出可以看出，兩個(gè)接收者都接收到了消息，因?yàn)榻粨Q機(jī)FANOUT_EXCHANGE綁定了兩個(gè)隊(duì)列。

在此我向大家推薦一個(gè)架構(gòu)學(xué)習(xí)交流群。交流學(xué)習(xí)群號(hào)：478030634 里面會(huì)分享一些資深架構(gòu)師錄制的視頻錄像：有Spring，MyBatis，Netty源碼分析，高并發(fā)、高性能、分布式、微服務(wù)架構(gòu)的原理，JVM性能優(yōu)化、分布式架構(gòu)等這些成為架構(gòu)師必備的知識(shí)體系。還能領(lǐng)取免費(fèi)的學(xué)習(xí)資源，目前受益良多

注：關(guān)注作者微信公眾號(hào)，了解更多分布式架構(gòu)、微服務(wù)、netty、MySQL、spring、性能優(yōu)化、等知識(shí)點(diǎn)。公眾號(hào)：《Java爛豬皮》

總結(jié)

以上是生活随笔為你收集整理的SpringBoot使用RabbitMQ消息队列的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。