/** * Copyright 2016-2017 ZTE, Inc. and others. * * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except * in compliance with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software distributed under the License * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express * or implied. See the License for the specific language governing permissions and limitations under * the License. */ package org.onap.msb.sdclient.wrapper.util; import org.apache.commons.lang3.StringUtils; import org.onap.msb.sdclient.DiscoverAppConfig; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * @ClassName: ConfigUtil * @Description: TODO(服务发现配置项工具类) * @author tanghua10186366 * @date 2017年1月23日 * */ public class ConfigUtil { private static ConfigUtil instance = new ConfigUtil(); private ConfigUtil() {} public static ConfigUtil getInstance() { return instance; } private String tcpudpPortRangeStart = DiscoverUtil.TCP_UDP_PORT_RANGE_START; private String tcpudpPortRangeEnd = DiscoverUtil.TCP_UDP_PORT_RANGE_END; private String consulAddress = DiscoverUtil.CONSUL_ADDRESSS; private String consulRegisterMode = DiscoverUtil.CONSUL_REGISTER_MODE; private static final Logger LOGGER = LoggerFactory.getLogger(ConfigUtil.class); public void initConsulClientInfo(DiscoverAppConfig config) { String env_CONSUL_IP = System.getenv("CONSUL_IP"); if (StringUtils.isNotBlank(env_CONSUL_IP)) { String consul_port = DiscoverUtil.CONSUL_DEFAULT_PORT; try { consul_port = config.getConsulAdderss().split(":")[1]; } catch (Exception e) { LOGGER.error("initConsulClientInfo throw err:" + e.getMessage()); } consulAddress = env_CONSUL_IP + ":" + consul_port; } else if (StringUtils.isNotBlank(config.getConsulAdderss())) { { consulAddress = config.getConsulAdderss(); } LOGGER.info("init Discover CONSUL ADDRESSS:" + consulAddress); } } public void initTCP_UDP_portRange() { String env_TCP_UDP_PORT_RANGE_START = System.getenv("TCP_UDP_PORT_RANGE_START"); String env_TCP_UDP_PORT_RANGE_END = System.getenv("TCP_UDP_PORT_RANGE_END"); if (StringUtils.isNotBlank(env_TCP_UDP_PORT_RANGE_START)) { tcpudpPortRangeStart = env_TCP_UDP_PORT_RANGE_START; } if (StringUtils.isNotBlank(env_TCP_UDP_PORT_RANGE_END)) { tcpudpPortRangeEnd = env_TCP_UDP_PORT_RANGE_END; } LOGGER.info("init TCP_UDP portRange:" + tcpudpPortRangeStart + "-" + tcpudpPortRangeEnd); } public void initConsulRegisterMode(DiscoverAppConfig config) { String env_CONSUL_REGISTER_MODE = System.getenv("CONSUL_REGISTER_MODE"); if (StringUtils.isNotBlank(env_CONSUL_REGISTER_MODE)) { consulRegisterMode = env_CONSUL_REGISTER_MODE; } else { if (StringUtils.isNotBlank(config.getConsulRegisterMode())) { consulRegisterMode = config.getConsulRegisterMode(); } } LOGGER.info("init Consul Register Mode:" + consulRegisterMode); } public String getConsulAddress() { return consulAddress; } public String getTcpudpPortRangeStart() { return tcpudpPortRangeStart; } public String getTcpudpPortRangeEnd() { return tcpudpPortRangeEnd; } public String getConsulRegisterMode() { return consulRegisterMode; } }