求教大佬一个 RocketMQ 的神奇问题

一、问题

本地两台虚拟机搭建了双主双从集群，同步模式下，在客户端向 rockermq 集群发送异步消息，提示 org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, base2

二、背景

在自己的虚拟机上搭建了双主双从：

vm1: 192.168.234.134 master1 slave2

vm2: 192.168.234.139 master2 slave1

三、现象

网上教的指定 autoCreateTopicEnable=true 使用过了，没有作用

现象一：

在客户端发送异步消息，提示 org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, base2

但是使用 rocketmq-console 查看，集群中的 broker 都是正常的，且 base2 这个话题的确已经存在

现象二：

在 for 循环发消息时，加个 sleep 一秒，消息发送就正常了

客户端代码：

public static void main(String[] args) throws Exception {
    // 实例化消息生产者 Producer
    DefaultMQProducer producer = new DefaultMQProducer("group1");
    // 指定 Nameserver 地址
    producer.setSendMsgTimeout(6000);
    producer.setVipChannelEnabled(false);
    producer.setNamesrvAddr("192.168.234.134:9876;192.168.234.139:9876");
    // 启动 Producer 实例
    producer.start();
    producer.setRetryTimesWhenSendAsyncFailed(0);


    for (int i = 0; i < 3; i++) {
        final int index = i;
        // 创建消息，并指定 Topic，Tag 和消息体
        Message msg = new Message("base2", "Tag1", ("Hello World" + i).getBytes());
        producer.send(msg, new SendCallback() {
            public void onSuccess(SendResult sendResult) {
                System.out.println("发送结果：" + sendResult);
            }

            public void onException(Throwable e) {
                System.out.println("发送异常：" + e);
            }
        });
		// 睡眠一秒
        TimeUnit.MILLISECONDS.sleep(1000);
    }
    // 如果不再发送消息，关闭 Producer 实例。
    producer.shutdown();

    while (true){}
}