消息隊(duì)列技術(shù)是分布式應(yīng)用間交換信息的一種技術(shù)，消息隊(duì)列可駐留在內(nèi)存或者磁盤(pán)上，隊(duì)列存儲(chǔ)消息直到它們被應(yīng)用程序讀走，通過(guò)消息隊(duì)列，應(yīng)用程序可以獨(dú)立的執(zhí)行—它們不需要知道彼此的位置，或者繼續(xù)執(zhí)行前不需要等待接收程序接收此消息。
（1）隊(duì)列管理器

隊(duì)列管理器是MQ系統(tǒng)中最上層的一個(gè)概念，由它為我們提供基于隊(duì)列的消息服務(wù)。

（2）消息

在MQ中，把應(yīng)用程序交由MQ傳輸?shù)臄?shù)據(jù)定義為消息，我們可以定義消息的內(nèi)容并對(duì)消息進(jìn)行廣義的理解，比如：用戶的各種類型數(shù)據(jù)文件，某個(gè)應(yīng)用向其他應(yīng)用發(fā)出的處理請(qǐng)求都可以作為消息。消息由兩部分組成：

• 消息描述符：描述消息的特征，如消息的優(yōu)先級(jí)，聲明周期，消息Id等
• 消息體：即用戶的數(shù)據(jù)部分，在MQ中，消息分為兩種類型，非永久性消息和永久性消息，非永久性消息是存儲(chǔ)在內(nèi)存中，它是為了提高性能而設(shè)計(jì)的，當(dāng)系統(tǒng)掉電或者M(jìn)Q隊(duì)列管理器重新啟動(dòng)時(shí)，將不可恢復(fù)。當(dāng)用戶對(duì)消息的可靠性要求不高，而側(cè)重系統(tǒng)的性能表現(xiàn)時(shí)，可以采用該類型的消息。如：發(fā)布股票信息時(shí)，由于股票信息不斷更新，可能每若干秒就會(huì)發(fā)布一次，新的消息會(huì)不斷覆蓋舊的消息。永久性消息是存儲(chǔ)在磁盤(pán)上的，并且記錄數(shù)據(jù)日志的，它具有高可靠性，在網(wǎng)絡(luò)和系統(tǒng)發(fā)生故障情況下能確保消息不丟，不重。
• 此外，在MQ中，還有邏輯消息和物理消息。利用邏輯消息和物理消息，可以將大消息進(jìn)行分段處理，也可以將若干個(gè)本身完整的消息在應(yīng)用邏輯上歸為一組進(jìn)行處理。

（4）隊(duì)列

隊(duì)列是消息的安全存放地，隊(duì)列存儲(chǔ)消息直到它被應(yīng)用程序處理。

消息隊(duì)列采用下述方式工作：
（a）程序A形成對(duì)消息隊(duì)列系統(tǒng)的調(diào)用，此調(diào)用告知消息隊(duì)列系統(tǒng)，消息準(zhǔn)備好了投向程序B。

（b）消息隊(duì)列系統(tǒng)發(fā)送此消息到程序B駐留處的系統(tǒng)，并將它放到程序B的隊(duì)列中。

（c）適當(dāng)時(shí)間后，程序B從它的隊(duì)列中讀此消息，并處理此信息、

由于采用了先進(jìn)的程序設(shè)計(jì)思想以及內(nèi)部工作機(jī)制，MQ能夠在各種網(wǎng)絡(luò)條件下保證消息的可靠傳遞，可以克服網(wǎng)絡(luò)線路質(zhì)量差或不穩(wěn)定的現(xiàn)狀，在傳輸過(guò)程中，如果通信線路出現(xiàn)故障或遠(yuǎn)端的主機(jī)發(fā)生故障，本地的應(yīng)用程序都不會(huì)受到影響，可以繼續(xù)發(fā)送數(shù)據(jù)，而無(wú)需等待網(wǎng)絡(luò)故障恢復(fù)或遠(yuǎn)端主機(jī)正常后再重新運(yùn)行。

在MQ中，隊(duì)列分為很多種類型：本地隊(duì)列，遠(yuǎn)程隊(duì)列、模板隊(duì)列，動(dòng)態(tài)隊(duì)列，別名隊(duì)列

本地隊(duì)列又分為普通本地隊(duì)列和傳輸隊(duì)列，普通本地隊(duì)列是應(yīng)用程序通過(guò)API對(duì)其進(jìn)行讀寫(xiě)操作的隊(duì)列，傳輸隊(duì)列可以理解為存儲(chǔ)-轉(zhuǎn)發(fā)隊(duì)列，比如：我們將某個(gè)消息交給MQ系統(tǒng)發(fā)送到遠(yuǎn)程主機(jī)，而此時(shí)網(wǎng)絡(luò)發(fā)生故障，MQ將把消息放在傳輸隊(duì)列中暫存，當(dāng)網(wǎng)絡(luò)恢復(fù)時(shí)，再發(fā)往遠(yuǎn)端目的地。

