解决RocketMQ报No route info of this topic：异常

2022-02-23 12:54 931阅读 0赞

目前rocketmq 被使用的概率大大提升，相信很多朋友也都想着去试试，在测试的过程中根据官网给出的案例，应该有部分朋友遇到过这个异常： No route info of this topic，然后上网查询结果，我相信大部分人看到的结果都是让我们在启动mqbroker的时候需要指定autoCreateTopicEnable=true

nohup sh mqbroker -n 192.168.180.133:9876 **autoCreateTopicEnable=true** > ~/logs/rocketmqlogs/broker.log 2>&1 &

其实并非如此，因为在新的版本中，这个参数已经默认是true了，所以我们指定还是不指定都是一样的。

那么这个问题到底该如何解决呢？

其实产生这个问题的主要方式就是在测试异步消息发送的时候，当生产者还没来得及接收异步消息，而此时生产者就被关闭掉了就会出现这个错误，那么怎么解决呢，就是在生产者成功得到异步通知后在关闭即可。我们以官网给出的例子为例：

官网上的简单案例中，提到，rocketmq发送消息共有三种方式，分别是：可靠同步发送，可靠异步方式，单向发送

我们在测试异步方式的时候，如果你把代码原封不动粘贴运行，多半会出现这个问题，原因已经分析过了：那么如何 解决呢

public static void main(String[] args) throws Exception{
    		//Instantiate with a producer group name.
            DefaultMQProducer producer = new DefaultMQProducer("group");
            // Specify name server addresses.
            producer.setNamesrvAddr("192.168.1.12:9876");
            //Launch the instance.
            producer.start();
            producer.setRetryTimesWhenSendAsyncFailed(0);
            for (int i = 0; i < 10; i++) {
                    final int index = i;
                    //Create a message instance, specifying topic, tag and message body.
                    Message msg = new Message("TopicTest1",
                        "TagA",
                        "OrderID188",
                        "Hello world".getBytes(RemotingHelper.DEFAULT_CHARSET));
                    producer.send(msg, new SendCallback() {
                        @Override
                        public void onSuccess(SendResult sendResult) {
                            System.out.printf("%-10d OK %s %n", index,
                                sendResult.getMsgId());
                        }
                        @Override
                        public void onException(Throwable e) {
                            System.out.printf("%-10d Exception %s %n", index, e);
                            e.printStackTrace();
                        }
                    });
            }
            //Shut down once the producer instance is not longer in use.
            //producer.shutdown();
    	}

把producer.shutdown() 注释掉即可！！！