RocketMQ异步报错:No route info of this topic

embedded/2024/10/22 14:25:07/

在SpringBoot中发送RocketMQ异步消息的时候报错了，提示org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, testTopic1
在这里插入图片描述
这里给出具体的解决方案

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

RocketMQ版本大于4.4.0的的话，autoCreateTopicEnable默认值为true，会自动创建topic。需要的话可以手动开启。位置在broker.properties文件里。新增下面这行配置

#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true

二、Broker模块没有正确连接到NAMESRV

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

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

cat ~/logs/rocketmqlogs/broker.log | grep register

出现如下内容说明连接成功，没有问题
在这里插入图片描述

2. 在mq的bin执行如下命令

sh mqadmin clusterList -n localhost:9876

出现如下内容说明连接成功，没有问题在这里插入图片描述

三、发送者没有连接到NAMESRV

第三种情况出现的最大可能是发送者和mq服务器之间的网络或端口不通，可以使用ping或者telnet确定问题。可能是防火墙或者安全组策略问题。

四、生产者提前被关闭

因为发送的是异步消息，所以存在异步消息还未得到响应前producer就被关闭的情况，遇到这种情况也会抛出这样的异常，最简单的解决方法是在producer关闭前让线程暂停几秒：
在这里插入图片描述