自已整理的一些零散的知識點
簡介
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/