python Producer Consumer rocket

1. 生产数据

from rocketmq.client import Producer, Message

import argparse

def ProducerSend(body):
    accesskey = "testaccess"
    secretkey = "test123"
    gid = "GID_test"

    producer = Producer(gid)
    producer.set_namesrv_addr('127.0.0.1:9876')
    producer.set_session_credentials(accesskey, secretkey,'')
    producer.start()

 

    msg = Message('test')
    msg.set_body(body)
    ret = producer.send_sync(msg)
    print(ret.status, ret.msg_id, ret.offset)
    producer.shutdown()

2. 消费数据

import time

from rocketmq.client import PushConsumer


accesskey = "testaccess"
secretkey = "test123"

def callback(msg):
    print(msg.id, msg.body)


consumer = PushConsumer('GID_Lcrmcnn')
consumer.set_namesrv_addr('127.0.0.1:9876')
# consumer.set_session_credentials(accesskey, secretkey, '')
consumer.subscribe('lcrm_test', callback)
consumer.start()

while True:
    time.sleep(3600)

consumer.shutdown()