rocketmq第三方库只支持mac和Linux，需注意！！
#*encoding=utf-8 from rocketmq.client import PullConsumer consumer = PullConsumer(‘CID_XXX‘) consumer.set_namesrv_addr(‘192.168.0.1:9876‘) consumer.start() while True: for msg in consumer.pull(‘msg-topic‘):print(msg.id, msg.body) consumer.shutdown()
原文：https://www.cnblogs.com/siyz/p/13055584.html