自已整理的一些零散的知識點

簡介

AMQP（消息隊列協議，Advanced Message Queuing Protocol）是一種消息協議 ，等同于JMS，但是JMS只是java平臺的方案，AMQP是一個跨語言的協議。

AMQP 不分語言平臺,最初來自JPMorgon,因為業務需要而滋生，很快從金融界推廣到整個計算機界流行起來。

AMQP 目前還是一個草案，最新版本是：0.10

Publisher --->Exchange ---> MessageQueue --->Consumer

整個過程是異步的.Publisher,Consumer相互不知道對方的存在

Exchange負責交換/路由，依靠Routing Key,每個消息者有一個Routing Key

每個Binding將自已感興趣的RoutingKey告訴Exchange,以便Exchange將相關的

消息轉發給相應的Queue

幾個概念

Producer,Routing Key,Exchange,Binding,Queue,Consumer.

Producer: 消息的創建者，消息的發送者

Routing Key：唯一用來映射消息該進入哪個隊列的標識

Exchange：負責消息的路由，交換

Binding:定義Queue和Exchange的映射關系

Queue：消息隊列

Consumer：消息的使用者

Exchange類型

Fan-Out:類似于廣播方式，不管RoutingKey

Direct:根據RoutingKey,進行關聯投寄 

Topic:類似于Direct,但是支持多個Key關聯，以組的方式投寄。

      key以.來定義界限。類似于usea.news,usea.weather.這兩個消息是一組的。

QPID

QPID是AMQP的一個實現，提供C++，JAVA版本的broker,支持多種語言客戶端。

基本功能外提供以下特性：

采用 Corosync(?)來保證集群環境下的Fault-tolerant(?) 特性

支持XML的Exchange,消息為XML時，彩用Xquery過濾

支持plugin

提供安全認證，可對producer/consumer提供身份認證

qpidd --port --no-data-dir --auth

port:端口

--no-data-dir:不指定數據目錄

--auth：不啟用安全身份認證

啟動后自動創建一些Exchange,amp.topic,amp.direct,amp.fanout

tools:

Qpid-config:維護Queue,Exchange,內部配置 

Qpid-route:配置broker Federation(聯盟？集群？)

Qpid-tool:監控

參考：

關于AMQP更多信息可參考： http://www.openamq.org/doc:amqp-background

關于QPID的更多和使用可參考：http://qpid.apache.org/