请问哪里可以找到rocketmq基于stomp协议的demo?
RocketMQ 支持使用 STOMP(Simple Text Oriented Messaging Protocol)协议进行消息交互,使得非 Java 语言的应用程序也可以轻松接入 RocketMQ 平台。
你可以在 RocketMQ 官网 找到 RocketMQ 基于 STOMP 协议的快速入门文档,其中包括了使用 STOMP 协议发送和接收消息的示例代码。
下面是一个使用 Python 的示例:
import stomp
class MyListener(stomp.ConnectionListener):
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([('localhost', 61614)])
conn.set_listener('', MyListener())
conn.start()
conn.connect()
conn.send('/queue/test', 'hello')
conn.send('/queue/test', 'world')
conn.subscribe('/queue/test', id=1, ack='auto')
import time
time.sleep(2)
conn.disconnect()
在该示例中,我们使用了 Python 的 STOMP 客户端库 stomp.py,该库提供了与 stompit 类似的 API。你可以使用类似上面代码中的方式,通过 STOMP 协议在 Python 中发送和接收消息。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/