五莲网站建设维护推广学子网站建设

在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关闭前让线程暂停几秒：