遠(yuǎn)程隊(duì)列是目的隊(duì)列在本地的定義，它類似一個(gè)地址指針，指向遠(yuǎn)程主機(jī)上的某個(gè)目的隊(duì)列，它僅僅是個(gè)定義，不真正占用磁盤(pán)存儲(chǔ)空間。
模板隊(duì)列和動(dòng)態(tài)隊(duì)列是MQ的一個(gè)特色，它的一個(gè)典型用途是用作系統(tǒng)的可擴(kuò)展性考慮。我們可以創(chuàng)建一個(gè)模板隊(duì)列，當(dāng)今后需要新增隊(duì)列時(shí)，每打開(kāi)一個(gè)模板隊(duì)列，MQ便會(huì)自動(dòng)生成一個(gè)動(dòng)態(tài)隊(duì)列，我們還可以指定該動(dòng)態(tài)隊(duì)列為臨時(shí)隊(duì)列或者是永久隊(duì)列，若為臨時(shí)隊(duì)列我們可以在關(guān)閉它的同時(shí)將它刪除，相反，若為永久隊(duì)列，我們可以將它永久保留，為我所用。
（4）通道

通道是MQ系統(tǒng)中隊(duì)列管理器之間傳遞消息的管道，它是建立在物理的網(wǎng)絡(luò)連接之上的一個(gè)邏輯概念，也是MQ產(chǎn)品的精華。
在MQ中，主要有三大類通道類型，即消息通道，MQI通道和Cluster通道。消息通道是用于在MQ的服務(wù)器和服務(wù)器之間傳輸消息的，需要強(qiáng)調(diào)指出的是，該通道是單向的，它又有發(fā)送(sender), 接收(receive), 請(qǐng)求者(requestor), 服務(wù)者(server)等不同類型，供用戶在不同情況下使用。MQI通道是MQ Client和MQ Server之間通訊和傳輸消息用的，與消息通道不同，它的傳輸是雙向的。群集(Cluster)通道是位于同一個(gè)MQ 群集內(nèi)部的隊(duì)列管理器之間通訊使用的。

MQ的通訊模式

點(diǎn)對(duì)點(diǎn)通訊：點(diǎn)對(duì)點(diǎn)方式是最為傳統(tǒng)和常見(jiàn)的通訊方式，它支持一對(duì)一、一對(duì)多、多對(duì)多、多對(duì)一等多種配置方式，支持樹(shù)狀、網(wǎng)狀等多種拓?fù)浣Y(jié)構(gòu)。

多點(diǎn)廣播：MQ適用于不同類型的應(yīng)用。其中重要的，也是正在發(fā)展中的是"多點(diǎn)廣播"應(yīng)用，即能夠?qū)⑾l(fā)送到多個(gè)目標(biāo)站點(diǎn)(Destination List)。可以使用一條MQ指令將單一消息發(fā)送到多個(gè)目標(biāo)站點(diǎn)，并確保為每一站點(diǎn)可靠地提供信息。MQ不僅提供了多點(diǎn)廣播的功能，而且還擁有智能消息分發(fā)功能，在將一條消息發(fā)送到同一系統(tǒng)上的多個(gè)用戶時(shí)，MQ將消息的一個(gè)復(fù)制版本和該系統(tǒng)上接收者的名單發(fā)送到目標(biāo)MQ系統(tǒng)。目標(biāo)MQ系統(tǒng)在本地復(fù)制這些消息，并將它們發(fā)送到名單上的隊(duì)列，從而盡可能減少網(wǎng)絡(luò)的傳輸量。

發(fā)布/訂閱(Publish/Subscribe)模式：發(fā)布/訂閱功能使消息的分發(fā)可以突破目的隊(duì)列地理指向的限制，使消息按照特定的主題甚至內(nèi)容進(jìn)行分發(fā)，用戶或應(yīng)用程序可以根據(jù)主題或內(nèi)容接收到所需要的消息。發(fā)布/訂閱功能使得發(fā)送者和接收者之間的耦合關(guān)系變得更為松散，發(fā)送者不必關(guān)心接收者的目的地址，而接收者也不必關(guān)心消息的發(fā)送地址，而只是根據(jù)消息的主題進(jìn)行消息的收發(fā)。在MQ家族產(chǎn)品中，MQ Event Broker是專門用于使用發(fā)布/訂閱技術(shù)進(jìn)行數(shù)據(jù)通訊的產(chǎn)品，它支持基于隊(duì)列和直接基于TCP/IP兩種方式的發(fā)布和訂閱。

群集(Cluster)：為了簡(jiǎn)化點(diǎn)對(duì)點(diǎn)通訊模式中的系統(tǒng)配置，MQ提供Cluster(群集)的解決方案。群集類似于一個(gè)域(Domain)，群集內(nèi)部的隊(duì)列管理器之間通訊時(shí)，不需要兩兩之間建立消息通道，而是采用群集(Cluster)通道與其它成員通訊，從而大大簡(jiǎn)化了系統(tǒng)配置。此外，群集中的隊(duì)列管理器之間能夠自動(dòng)進(jìn)行負(fù)載均衡，當(dāng)某一隊(duì)列管理器出現(xiàn)故障時(shí)，其它隊(duì)列管理器可以接管它的工作，從而大大提高系統(tǒng)的高可靠性。

總結(jié)

以上是生活随笔為你收集整理的MQ消息中间件介绍的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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