ActiveMQ的PHP、Python客户端

发表于 | 分类于 | | 阅读次数:

ActiveMQ这款开源消息服务器提供了多语言支持，除了一般的Java客户端以外，还可以使用C/C++、PHP、Python、JavaScript（Ajax）等语言开发客户端。最近由于项目需要，需要提供PHP和Python的主题订阅客户端。这里作为总结，列出这两种语言客户端的简单安装和使用。
对于PHP和Python，可以通过使用STOMP协议与消息服务器进行通讯。在ActiveMQ的配置文件activemq.xml中，需要添加以下语句，来提供基于STOMP协议的连接器。

1
2
3
4
<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这一客户端库：
150641717
基于stomppy访问ActiveMQ的Python代码：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
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 ）：

1
2
3
4
5
6
tar -zxf stomp-1.0.5.tgz 
cd stomp-1.0.5/
/usr/local/php/bin/phpize 
./configure --enable-stomp --with-php-config=/usr/local/php/bin/php-config
make
make install

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

1
extension=stomp.so

访问ActiveMQ的PHP代码：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
<?php 

$topic  = '/topic/all_news'; 

/* connection */ 
try { 
    $stomp = new Stomp('tcp://127.0.0.1:61613'); 
} catch(StompException $e) { 
    die('Connection failed: ' . $e->getMessage()); 
} 

/* subscribe to messages from the queue 'foo' */ 
$stomp->subscribe($topic); 

/* read a frame */ 
while(true) { 
        $frame = $stomp->readFrame(); 

        if ($frame != null) { 
            echo $frame->body; 

            /* acknowledge that the frame was received */ 
            $stomp->ack($frame); 
        } 
} 

/* close connection */ 
unset($stomp); 

?>