当前位置：首页 > news >正文

RocketMQ疑难杂症之No route info of this topic解决方案

news 来源：原创 2024/9/20 9:32:33

成因：
由于配置了 docker 虚拟 IP，导致 brocker 总是代理到 docker 的虚拟 IP 上。

原理：
RocketMQ 的 broker 启动类
org.apache.rocketmq.broker.BrokerStartup
启动的时候会读取代码中的默认配置，关于 broker 的配置在
org.apache.rocketmq.common.BrokerConfig
中，根据源代码可以得知，broker 使用的默认 IP 为本机 IP
brokerIP1 = RemotingUtil.getLocalAddress();
得到选取 IP 的思路是，遍历本地的所有网卡 IP，过滤掉 "127.0" 和 "192.168" 开头的 IP 地址，然后得到第一个 IP，为本机 IP。

问题：
当这台机器有很多别的网卡（如：安装 docker 后），broker 使用的 IP，就可能会导致我们的客户端无法连接。

方案：
强制绑定服务器IP地址：System.getProperty("DUBBO_IP_TO_BIND")

// 创建生产者，指定所属的生产者组名
DefaultMQProducer producer = new DefaultMQProducer(mqConfig.getGroup());
// 指定NameServer的地址
producer.setNamesrvAddr(apacheMqConfig.getNamesrvAddr());
//强制绑定服务器IP地址
if (ObjectUtil.isNotEmpty(System.getProperty("DUBBO_IP_TO_BIND"))) {
    producer.setClientIP(System.getProperty("DUBBO_IP_TO_BIND"));
}

// 创建消费者，指定所属的消费者组名
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(mqConfig.getGroup());
// 指定NameServer的地址
consumer.setNamesrvAddr(mqConfig.getNamesrvAddr());
//强制绑定服务器IP地址
if (ObjectUtil.isNotEmpty(System.getProperty("DUBBO_IP_TO_BIND"))) {
    consumer.setClientIP(System.getProperty("DUBBO_IP_TO_BIND"));
}

备注：DUBBO_IP_TO_BIND 是 jar 包启动时获取到的服务器 IP