工作小总结&小工具类 Redis AI相关 MQTT Maven mybatis ChatGPT uniapp zookeeper Thymeleaf语法 POI-TL sa-token PowerDesigner16.5 taos数据库 frp echarts Actor模型及Akka thingsboard 大疆无人机对接 CI/CD 教师资格证小任务面试其他职场淘宝客支付宝支付 HBuilder X Flink Java集合类多线程 ES Ribbon eureka Docker java游戏网络通信 Nacos 芋道管理系统 Solr 分布式相关 Dubbo 数据结构 EasyPOI Drools RocketMQ JS 七天深入MySQL实战营书籍 kafka spring Java基础 java web 若依(ruoyi) 分布式事务面试宝典 mysql java8新特性 spring cloud ElasticSearch学习系列 HM_leadnews 即时通讯并发思维&学习 VUE 宝塔面板算法刷题设计模式 RabbitMQ学习系列教程 P3C规范 JVM学习系列反射自定义注解网络美文 PHP源码经验分享资源 git项目 websocket 网赚数据库读写分离测试相关其他随笔 shiro学习系列 fremarker学习系列学习笔录-spring boot 网络文章工作小总结

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

🔔🔔🔔好消息!好消息!🔔🔔🔔

有需要的朋友👉:联系凯哥微信号 kaigejava2022

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名称)

cat ~/logs/rocketmqlogs/broker.log  | grep topicName=recommend

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

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

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

autoCreateTopicEnable=true

表示自动创建topic.

或者手动创建topic。

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

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

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

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

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

mqadmin clusterList -n localhost:9876

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

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

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