1.python
使用的是python 2.5。
2.STOMP
stomp是Python客户端库用来访问消息传递的服务器,比如ActiveMQ或JBoss Messaging。
通过cmd命令打开setup.py所在的目录,使用setup.py install 命令进行安装。
3.ActiveMQ
使用的是apache-activemq-5.6.0。安装成功后,配置环境变量ACTIVEMQ_HOME:apache-activemq-5.6.0所在路径。
在apache-activemq-5.6.0\conf目录下找到activemq.xml,找到
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/><!-- 添加以下内容 -->
<transportConnector uri="stomp://localhost:61613"/>
保存。
cmd进入BIN目录,运行activemq,或者直接运行activemq.bat,然后可以看到下面信息
在浏览器中输入 :localhost:8161/admin/打开ActiveMQ的控制台,然后可以看到如下信息
然后编写python测试程序
#!/usr/bin/python
#
# Usage: stomp_test.py <msize> <nmsgs>
#
import stomp
import time
dest = 'TEST_ID'
try:
conn = stomp.Connection([('127.0.0.1', 61613)])
print "connection"
conn.start()
print "start"
conn.connect(wait=True)
print "connected"
conn.send('123456789', destination=dest, headers={'type':'textMessage'}, ack='auto')
print "send"
time.sleep(2)
print "sleep"
conn.disconnect()
print "disconnect"
except Exception , e:
print '==============', e
然后在ActiveMQ控制台Queues中看到发送的消息了
4.ANT(对ActiveMQ的测试)
安装ANT
设置环境变量:
ANT_HOME=安装路径
PATH=安装路径的bin目录
CMD进入BIN目录后后,输入ANT出现
Buildfile: build.xml does not exist!
Build failed
表示配置成功!
1.打开一个cmd,运行activemq
2.打开另外一个cmd,进入安装目录下的example目录,运行ant consumer,可以看到相关接受信息
3.打开另外一个cmd,进入安装目录下的example目录,运行ant producer,可以看到相关接受信息
ok!