/**\r
- * Copyright 2017-2020 ZTE Corporation.\r
+ * Copyright 2017-2021 ZTE Corporation.\r
* <p>\r
* Licensed under the Apache License, Version 2.0 (the "License");\r
* you may not use this file except in compliance with the License.\r
*/\r
package org.onap.holmes.common.config;\r
\r
+import com.google.gson.JsonArray;\r
import com.google.gson.JsonObject;\r
import com.google.gson.JsonParser;\r
import org.onap.holmes.common.constant.AlarmConst;\r
import javax.ws.rs.core.Response;\r
import java.util.regex.Pattern;\r
\r
+import static org.onap.holmes.common.utils.CommonUtils.getEnv;\r
+import static org.onap.holmes.common.utils.CommonUtils.isIpAddress;\r
+\r
public class MicroServiceConfig {\r
\r
final static public String CONSUL_ADDR_SUF = ":8500/v1/catalog/service/";\r
final static public String MSB_ADDR = "MSB_ADDR";\r
final static public String MSB_IAG_SERVICE_HOST = "MSB_IAG_SERVICE_HOST";\r
final static public String MSB_IAG_SERVICE_PORT = "MSB_IAG_SERVICE_PORT";\r
- final static public Pattern IP_REG = Pattern.compile("(http(s)?://)?(\\d+\\.\\d+\\.\\d+\\.\\d+)(:(\\d+))?");\r
+\r
final static public String AAI_HOSTNAME = "aai.onap";\r
\r
final static public Logger log = LoggerFactory.getLogger(MicroServiceConfig.class);\r
\r
- public static String getEnv(String name) {\r
- String value = System.getenv(name);\r
- if (value == null) {\r
- value = System.getProperty(name);\r
- }\r
- return value;\r
- }\r
-\r
public static String getConsulAddrInfo() {\r
return "http://" + getEnv(CONSUL_HOST) + CONSUL_ADDR_SUF;\r
}\r
String queryString = getConsulAddrInfo() + hostname;\r
log.info("Query the " + hostname + " address using the URL: " + queryString);\r
try {\r
- JsonObject addrJson = JsonParser.parseString(execQuery(queryString))\r
- .getAsJsonArray()\r
- .get(0)\r
- .getAsJsonObject();\r
- if (addrJson != null && addrJson.get("ServiceAddress") != null\r
- && addrJson.get("ServicePort") != null) {\r
- ret = "http://" + addrJson.get("ServiceAddress").getAsString() + ":" + addrJson\r
- .get("ServicePort").getAsString();\r
+ JsonArray addrArray = JsonParser.parseString(execQuery(queryString)).getAsJsonArray();\r
+ if (addrArray.size() > 0) {\r
+ JsonObject addrJson = addrArray.get(0).getAsJsonObject();\r
+ if (addrJson != null && addrJson.get("ServiceAddress") != null\r
+ && addrJson.get("ServicePort") != null) {\r
+ ret = "http://" + addrJson.get("ServiceAddress").getAsString() + ":" + addrJson\r
+ .get("ServicePort").getAsString();\r
+ }\r
+ } else {\r
+ log.info("No service info is returned from DCAE Consul. Hostname: {}", hostname);\r
}\r
} catch (Exception e) {\r
log.warn(e.getMessage(), e);\r
}\r
\r
public static String[] getMsbIpAndPort() {\r
- return new String[] {getEnv(MSB_IAG_SERVICE_HOST), getEnv(MSB_IAG_SERVICE_PORT)};\r
+ return new String[]{getEnv(MSB_IAG_SERVICE_HOST), getEnv(MSB_IAG_SERVICE_PORT)};\r
}\r
\r
public static String[] getMicroServiceIpAndPort() {\r
return serviceAddrInfo;\r
}\r
\r
- public static boolean isIpAddress(String info) {\r
- return IP_REG.matcher(info).matches();\r
- }\r
+\r
\r
private static String[] split(String addr) {\r
String ip;\r