kelvin

from rocketmq.client import Producer, Message # 创建消费者，指定groupid的名称 producer = Producer('PID-python') # 设置nameserver的地址 producer.set_namesrv_addr('172.16.154.100:9876') # 启动生产者 producer.start() for i in range(100): # 创建消息，指定topic msg = Message('test-topic4') msg.set_keys('t_key') msg.set_tags('t_tag') msg.set_body('t_body_' + str(i))...