前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >初识 RocketMQ,一般人都会犯这样的错误,趁早提前避免

初识 RocketMQ,一般人都会犯这样的错误,趁早提前避免

作者头像
猿芯
发布2021-03-22 11:30:57
4180
发布2021-03-22 11:30:57
举报
文章被收录于专栏:Wooola的技术博客

背景

producer 发消息时,报 No route info of this topic 错误:

代码语言:javascript
复制
org.apache.rocketmq.client.exception.MQClientException: No route info of this topic
See http://rocketmq.apache.org/docs/faq/ for further details.
        at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:662) ~[rocketmq-client-4.5.2.jar!/:4.5.2]
        at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.access$300(DefaultMQProducerImpl.java:90) ~[rocketmq-client-4.5.2.jar!/:4.5.2]
        at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl$3.run(DefaultMQProducerImpl.java:491) ~[rocketmq-client-4.5.2.jar!/:4.5.2]
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_262]
        at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_262]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_262]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_262]
        at java.lang.Thread.run(Thread.java:748) [na:1.8.0_262]

这个错误网上说是由于 Broker 未启用自动创建 Topic 开关造成的,解决办法是在启动 Broker 时指定 autoCreateTopicEnable=true 即可。

例如:

代码语言:javascript
复制
  nohup sh mqbroker -n xxxip:9876  autoCreateTopicEnable=true 

其实这个说法并不靠谱,即使配置了autoCreateTopicEnable=true 还是会报这个错误,其实还有别的原因也有可能报 No route info of this topic 错误。问题原因出在使用 sh mqbroker -n xxxip:9876 启动 mqborker 时候,如果 xxip 是内网 IP,否则也会报 No route info of this topic 错误。

所以解决办法就是把 xxip 改成 公网IP即可,修改方式有两种:1、在 sh mqbroker 命令指定

代码语言:javascript
复制
nohup sh bin/mqbroker -n 公网IP:9876  autoCreateTopicEnable=true &

2、在 conf/broker.conf 中 加入 brokerIP1=公网IP 以及 autoCreateTopicEnable=true

代码语言:javascript
复制
brokerIP1=公网IP
autoCreateTopicEnable=true

推荐完整命令

  • 启动 mqnamesrv
代码语言:javascript
复制
nohup sh /app/rocketmq-4.8.0/bin/mqnamesrv & 
  • 启动 mqbroker
代码语言:javascript
复制
nohup sh /app/rocketmq-4.8.0/bin/mqbroker -c /app/rocketmq-4.8.0/conf/broker.conf &

作者简介:编筐少年,一枚简单的北漂程序员。喜欢用简单的文字记录工作与生活中的点点滴滴,愿与你一起分享程序员灵魂深处真正的内心独白。我的微信号:WooolaDunzung,公众号【猿芯】输入 1024 ,有份惊喜送给你哦。

喜欢就点个"在看"呗^_^

本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2021-03-11,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 架构荟萃 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 背景
  • 推荐完整命令
相关产品与服务
弹性公网 IP
弹性公网 IP(Elastic IP,EIP)是可以独立购买和持有,且在某个地域下固定不变的公网 IP 地址,可以与 CVM、NAT 网关、弹性网卡和高可用虚拟 IP 等云资源绑定,提供访问公网和被公网访问能力;还可与云资源的生命周期解耦合,单独进行操作;同时提供多种计费模式,您可以根据业务特点灵活选择,以降低公网成本。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档