tongchenkeji
发表于：0次点击

rocketmq5.x只有tcp接入点吗，python sdk需要http接入点，请问怎么使用？[阿里云消息队列MQ]

rocketmq5.x创建只能选择tcp接入点

rocketmq5.x没有对应的python sdk

rocketmq4.x有python sdk，但是需要http endpoint

请问，使用python连接rocketmq5.x进行收发消息，有什么推荐的方法？

「点点赞赏，手留余香」

    还没有人赞赏，快来当第一个赞赏的人吧！
消息队列 MQ# Python483# 云消息队列 MQ1430# 开发工具825# 网络协议349
=====这是一个广告位，招租中，联系qq 78315851====
对象存储OSS
在使用OSS上传文件时，报了网络连接错误Connection pool shut down[阿里云oss]
阿里云云效
云效如何切换绑定的企业？[阿里云云效]
4 条回复 A 作者 M 管理员

  1. 在RocketMQ 5.x版本中,只提供了TCP接入点,而没有提供HTTP接入点。因此,如果使用的是RocketMQ 5.x,并且需要使用HTTP协议进行通信,那么需要自己实现一个HTTP客户端来连接RocketMQ。
    以下是使用Python连接RocketMQ 5.x的步骤:

    1. 安装RocketMQ客户端库:在Python环境中安装RocketMQ客户端库,可以使用pip命令进行安装:

    pip install rocketmq-client
    CopyCopy

    1. 创建消息生产者:使用RocketMQ客户端库创建一个消息生产者对象,用于发送消息。代码如下:

    producer = DefaultMQProducer(“producer_group”)
    producer.setNamesrvAddr(“127.0.0.1:9876”) # 设置NameServer地址
    producer.start()
    CopyCopy

    1. 发送消息:使用消息生产者对象发送消息。代码如下:

    message = Message(“TopicTest”, “TagA”, “Hello RocketMQ ” + str(i))
    producer.send(message)
    CopyCopy

    1. 创建消息消费者:使用RocketMQ客户端库创建一个消息消费者对象,用于接收消息。代码如下:

    consumer = DefaultMQPushConsumer(“consumer_group”)
    consumer.setNamesrvAddr(“127.0.0.1:9876”) # 设置NameServer地址
    consumer.subscribe(“TopicTest”, “*”) # 订阅主题和标签
    consumer.start()
    CopyCopy

    1. 接收消息:使用消息消费者对象接收消息。代码如下:

    while True:
    msg = consumer.receive()
    if msg:
    print(“Received message: ” + msg.getBody())
    else:
    continue
    CopyCopy

    在上面的代码中,需要注意以下几点:

    • 客户端需要设置NameServer地址,NameServer地址由RocketMQ管理员提供。
    • 生产者发送消息时,需要指定消息的主题和标签。
    • 消费者订阅主题和标签时,可以使用通配符“*”订阅所有标签。
    已喜欢 已反对

  2. 在使用Python发送接收RocketMQ消息时，你可以选择以下几种方式：

    1. 可靠同步发送：这种方式主要运用在比较重要一点消息传递/通知等业务。例如，public class SyncProducer { public static void main…。

    2. 可靠异步发送：这种方式适用于需要异步处理消息的场景。例如，你可以使用线程池或者协程池来实现异步发送消息。

    3. 单向发送：这种方式适用于只需要发送消息而不关心消息是否被成功接收的场景。例如，你可以使用Python的内置库socket来实现单向发送消息。

    对于RocketMQ5.x版本的Python SDK，目前官方并没有提供。你可以选择使用RocketMQ4.x版本的Python SDK，然后通过HTTP Endpoint连接到RocketMQ5.x的服务器。需要注意的是，这种方式可能会增加一些网络延迟。

    另外，你也可以考虑使用其他的消息队列中间件，如Kafka、RabbitMQ等，它们都有相应的Python SDK可以使用。

    已喜欢 已反对

  3. 根据您的描述，您可以考虑以下方案来使用Python连接到RocketMQ 5.x进行收发消息：

    1. 使用现有的Python SDK（如 rocketmq-client-python），并将其配置为通过TCP端点连接到RocketMQ 5.x。由于RocketMQ 5.x引入了新的Proxy组件以实现跨语言支持，并且该组件目前仅支持TCP协议，因此您可能需要编写一些额外的代码以适应这种变化。
    2. 自定义Python客户端来直接连接到RocketMQ Broker并通过TCP协议进行通信。这将需要您熟悉RocketMQ协议，并能够实现必要的编码和解码逻辑。此外，您还需要处理网络错误和其他异常情况。
    已喜欢 已反对