利用Python连接ActiveMQ的途径
5星
- 浏览量: 0
- 大小:None
- 文件类型：None
简介：
本文介绍了如何使用Python语言与ActiveMQ消息中间件进行连接的方法和步骤，帮助开发者实现高效的消息队列通信。
在使用Windows 10家庭中文版以及Python 3.6.4的环境下，可以通过stomp.py库来访问ActiveMQ。该库基于STOMP协议（端口为61613），支持跨语言客户端操作，并且提供了详细的官方文档和示例代码进行说明。
安装过程包括从官方网站下载stomp.py的相关文件并解压，在命令行中进入其目录后，通过执行`python setup.py install`命令完成安装。之后就可以开始使用该库来实现Python与ActiveMQ之间的交互了。
以下是来自官方文档的参考样例：
常规Python访问示例如下：
```python
import stomp
class MyListener(stomp.ConnectionListener):
def on_message(self, headers, message):
print(received a message {}.format(message))
conn = stomp.StompConnection12()
conn.set_listener(, MyListener())
conn.connect(admin, password)
conn.subscribe(destination=/queue/test, id=1, ack=auto)
# 发布消息
message_to_send = Hello World!
conn.send(body=message_to_send, destination=/queue/test)
```
使用Jython访问的示例代码与常规Python类似，此处不再赘述。
全部评论 (0)
