activemq Python
时间: 2023-11-05 15:17:39 浏览: 39
ActiveMQ支持Python访问,提供了基于STOMP协议的库。可以使用stomp.py这个Python库来实现与ActiveMQ的交互。在官方文档的Cross Language Clients中提供了更详细的介绍和示例代码。
下面是一个示例代码的片段,展示了如何使用stomp.py库连接到ActiveMQ并发送和接收消息:
```
import time
import sys
import stomp
class MyListener(stomp.ConnectionListener):
def on_error(self, frame):
print('received an error "%s"' % frame.body)
def on_message(self, frame):
print('received a message "%s"' % frame.body)
conn = stomp.Connection()
conn.set_listener('', MyListener())
conn.connect('admin', 'password', wait=True)
conn.subscribe(destination='/queue/test', id=1, ack='auto')
conn.send(body=' '.join(sys.argv<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* [ActiveMQ:使用Python访问ActiveMQ的方法](https://download.csdn.net/download/weixin_38519660/14869343)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"]
- *2* *3* [python 使用ActiveMQ](https://blog.csdn.net/CHERISHGF/article/details/119325862)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]