private static void initConnectionInfo()

in java/e2e-v4/src/main/java/org/apache/rocketmq/frame/ResourceInit.java [100:127]


    private static void initConnectionInfo() {
        allIp = System.getenv("ALL_IP");
        if (allIp != null) {
            String[] allPodInfos = allIp.split(",");
            for (String podInfo : allPodInfos) {
                if (podInfo.contains("nameserver")) {
                    nameserverIpList.add(podInfo.substring(podInfo.indexOf(":") + 1));
                } else if (podInfo.contains("broker")) {
                    brokerIpList.add(podInfo.substring(podInfo.indexOf(":") + 1));
                }
            }
            if (nameserverIpList.isEmpty()) {
                log.warn("INIT- Get nameserver from external is empty");
                namesrvAddr = System.getProperty("namesrvAddr", properties.getProperty("namesrvAddr"));
            } else {
                namesrvAddr = nameserverIpList.get(0) + ":" + nameserverPort;
            }
        } else {
            log.info("INIT- Get ALL_IP is null, use local info");
            namesrvAddr = System.getProperty("namesrvAddr", properties.getProperty("namesrvAddr"));
        }
        cluster = System.getenv("cluster") != null ? System.getenv("cluster") : properties.getProperty("cluster");
        if (cluster == null) {
            log.error("INIT- cluster is null, system exit");
            System.exit(-1);
        }
        log.info("INIT- namesrvAddr:{}, cluster:{}", namesrvAddr, cluster);
    }