rocketmq安裝部署 ，運行避坑（python3）

按照rocketmq官網的快速入門，進行linux上的安裝：

　　快速入門 - Apache RocketMQ

避坑：

1、rocketmq可執行命令的路徑：

　　xx/xx/rocketmq/rocketmq-all-4.9.2/distribution/target/rocketmq-4.9.2/rocketmq-4.9.2/bin/

　　/xx/xx為下載rocketmq時的存放路徑

　　否則會報錯：

　　　　apache.xxx class noload 依賴的啟動類找不到

2、后台啟動namesrv和broker

　　nohup sh bin/mqnamesrv &

　　nohup sh bin/mqbroker &

　　使用默認的配置文件啟動broker，會導致mq服務只能在服務器本地連接，外部無法連接

　　producer發消息報錯：

　　　　rocketmq.exceptions.ProducerSendSyncFailed: No route info of this topic: xxx_topic,error:-1,in file rocketmq-client-cpp/src/producer/DefaultMQProducer.cpp line:379

　　解決方法：

　　　　1、指定配置文件/xx/xx/xx/xx/.../broker_me.conf， 在配置文件中添加以下配置：

　　　　　　namesrvAddr=本地外網IP:9876

　　　　　　brokerIP1=本地外網IP

　　　　　　使用該命令啟動：nohup sh bin/mqbroker -c /xx/xx/xx/xx/.../broker_me.conf &

　　　　2、服務器開放默認的namesrv端口9876、broker配置文件中的listenPort值（broker端口，默認為10911）

3、日志查看：

　　namesrv：tail -f ~/logs/rocketmqlogs/namesrv.log

　　broker：tail -f ~/logs/rocketmqlogs/broker.log

 

 

python3使用rocketmq庫進行生產和消費rocketmq:

　　producer：

# -*-coding:utf-8-*-
from rocketmq.client import Producer, Message

producer = Producer("producer_id")
producer.set_namesrv_addr("namesrvIP:9876")
producer.set_group("producer_group")
print("start")
producer.start()

def success(sendres):
    print("success")
    print(sendres)

def error(error_obj):
    print("error")
    print(error_obj.error)

msg = Message("xxx_topic")
msg.set_body("body_str")
# 異步發送
producer.send_async(msg, success, error)
# 同步發送
# ret = producer.send_sync(msg)
# print(ret)

producer.shutdown()
print("end...")

 

　　consumer：

# -*-coding:utf-8-*-
import time
from rocketmq.client import PushConsumer


def handle_message(msg):
    print(msg.id)
    print(msg.body)


consumer = PushConsumer("push_consumer_id")
consumer.set_namesrv_addr("namesrvIp:9876")
consumer.set_group("push_consumer_group")
consumer.subscribe("xxx_topic", handle_message)
print("start")
consumer.start()

while True:
    print("wait 5s")
    time.sleep(5)

#consumer.shutdown()
#print("end.")