ActiveMQ:使用Python访问ActiveMQ的方法-创新互联

Windows 10家庭中文版，Python 3.6.4，stomp.py 4.1.21

ActiveMQ支持Python访问，提供了基于STOMP协议（端口为61613）的库。

ActiveMQ的官文Cross Language Clients中给出了更详细的介绍，并附有示例代码，如下图：

第一行为常规Python访问，第二行为使用Jython访问的方式，四个操作。

Python访问ActiveMQ需要使用stomp.py，见其官网。

下载官网的代码，解压，命令行进入其目录，使用pyhthon setup.py install即可安装好，然后就可以使用stomp.py了。

官方示例代码：给队列test发送一个消息，也可以把第7行的destination的“/queue/”去掉，只剩test。

import stomp

conn = stomp.Connection()
conn.set_listener('', MyListener())
conn.start()
conn.connect('admin', 'password', wait=True)
conn.send(body=' '.join(sys.argv[1:]), destination='/queue/test')
conn.disconnect()