现象
容器化后，不同的RocketMQ的consumer部署在同一个容器。某开发小年轻和我说会导致client的InstanceName重复。
解决
查看代码
DefaultMQPushConsumerImpl#start
if (this.defaultMQPushConsumer.getMessageModel() == MessageModel.CLUSTERING) {
this.defaultMQPushConsumer.changeInstanceNameToPID();
}
public void changeInstanceNameToPID() {
if (this.instanceName.equals("DEFAULT")) {
this.instanceName = String.valueOf(UtilAll.getPid());
}
}
public static int getPid() {
RuntimeMXBean runtime = ManagementFactory.getRuntimeMXBean();
String name = runtime.getName(); // format: "pid@hostname"
try {
return Integer.parseInt(name.substring(0, name.indexOf('@')));
} catch (Exception e) {
return -1;
}
}
乍一看，发现还真的有问题，然后搜索官方issue
https://github.com/apache/rocketmq/issues/667
再看在docker环境下（使用host模式），获取到的clientIp和pid都是一样的。当然clientIp一样的确切原因还没完全确认
确认我们的docker模式，发现并没有使用host模式，所以没有问题。
这个故事告诉我们，遇到问题，还是要自己查一遍。
