报错描述:
我是在windows上使用RocketMQ,环境配置,文件配置,MQ启动,一系列操作都成功后,然后在项目中使用MQ的时候报了这个错!!!
问题分析
出现这个报错无非就六大毛病,如下:
- 配置autoCreateTopicEnable=true,如果这个属性没有配置,且你没有手动创建topic,就会报出上面的异常信息No route info of this topic也就是Broker禁止自动创建Topic,且用户没有通过手工方式创建Topic。
- Producer没有正确连接到Name Server
- Broker没有正确连接到Name Server
- Windwos下mq的安装版本和pom.xml中使用的jar包版本不对
- 缺少fastjson包或者fastjson包版本不对
- 防火墙未关闭问题
解决方案:
我在上面六大毛病中,是第一条的问题。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文件。问题解决!!!
最好祝大家生活愉快!!!