报错描述:

我是在windows上使用RocketMQ,环境配置,文件配置,MQ启动,一系列操作都成功后,然后在项目中使用MQ的时候报了这个错!!!


问题分析

出现这个报错无非就六大毛病,如下:

  1. 配置autoCreateTopicEnable=true,如果这个属性没有配置,且你没有手动创建topic,就会报出上面的异常信息No route info of this topic也就是Broker禁止自动创建Topic,且用户没有通过手工方式创建Topic。
  2. Producer没有正确连接到Name Server
  3. Broker没有正确连接到Name Server
  4. Windwos下mq的安装版本和pom.xml中使用的jar包版本不对
  5. 缺少fastjson包或者fastjson包版本不对
  6. 防火墙未关闭问题

解决方案:

我在上面六大毛病中,是第一条的问题。Broker禁止自动创建Topic,并且用户没有通过手工方式创建Topic。所以我主要解决是在启动MQ的时候,加上autoCreateTopicEnable=true即可。

说明:因为我是在windows上安装的RocketMQ,所以在RocketMQ安装目录找到bin目录。

在bin目录下创建两个启动文件,一个名为MqNameServe.bat,一个名为MqBroker.bat。

MqNameServe.bat文件内容如下:

start mqnamesrv.cmd

MqBroker.bat文件内容如下:

start mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true

然后先启动MqNameServe.bat文件在启动MqBroker.bat文件。问题解决!!!

最好祝大家生活愉快!!!