首页 > 代码库 > 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个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。