使用Rocket MQ发送消息时报错 No route info of this topic， 详细错误信息如下：

com.aliyun.openservices.ons.api.exception.ONSClientException: defaultMQProducer send exception
	at com.aliyun.openservices.ons.api.impl.rocketmq.ProducerImpl.checkProducerException(ProducerImpl.java:238)
	at com.aliyun.openservices.ons.api.impl.rocketmq.ProducerImpl.send(ProducerImpl.java:132)
	at com.newcapec.mq.MqProducerService.main(MqProducerService.java:116)
Caused by: com.aliyun.openservices.shade.com.alibaba.rocketmq.client.exception.MQClientException: No route info of this topic, recommend
See http://rocketmq.apache.org/docs/faq/ for further details.
	at com.aliyun.openservices.shade.com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendDefaultImpl(DefaultMQProducerImpl.java:581)
	at com.aliyun.openservices.shade.com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1132)
	at com.aliyun.openservices.shade.com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:1086)
	at com.aliyun.openservices.shade.com.alibaba.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:257)
	at com.aliyun.openservices.ons.api.impl.rocketmq.ProducerImpl.send(ProducerImpl.java:123)
	... 1 more

 

出现上面的错误，主要有三种情况

第一种，Broker模块不支持自动创建topic，并且topic没有被手动创建过

第二种，Broker模块没有正确连接到NAMESRV

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

 

解决办法

第一种情况是topic确实不存在，可以查看broker的日志确定topic是否真的存在。

登录MQ所在的服务器，执行如下命令（把recommend换成你的topic名称）

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

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

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

 

自动创建topic：启动broker时加上自动创建topic的参数，如下，其中autoCreateTopicEnable=true表示自动创建topic

nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true > ../broker.log &

 

手动创建topic：进入mq的安装目录 ，执行如下命令创建topic。

mq安装的相对目录是rocketmq-all-4.4.0/distribution/target/apache-rocketmq/bin

以下命令创建了一个名称是orderPay的topic

sh mqadmin updateTopic -b localhost:10911 -t orderPay

 

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

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

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

2019-12-04 09:40:16 INFO brokerOutApi_thread_1 - register broker to name server localhost:9876 OK 2019-12-04 09:40:46 INFO brokerOutApi_thread_2 - register broker to name server localhost:9876 OK

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

sh mqadmin clusterList -n localhost:9876

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

 

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

 

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

---

扫码关注我的公众号

每天进步一点点，不负光阴，度几扶人