The producer group has been created before
编写一个help类
public class RunTimeUtil {
private static AtomicInteger index = new AtomicInteger();
public static int getPid() {
String info = getRunTimeInfo();
int pid = (new Random()).nextInt();
int index = info.indexOf("@");
if(index > 0) {
pid = Integer.parseInt(info.substring(0, index));
}
return pid;
}
public static String getRunTimeInfo() {
RuntimeMXBean runtime = ManagementFactory.getRuntimeMXBean();
String info = runtime.getName();
return info;
}
public static String getRocketMqUniqeInstanceName() {
return "pid" + getPid() + "_index" + index.incrementAndGet();
}
}
consumer.setInstanceName(RunTimeUtil.getRocketMqUniqeInstanceName());
即可解决上述问题
编写一个help类 public class RunTimeUtil { private static AtomicInteger index = new AtomicInteger(); public static int getPid() { String info = getRunTimeInfo(); int pid = (new Random()).nextInt(); int index = info.indexOf("@"); if(index > 0) { pid = Integer.parseInt(info.substring(0, index)); } return pid; } public static String getRunTimeInfo() { RuntimeMXBean runtime = ManagementFactory.getRuntimeMXBean(); String info = runtime.getName(); return info; } public static String getRocketMqUniqeInstanceName() { return "pid" + getPid() + "_index" + index.incrementAndGet(); } } consumer.setInstanceName(RunTimeUtil.getRocketMqUniqeInstanceName()); 即可解决上述问题