歷史：

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

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

基本概念

AMQP基本模型如下圖所示：    

Broker：

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

Virtual host：

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

Exchange

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

屬性：

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

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

類型：

• direct (point-to-point)

• fanout (multicast)

• topic (publish-subscribe)

Queue

隊列是接收消息的實體，具有名字和屬性，但沒有類型?？蛻舳丝梢杂嗛嗞犃幸员闶筨roker遞送某消息隊列的內容到該客戶端。

屬性：

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

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

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

• exclusive ：隊列僅服務于一個客戶端。

• auto-delete ：隊列在沒有活躍訂閱者的時候將自動刪除。當客戶端終結時，exclusive類型的隊列則一定會自動刪除。

Binding

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

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

• direct型 ：消息的路由關鍵字與綁定相同。

• fanout型 ：總是匹配，即使綁定無關鍵字。

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

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

Connection:

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

Channel:

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

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

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

最新評論