自已整理的一些零散的知識(shí)點(diǎn)
簡(jiǎn)介
AMQP(消息隊(duì)列協(xié)議,Advanced Message Queuing Protocol)是一種消息協(xié)議 ,等同于JMS,但是JMS只是java平臺(tái)的方案,AMQP是一個(gè)跨語(yǔ)言的協(xié)議。
AMQP 不分語(yǔ)言平臺(tái),最初來(lái)自JPMorgon,因?yàn)闃I(yè)務(wù)需要而滋生,很快從金融界推廣到整個(gè)計(jì)算機(jī)界流行起來(lái)。
AMQP 目前還是一個(gè)草案,最新版本是:0.10
Publisher --->Exchange ---> MessageQueue --->Consumer
整個(gè)過(guò)程是異步的.Publisher,Consumer相互不知道對(duì)方的存在
Exchange負(fù)責(zé)交換/路由,依靠Routing Key,每個(gè)消息者有一個(gè)Routing Key
每個(gè)Binding將自已感興趣的RoutingKey告訴Exchange,以便Exchange將相關(guān)的
消息轉(zhuǎn)發(fā)給相應(yīng)的Queue
幾個(gè)概念
Producer,Routing Key,Exchange,Binding,Queue,Consumer.
Producer: 消息的創(chuàng)建者,消息的發(fā)送者
Routing Key:唯一用來(lái)映射消息該進(jìn)入哪個(gè)隊(duì)列的標(biāo)識(shí)
Exchange:負(fù)責(zé)消息的路由,交換
Binding:定義Queue和Exchange的映射關(guān)系
Queue:消息隊(duì)列
Consumer:消息的使用者
Exchange類型
Fan-Out:類似于廣播方式,不管RoutingKey
Direct:根據(jù)RoutingKey,進(jìn)行關(guān)聯(lián)投寄
Topic:類似于Direct,但是支持多個(gè)Key關(guān)聯(lián),以組的方式投寄。
key以.來(lái)定義界限。類似于usea.news,usea.weather.這兩個(gè)消息是一組的。
QPID
QPID是AMQP的一個(gè)實(shí)現(xiàn),提供C++,JAVA版本的broker,支持多種語(yǔ)言客戶端。
基本功能外提供以下特性:
采用 Corosync(?)來(lái)保證集群環(huán)境下的Fault-tolerant(?) 特性
支持XML的Exchange,消息為XML時(shí),彩用Xquery過(guò)濾
支持plugin
提供安全認(rèn)證,可對(duì)producer/consumer提供身份認(rèn)證
qpidd --port --no-data-dir --auth
port:端口
--no-data-dir:不指定數(shù)據(jù)目錄
--auth:不啟用安全身份認(rèn)證
啟動(dòng)后自動(dòng)創(chuàng)建一些Exchange,amp.topic,amp.direct,amp.fanout
tools:
Qpid-config:維護(hù)Queue,Exchange,內(nèi)部配置
Qpid-route:配置broker Federation(聯(lián)盟?集群?)
Qpid-tool:監(jiān)控
參考:
關(guān)于AMQP更多信息可參考: http://www.openamq.org/doc:amqp-background
關(guān)于QPID的更多和使用可參考:http://qpid.apache.org/