Apache Qpid:
Wiki上的描述是:
Apache Qpid is an open source (Apache 2.0 licensed) messaging system which implements the Advanced Message Queuing Protocol. It provides transaction management, queuing, distribution, security, management, clustering, federation and heterogeneous multi-platform support.
OK,不廢話,進入正題,我今天搞了一天才將其配置好,稍微會有一點麻煩,不過還算好用,對于用到Message Queue或者想用的朋友,可以嘗試一下!
首先進入
http://qpid.apache.org/getting-started.html,然后進入download 頁面,由于我是用JAVA來開發,所以我選擇下載Mutiple Component Packages條目下的JAVA broker,client & tools這一個,用C++開發或者其他語言開發的也可以適當選擇下載。另外還有一個適用的工具可以下載是在Management tools條目下面(是一個基于Eclipse RUP 的軟件,由于今天調了半天沒調好所以就不說明了)
然后回到getting-start那一頁看安裝說明: 在這里我稍微說下吧,反正也很簡單(解壓什么的就略過了)!
1. 設置環境變量,這里有兩個環境變量需要設置 QPID_HOME 和QPID_WORK,上面的E問很簡單,QPID_WORK是用來設置broker產生文件的路徑,主要是LOG吧。
2.修改%QPID_HOME%\etc\config.xml文件,主要是修改management下面的<keyStorePath></keyStorePath>的文件路徑,否則直接啟動會出現一個莫名其妙的找不到文件的錯誤
4.執行create-example-ssl-strores,然后執行qpid-server命令即可,你可以發現broker很正常的啟動了
對于JMS的Prodcer(PTP)/Publisher(PUB/SUB)執行步驟一般是
1.通過ConnectionFactroy得到Connection(請注意Qpid示例中properties文件的connectionfactory.xxxxx鍵后面對應的值一般都是amqp://xxxx:xxxx@xxxx/xxx?brokerlist='tcp://localhost:5672'格式的)
2. 通過Connection獲得一個Session(PTP)/TopicSession(PUB/SUB)
3. 獲得MessageProducer(PTP)/Topic(PUB/SUB)
4. 產生/發布消息
5. 關閉Connection(當關閉Connection的時候,Session 也會自動關閉)
消費者/訂閱之的執行步驟幾乎差不多,就是第四步是消費/訂閱消息
好了,今天就寫到這吧,很簡單的介紹,以后再慢慢寫,有什么問題,大家可以共同探討下!
最后,注意文明用語,謝謝!~~~~
posted on 2010-05-14 18:48
Zhjiang 閱讀(1215)
評論(0) 編輯 收藏