ActiveMQ的PHP、Python客

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

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

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

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

基于stomppy访问ActiveMQ的Python代码：

import time, sys 
import stomp 
 
#消息侦听器 
class MyListener(object): 
    def on_error(self, headers, message): 
        print 'received an error %s' % message 
 
    def on_message(self, headers, message): 
        print '%s' % message 
         
#创建连接 
conn = stomp.Connection([('127.0.0.1',61613)]) 
 
#设置消息侦听器 
conn.set_listener('', MyListener()) 
 
#启动连接 
conn.start() 
conn.connect() 
 
#订阅主题，并采用消息自动确认机制 
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代码：

<?php 
 
$topic  = '/topic/all_news'; 
 
 
try { 
    $stomp = new Stomp('tcp://127.0.0.1:61613'); 
} catch(StompException $e) { 
    die('Connection failed: ' . $e->getMessage()); 
} 
 
 
$stomp->subscribe($topic); 
 
 
while(true) { 
        $frame = $stomp->readFrame(); 
         
        if ($frame != null) { 
            echo $frame->body; 
 
             
            $stomp->ack($frame); 
        } 
} 
 
 
unset($stomp); 
 
?>