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 阅读(1208)
评论(0) 编辑 收藏