mzinfo/V2/tests/p.py

#!/usr/bin/python
# -*- coding=utf-8 -*-
# @Create Time:		2024-01-10 16:16:18
# @Last Modified time:2024-01-10 16:16:18
import sys, time
from rocketmq.client import Producer, Message

topicName = 'test'
groupName = 'log'
nameserver = 'localhost:9876'
KEYS = 'XXX'
TAGS = 'XXX'

def create_message():
    # 组装消息
    msg = Message(topicName)
    # 设置keys
    msg.set_tags(KEYS)
    # 设置tags
    msg.set_tags(TAGS)
    msg.set_property('property', 'test')
    # 消息内容
    msg.set_body('message body')
    return msg

def send_message_sync(count):
    # 初始化生产者，并设置生产组消息，组名称使用全称
    producer = Producer(groupName)
    # 设置服务器地址
    producer.set_name_server_address(nameserver)
    # 启动生产者
    producer.start()
    for n in range(count):
        msg = create_message()
        # 发送同步消息
        ret = producer.send_sync(msg)
        print(ret.status, ret.msg_id, ret.offset)
    # 资源释放
    producer.shutdown()

if __name__ == '__main__':
    send_message_sync(10)