自已整理的一些零散的知識(shí)點(diǎn)

簡介

AMQP（消息隊(duì)列協(xié)議，Advanced Message Queuing Protocol）是一種消息協(xié)議 ，等同于JMS，但是JMS只是java平臺(tái)的方案，AMQP是一個(gè)跨語言的協(xié)議。

AMQP 不分語言平臺(tái),最初來自JPMorgon,因?yàn)闃I(yè)務(wù)需要而滋生，很快從金融界推廣到整個(gè)計(jì)算機(jī)界流行起來。

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

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

整個(gè)過程是異步的.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：唯一用來映射消息該進(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以.來定義界限。類似于usea.news,usea.weather.這兩個(gè)消息是一組的。

QPID

QPID是AMQP的一個(gè)實(shí)現(xiàn)，提供C++，JAVA版本的broker,支持多種語言客戶端。

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

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

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

支持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/