成因:
由于配置了 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