首页 > 代码库 > python+stomp+activemq
python+stomp+activemq
python也可以连接MQ，以ActiveMQ为例，安装stomp.py:
https://github.com/jasonrbriggs/stomp.py
下载后安装：
python setup.py install
很简单，然后一个简单的示例：
import timeimport sysimport stompclass MyListener(object): def on_error(self, headers, message): print(‘received an error %s‘ % message) def on_message(self, headers, message): print(‘received a message %s‘ % message)#官方示例的连接代码也落后了，现在分协议版本conn = stomp.Connection10([(‘ip...‘,61613)]) conn.set_listener(‘‘, MyListener())conn.start()conn.connect()conn.subscribe(destination=‘/queue/test‘, id=1, ack=‘auto‘)#注意，官方示例这样发送消息是有问题的#conn.send(body=‘hello,garfield! this is ‘.join(sys.argv[1:]), destination=‘/queue/test‘)conn.send(body=‘hello,garfield!‘, destination=‘/queue/test‘)time.sleep(2)conn.disconnect()
好了，可以发送、接收消息了!
python+stomp+activemq
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。