标签：producer broker 避坑 xx python3 print consumer rocketmq

按照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：

 1 # -*-coding:utf-8-*-
 2 from rocketmq.client import Producer, Message
 3 
 4 producer = Producer("producer_id")
 5 producer.set_namesrv_addr("namesrvIP:9876")
 6 producer.set_group("producer_group")
 7 print("start")
 8 producer.start()
 9 
10 def success(sendres):
11     print("success")
12     print(sendres)
13 
14 def error(error_obj):
15     print("error")
16     print(error_obj.error)
17 
18 msg = Message("xxx_topic")
19 msg.set_body("body_str")
20 # 异步发送
21 producer.send_async(msg, success, error)
22 # 同步发送
23 # ret = producer.send_sync(msg)
24 # print(ret)
25 
26 producer.shutdown()
27 print("end...")

 

　　consumer：

 1 # -*-coding:utf-8-*-
 2 import time
 3 from rocketmq.client import PushConsumer
 4 
 5 
 6 def handle_message(msg):
 7     print(msg.id)
 8     print(msg.body)
 9 
10 
11 consumer = PushConsumer("push_consumer_id")
12 consumer.set_namesrv_addr("namesrvIp:9876")
13 consumer.set_group("push_consumer_group")
14 consumer.subscribe("xxx_topic", handle_message)
15 print("start")
16 consumer.start()
17 
18 while True:
19     print("wait 5s")
20     time.sleep(5)
21 
22 #consumer.shutdown()
23 #print("end.")

 

　　　　

　　

标签：producer,broker,避坑,xx,python3,print,consumer,rocketmq
来源： https://www.cnblogs.com/tec-dream/p/15817670.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。