ActiveMQ的PHP、Python客户端

ActiveMQ这款开源消息服务器提供了多语言支持，除了一般的Java客户端以外，还可以使用C/C++、PHP、Python、JavaScript（Ajax）等语言开发客户端。最近由于项目需要，需要提供PHP和Python的主题订阅客户端。这里作为总结，列出这两种语言客户端的简单安装和使用。

对于PHP和Python，可以通过使用STOMP协议与消息服务器进行通讯。在ActiveMQ的配置文件activemq.xml中，需要添加以下语句，来提供基于STOMP协议的连接器。

1. <transportConnectors>
2. <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
3. <transportConnector name="stomp" uri="stomp://0.0.0.0:61613"/><!--添加stomp连接器-->
4. </transportConnectors>

Python
安装Python27，并安装stomppy（http://code.google.com/p/stomppy/）这一客户端库：

基于stomppy访问ActiveMQ的Python代码：

1. import time, sys
2. import stomp
3. #消息侦听器
4. class MyListener(object):
5. def on_error(self, headers, message):
6. print ‘received an error %s‘ % message
7. def on_message(self, headers, message):
8. print ‘%s‘ % message
9. #创建连接
10. conn = stomp.Connection([(‘127.0.0.1‘,61613)])
11. #设置消息侦听器
12. conn.set_listener(‘‘, MyListener())
13. #启动连接
14. conn.start()
15. conn.connect()
16. #订阅主题，并采用消息自动确认机制
17. conn.subscribe(destination=‘/topic/all_news‘, ack=‘auto‘)

PHP

安装PHP5，并安装STOMP的客户端库（http://php.net/manual/zh/book.stomp.php）：

安装完成后，将生成的stomp.so移入php.ini中指定的extension_dir目录下，并在php.ini中添加该客户端库:

访问ActiveMQ的PHP代码：

1. <?php
2. $topic  = ‘/topic/all_news‘;
3. /* connection */
4. try {
5. $stomp = new Stomp(‘tcp://127.0.0.1:61613‘);
6. } catch(StompException $e) {
7. die(‘Connection failed: ‘ . $e->getMessage());
8. }
9. /* subscribe to messages from the queue ‘foo‘ */
10. $stomp->subscribe($topic);
11. /* read a frame */
12. while(true) {
13. $frame = $stomp->readFrame();
14. if ($frame != null) {
15. echo $frame->body;
16. /* acknowledge that the frame was received */
17. $stomp->ack($frame);
18. }
19. }
20. /* close connection */
21. unset($stomp);
22. ?>

本文出自 “学习文档” 博客，请务必保留此出处http://zephiruswt.blog.51cto.com/5193151/1109606