#!/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)