python rocketmq

# Python RocketMQ 示例代码

from rocketmq.client import PushConsumer, ConsumeStatus

# 初始化消费者
consumer = PushConsumer('your_consumer_group')
consumer.set_name_server_address('127.0.0.1:9876')  # 设置NameServer地址

# 订阅主题
consumer.subscribe('your_topic', 'your_tag')

# 定义消息处理函数
def callback(msg):
    print(f"Receive message: {msg.body.decode('utf-8')}")
    return ConsumeStatus.CONSUME_SUCCESS

# 注册消息处理函数
consumer.register_message_callback(callback)

# 启动消费者
consumer.start()
print("Consumer started.")

# 停止消费者
# consumer.shutdown()

解释说明：

1. 导入模块：从 rocketmq.client 模块中导入 PushConsumer 和 ConsumeStatus。
2. 初始化消费者：创建一个 PushConsumer 实例，并设置消费者的组名。
3. 设置NameServer地址：通过 set_name_server_address 方法设置 RocketMQ 的 NameServer 地址。
4. 订阅主题：使用 subscribe 方法订阅指定的主题和标签。
5. 定义消息处理函数：定义一个回调函数 callback，用于处理接收到的消息。该函数接收消息对象 msg，并返回消费状态 ConsumeStatus.CONSUME_SUCCESS。
6. 注册消息处理函数：通过 register_message_callback 方法将回调函数注册到消费者。
7. 启动消费者：调用 start 方法启动消费者，开始监听消息。
8. 停止消费者：可以通过 shutdown 方法停止消费者（注释掉了，可以根据需要调用）。

希望这段代码对你有帮助！