前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >【已解决】RocketMQ在发送消息的时候,提示:MQClientException: No route info of this topic

【已解决】RocketMQ在发送消息的时候,提示:MQClientException: No route info of this topic

作者头像
凯哥Java
发布于 2022-12-16 10:57:27
发布于 2022-12-16 10:57:27
4.4K00
代码可运行
举报
文章被收录于专栏:凯哥Java凯哥Java
运行总次数:0
代码可运行

RocketMQ在发送消息的时候,提示:MQClientException: No route info of this topic xxx

错误提示是说,没有xxx这个topic.

出现topic不存在,主要有以下三种情况导致的:

第一种:broker中真的没有xxx这个topic.

可能原因:Broker模块不支持自动创建topic,并且xxxtopic也没有被手动创建多

第二种:borker模块没有正确连接到NAMESRV

第三种:发送者没有连接到NAMESRV

知道了产生原因,我们就来解决办法:

第一种情况查看topic是否正的存在。可以登录rockermq控制台查看:

可以搜索topic。

或者查看broker的日志确定topic是否真的存在。

登录MQ所在的服务器机器上,执行如下命令(注意:把recommend换成你自己的topic名称)

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
cat ~/logs/rocketmqlogs/broker.log  | grep topicName=recommend

出现如下内容说明topic已经存在:

如果没有出现以上内容,说明topic确实不存在。可以通过自动创建topic或者手动创建topic解决问题。

自动创建topic:可以在启动broker启动脚本添加自动创建topic参数。或者在启动时候指定broker.conf配置文件中添加:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
autoCreateTopicEnable=true

表示自动创建topic.

或者手动创建topic。

手动创建topic的话,可以直接在控制台创建。凯哥就不演示了。

第二种情况出现的概率极低。可以采用以下两种方式确认

1. 查看broker的日志,出现如下内容,说明连接成功。

查看日志命令 cat ~/logs/rocketmqlogs/broker.log | grep register

2. 在mq的安装目录执行如下命令

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
mqadmin clusterList -n localhost:9876

出现如下内容说明连接成功,没有问题

第三种情况出现的最大可能是发送者和mq服务器之间的网络或端口不通,可以使用ping或者telnet确定问题。如果ping或者telnet连接不通,需要联系运维工程师开通网络或端口权限

凯哥遇到的是第一种情况,topic确实不存在,是通过手动创建topic解决的

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2022-10-19 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

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

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

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
本文部分代码块支持一键运行,欢迎体验
本文部分代码块支持一键运行,欢迎体验