高級消息隊列協議AMQP簡介

歷史:

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

於是2004年,摩根大通和iMatrix開始著手Advanced Message Queuing Protocol (AMQP)開放標準的開發。2006年,AMQP規范發佈。2007年,Rabbit技術公司基於AMQP標準開發的RabbitMQ 1.0 發佈。

基本概念

AMQP基本模型如下圖所示:    

Broker:

接收和分發消息的應用,如RabbitMQ Server就是Message Broker。

Virtual host:

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

Exchange

交換器是消息送達的實體。他是具名的,它是消息的第一站。系統根據分發規則,匹配查詢表中的routing key,分發消息到queue中去。

屬性:

  • durable:該交換器將在broker重啟後生效。

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

類型:

  • direct (point-to-point)

  • fanout (multicast)

  • topic (publish-subscribe)

Queue

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

屬性:

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

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

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

  • exclusive :隊列僅服務於一個客戶端。

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

Binding

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

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

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

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

  • topic型 :匹配路由關鍵字屬性,字符串的各個部分以'.'分隔。可包含兩個特殊字符:'*'表示單個任意詞,'#'表示0個或多個詞,例如 *.stock.# 匹配usd.stock和eur.stock.db,但不匹配stock.nasdaq。

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

Connection:

publisher/consumer和broker之間的TCP連接。斷開連接的操作隻會在client端進行,Broker不會斷開連接,除非出現網絡故障或broker服務出現問題。

Channel:

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

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

到此這篇關於高級消息隊列協議AMQP的文章就介紹到這瞭。希望對大傢的學習有所幫助,也希望大傢多多支持WalkonNet。

推薦閱讀: