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

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

成都创新互联公司成立与2013年,先为福建等服务建站,福建等地企业,进行企业商务咨询服务。为福建企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。

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()

文章题目:ActiveMQ:使用Python访问ActiveMQ的方法-创新互联
URL链接:http://scyanting.com/article/cdjhes.html