接觸AMQP協議已經有一段時間了，這個協議比想象的中的要複雜一些，特別是針對AMQP-1-0以前的版本。具體的概念，網上可以搜尋到很多的資料，本文借花獻佛，讓讀者對AMQP協議有一個大概的瞭解。重點是在後續章節的關於一些遇到的技術難點的解決方案的分享。

最新的AMQP協議是1.0,但是以前還包括其他版本的協議

Final Specification by AMQP Working Group:

AMQP 1.0 Final, as contributed to OASIS.

Older Specifications:
AMQP version 0-10 by the AMQP Working Group

AMQP version 0-9-1 by the AMQP Working Group

AMQP version 0-9 by the AMQP Working Group

AMQP version 0-8 by the AMQP Working Group

AMQP的全稱是Advanced Message Queuing Protocol，翻譯過來就是高階訊息佇列協議。簡單來說，AMQP是一個廠商中立、語言無關的Message Broker規範。（具體請參考http://blog.csdn.net/anyaas/article/details/17637141）

AMQP規範中有幾個核心的概念：

• Message
• Virtual Host
• Exchange
• Queue
• Binding
• Routing Key
• Binding Key
• Exchange Type
• Publisher/Producer
• Subscriber/Consumer
• Connection
• Channel

Virtual Host

每個Message Broker由一個或 Virtual Host構成；可以類比一下理機和虛擬機器。Virtual Host相當於一個獨立的名稱空間，它有屬於自己的Exchange、Queue以及的一些相關物件。不同Virtual Host之間的Exchange可以重名。Queue只能和相同Virtual Host中的Exchange進行繫結。

Exchange

Queue

Queue即訊息佇列，負責儲存Exchange轉發過來的Message。注意，是Queue，所以Message是First-In-First-Out。

Binding

Binding指的是Exchange根據規則作出訊息轉發決策的過程。Message到達Exchange，Exchange此時並不知道Message應該被轉發到哪些Queue，然後Exchange根據規則對Message進行Binding決策，Binding完成之後，Exchange根據Binding的結果將Message轉發到正確的Queues。

Routing Key

每個Message一般來說必須指定一個Routing Key，Exchange根據Message的Routing Key進行Binding，然後完成Message的轉發。

Binding Key

每個Queue一般來說必須指定一個Binding Key。 Binding的過程其實就是根據一定的規則判定Message的Routing Key是否與Queue的Binding Key匹配，如果匹配，則轉發Message到Queue。如果Message的Routing Key與多個Queue的Binding Key匹配，則所有匹配的Queue都會收到該Message。

Exchange Type

Exchange Type決定了Binding的匹配規則。AMQP支援三種Exchange Type：

• Direct Exchange
• Topic Exchange
• Fanout Exchange

如果你熟悉網路中單播、組播、廣播的概念的話，你可以簡單理解為：Direct Exchange就是單播，Topic Exchange就是組播，Fanout Exchange就是廣播。

Connection

Publisher/Producer與Virutal Host 或 Subscriber/Consumer與Virtual Host之間的TCP連線。

Channel

通過多路複用技術，多個Channel共享同一個Connection。Message通過Channel在Publisher/Producer、Virutal Host、Subscriber/Consumer之間傳遞。

比較常見的第三方的實現有：

(1) Qpid

Qpid 是 Apache 開發的一款面向物件的訊息中介軟體，它是一個 AMQP 的實現，可以和其他符合 AMQP 協議的系統進行通訊。Qpid 提供了 C++/Python/Java/C# 等主流程式語言的客戶端庫，Qpid 提供了很多額外的 HA 特性，非常適於叢集環境下的訊息通訊。

雖然QPID 有0.9 和1.0的版本，而且1.0的版本有Exchange的功能

因為QPID在我們的plugin只支援1.0的版本，所以在plugin的設計上，Sender activity沒有Exchange 屬性

它提供了 C++ 和 Java 兩個版本的 broker服務端，並支援多種語言的客戶端。C++版本的伺服器端具備高效能/低消耗以及RDMA支援；而Java版本的伺服器則支援JMS。Qpid 還提供了一些額外的特性：

採用 Corosync 來保證了叢集環境下的 Fault-tolerant 特性
支援 XML 型別的 Exchange，當訊息格式為 XML 時，可以利用 Xquery 進行過濾
支援 plugin，使用者可以方便地增加新的功能，比如新的 exchange 型別
提供了安全認證特性，任何 producer/consumer 需要和 broker 通訊時，都需要提供身份認證。QPID 的安全認證使用 SSL 協議。
授權協議： Apache
開發語言： Java C/C++
作業系統： 跨平臺
官網：http://qpid.apache.org 

比較好的部落格有：

https://www.ibm.com/developerworks/cn/opensource/os-cn-qpid1/
http://blog.sina.com.cn/s/blog_5bce66f00101htgr.html

(2) RabbitMQ

RabbitMQ是基於ErLang語言開發的，官方RabbitMQ下載地址：http://www.rabbitmq.com/download.html，選擇相應的系統版本，進行下載。Erlang版本的選擇儘量選擇最新版本即可。

比較好的部落格有：

http://jaeger.blog.51cto.com/11064196/1762756(經典)
http://www.voidcn.com/blog/Olaking/article/p-3890458.html
https://geewu.gitbooks.io/rabbitmq-quick/content/RabbitMQ%E4%BB%8B%E7%BB%8D.html

Rabbit in action 中文版可以從下面下載到

http://book.51cto.com/art/201510/495741.htm

（3）ActiveMQ

ActiveMQ是Apache軟體基金下的一個開源軟體，它遵循JMS1.1規範（Java Message Service），是訊息驅動中介軟體軟體（MOM）。它為企業訊息傳遞提供高可用，出色效能，可擴充套件，穩定和安全保障。ActiveMQ使用Apache許可協議。因此，任何人都可以使用和修改它而不必反饋任何改變。這對於商業上將ActiveMQ用在重要用途的人尤為關鍵。MOM的工作是在分散式的各應用之間排程事件和訊息，使之到達指定的接收者。所以高可用，高效能，高可擴充套件性尤為關鍵。

ActiveMQ的目標是在儘可能多的平臺和語言上提供一個標準的，訊息驅動的應用整合。ActiveMQ實現JMS規範並在此之上提供大量額外的特性。這些額外的特性也會在這本書中詳細闡述。

ActiveMQ in action 中文版
http://download.csdn.net/detail/jacky68147527/5925161

如何使用安裝ActiveMQ？
H:\amqp\apache-activemq-5.13.3\data


如何配置AMQP
http://activemq.apache.org/amqp.html