歷史：

Message Queue的需求由來已久，80年代最早在金融交易中，高盛等公司采用Teknekron公司的產(chǎn)品，當(dāng)時的Message queuing軟件叫做：the information bus（TIB）。 TIB被電信和通訊公司采用，路透社收購了Teknekron公司。之后，IBM開發(fā)了MQSeries，微軟開發(fā)了Microsoft Message Queue（MSMQ）。這些商業(yè)MQ供應(yīng)商的問題是廠商鎖定，價格高昂。2001年，Java Message queuing試圖解決鎖定和交互性的問題，但對應(yīng)用來說反而更加麻煩了。

于是2004年，摩根大通和iMatrix開始著手Advanced Message Queuing Protocol （AMQP）開放標(biāo)準(zhǔn)的開發(fā)。2006年，AMQP規(guī)范發(fā)布。2007年，Rabbit技術(shù)公司基于AMQP標(biāo)準(zhǔn)開發(fā)的RabbitMQ 1.0 發(fā)布。

基本概念

AMQP基本模型如下圖所示：    

Broker：

接收和分發(fā)消息的應(yīng)用，如RabbitMQ Server就是Message Broker。

Virtual host：

出于多租戶和安全因素設(shè)計的，把AMQP的基本組件劃分到一個虛擬的分組中，類似于網(wǎng)絡(luò)中的namespace概念。

Exchange

交換器是消息送達(dá)的實體。他是具名的，它是消息的第一站。系統(tǒng)根據(jù)分發(fā)規(guī)則，匹配查詢表中的routing key，分發(fā)消息到queue中去。

屬性：

• durable：該交換器將在broker重啟后生效。

• auto-delete：該交換器將在沒有消息隊列綁定時自動刪除。一個從未綁定任何隊列的交換器不會自動刪除。

類型：

• direct (point-to-point)

• fanout (multicast)

• topic (publish-subscribe)

Queue

隊列是接收消息的實體，具有名字和屬性，但沒有類型。客戶端可以訂閱隊列以便使broker遞送某消息隊列的內(nèi)容到該客戶端。

屬性：

• alternate-exchange ：當(dāng)消息被訂閱者拒絕或者由于隊列被刪除而孤立時則被送往此交換器，同時隊列中的該消息被刪除。

• passive ：當(dāng)隊列不存在時會拋出一個錯誤信息，仍然不會被聲明。

• durable ：隊列將在broker重啟時啟動。

• exclusive ：隊列僅服務(wù)于一個客戶端。

• auto-delete ：隊列在沒有活躍訂閱者的時候?qū)⒆詣觿h除。當(dāng)客戶端終結(jié)時，exclusive類型的隊列則一定會自動刪除。

Binding

綁定是隊列和交換器之間的關(guān)系，規(guī)定消息如何由交換器到隊列。綁定的屬性被交換器用來與路由算法匹配。

當(dāng)一個消息的路由關(guān)鍵字與綁定中的模式匹配時，交換器會把該消息的拷貝送達(dá)隊列。如何進(jìn)行匹配僅依賴于交換器的類型：

• direct型 ：消息的路由關(guān)鍵字與綁定相同。

• fanout型 ：總是匹配，即使綁定無關(guān)鍵字。

• topic型 ：匹配路由關(guān)鍵字屬性，字符串的各個部分以'.'分隔?？砂瑑蓚€特殊字符：'*'表示單個任意詞，'#'表示0個或多個詞，例如 *.stock.# 匹配usd.stock和eur.stock.db，但不匹配stock.nasdaq。

• headers型 ：匹配各個鍵-值對的邏輯組合結(jié)果。

Connection:

publisher／consumer和broker之間的TCP連接。斷開連接的操作只會在client端進(jìn)行，Broker不會斷開連接，除非出現(xiàn)網(wǎng)絡(luò)故障或broker服務(wù)出現(xiàn)問題。

Channel:

如果每一次訪問RabbitMQ都建立一個Connection，在消息量大的時候建立TCP Connection的開銷將是巨大的，效率也較低。

Channel是在connection內(nèi)部建立的邏輯連接，如果應(yīng)用程序支持多線程，通常每個thread創(chuàng)建單獨的channel進(jìn)行通訊，AMQP method包含了channel id幫助客戶端和message broker識別channel，所以channel之間是完全隔離的。Channel作為輕量級的Connection極大減少了操作系統(tǒng)建立TCP connection的開銷。

到此這篇關(guān)于高級消息隊列協(xié)議AMQP的文章就介紹到這了。希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評論