/*******************************************************************************
* 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
+ * 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
+ * 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.
+ * 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.apiroute.wrapper;
-import io.dropwizard.jetty.HttpConnectorFactory;
-import io.dropwizard.server.SimpleServerFactory;
-
-import java.io.BufferedWriter;
import java.io.File;
import java.io.FileNotFoundException;
-import java.io.FileOutputStream;
import java.io.IOException;
-import java.io.OutputStreamWriter;
import java.net.URL;
import java.util.List;
import org.apache.commons.lang3.StringUtils;
-import org.onap.msb.apiroute.ApiRouteApp;
import org.onap.msb.apiroute.ApiRouteAppConfig;
import org.onap.msb.apiroute.SyncDataManager;
import org.onap.msb.apiroute.api.ApiRouteInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import redis.clients.jedis.Jedis;
-
import com.fasterxml.jackson.core.type.TypeReference;
+import io.dropwizard.jetty.HttpConnectorFactory;
+import io.dropwizard.server.SimpleServerFactory;
+import redis.clients.jedis.Jedis;
+
public class InitRouteServiceWrapper {
- private static final Logger LOGGER = LoggerFactory.getLogger(InitRouteServiceWrapper.class);
+ private static final Logger LOGGER = LoggerFactory.getLogger(InitRouteServiceWrapper.class);
- private static InitRouteServiceWrapper instance = new InitRouteServiceWrapper();
+ private static InitRouteServiceWrapper instance = new InitRouteServiceWrapper();
- private InitRouteServiceWrapper() {}
+ private InitRouteServiceWrapper() {}
- public static InitRouteServiceWrapper getInstance() {
- return instance;
- }
+ public static InitRouteServiceWrapper getInstance() {
+ return instance;
+ }
- /**
- * The listener registration service changes
- */
- public void registerServiceChangeListener() {
+ /**
+ * The listener registration service changes
+ */
+ public void registerServiceChangeListener() {
- RouteNotify.getInstance().addServiceChangeListener(new MicroServiceChangeListener());
+ RouteNotify.getInstance().addServiceChangeListener(new MicroServiceChangeListener());
- }
-
- public void initFilterConfig(){
- //route init
- ConfigUtil.getInstance().initRouteWay();
- ConfigUtil.getInstance().initApiGatewayPort();
- ConfigUtil.getInstance().initRouteNameSpaceMatches();
- ConfigUtil.getInstance().initRouteLabelsMatches();
- ConfigUtil.getInstance().initNodeMetaQueryParam();
-
- }
-
- public void initDataSynchro(){
-
- registerServiceChangeListener();
+ }
- boolean ifRedisConnect=startCheckRedisConnect();
+ public void initFilterConfig() {
+ // route init
+ ConfigUtil.getInstance().initRouteWay();
+ ConfigUtil.getInstance().initApiGatewayPort();
+ ConfigUtil.getInstance().initRouteNameSpaceMatches();
+ ConfigUtil.getInstance().initRouteLabelsMatches();
+ ConfigUtil.getInstance().initNodeMetaQueryParam();
- if(ifRedisConnect){
- initRouteInfoFromJson();
- runConsulClientApp();
}
- }
-
- public void initHealthCheck()
- {
- LOGGER.info("start check consul link thread");
- Thread tConsul= new Thread(new ConsulLinkHealthCheck(),"_healthcheck_consul_");
- tConsul.setDaemon(true);
- tConsul.start();
-
- LOGGER.info("start check redis thread");
- Thread tRedies= new Thread(new RedisHealthCheck(),"_healthcheck_redis_");
- tRedies.setDaemon(true);
- tRedies.start();
- }
+ public void initDataSynchro() {
+
+ registerServiceChangeListener();
+
+ boolean ifRedisConnect = startCheckRedisConnect();
+ if (ifRedisConnect) {
+ initRouteInfoFromJson();
+ runConsulClientApp();
+ }
+ }
+ public void initHealthCheck() {
+ LOGGER.info("start check consul link thread");
+ Thread tConsul = new Thread(new ConsulLinkHealthCheck(), "_healthcheck_consul_");
+ tConsul.setDaemon(true);
+ tConsul.start();
+
+ LOGGER.info("start check redis thread");
+ Thread tRedies = new Thread(new RedisHealthCheck(), "_healthcheck_redis_");
+ tRedies.setDaemon(true);
+ tRedies.start();
+ }
- public boolean startCheckRedisConnect() {
+
+
+ public boolean startCheckRedisConnect() {
int n = 0;
while (true) {
- if (!checkRedisConnect()) {
- n++;
- LOGGER.warn(n + "/10 : Initial Route Configuration——redis connection fail...");
-
- try {
- Thread.sleep(10000);
- } catch (InterruptedException e) {
- LOGGER.error("Thread.sleep throw except:" + e.getMessage());
- }
+ if (!checkRedisConnect()) {
+ n++;
+ LOGGER.warn(n + "/10 : Initial Route Configuration——redis connection fail...");
+
+ try {
+ Thread.sleep(10000);
+ } catch (InterruptedException e) {
+ LOGGER.error("Thread.sleep throw except:" + e.getMessage());
+ }
- if (n >= 10) {
- LOGGER.error("Initial Route Configuration——redis connection fail,timeout exit...");
- return false;
+ if (n >= 10) {
+ LOGGER.error("Initial Route Configuration——redis connection fail,timeout exit...");
+ return false;
+ }
+ } else {
+ LOGGER.warn(" Initial Route Configuration——redis connection success...");
+ return true;
}
- } else {
- LOGGER.warn(" Initial Route Configuration——redis connection success...");
- return true;
- }
}
-
- }
-
-
- // Open the consul to monitor subscription service
- public void runConsulClientApp() {
-
- String consulIP;
- int consulPort;
- String consulConfSource="Default";
-
-
- DiscoverInfo discoverInfo = ConfigUtil.getInstance().getDiscoverInfo();
-
- if (discoverInfo.isEnabled()) {
- LOGGER.warn("starting to initial consul Configuration");
- String[] routeWay = ConfigUtil.getInstance().getRouteWay();
- try {
- String sys_consulIp=ConfigUtil.getInstance().getConsul_ip();
- if (StringUtils.isNotBlank(sys_consulIp)) {
- consulIP = sys_consulIp.trim();
- consulPort = RouteUtil.consulDeafultPort;
- consulConfSource="env:CONSUL_IP";
- } else {
- consulIP = discoverInfo.getIp();
- consulPort = discoverInfo.getPort();
- consulConfSource="init discoverInfo";
- }
- LOGGER.warn("init consul sync Address from [ "+consulConfSource+" ]:" + consulIP + ":" + consulPort);
+ }
- // Registration service discovery routing
- // api
- ApiRouteInfo discoverApiService = new ApiRouteInfo();
- discoverApiService.setServiceName("msdiscover");
- discoverApiService.setUrl("/api/microservices/v1");
- discoverApiService.setVersion("v1");
- discoverApiService.setMetricsUrl("/admin/metrics");
- discoverApiService.setApiJson("/api/microservices/v1/swagger.json");
- discoverApiService.setHost("msb");
- RouteServer[] servers = new RouteServer[1];
- servers[0] = new RouteServer(discoverInfo.getIp(), String.valueOf(discoverInfo.getPort()));
- discoverApiService.setServers(servers);
+ // Open the consul to monitor subscription service
+ public void runConsulClientApp() {
+ String consulIP;
+ int consulPort;
+ String consulConfSource = "Default";
- for (int i = 0; i < routeWay.length; i++) {
- ApiRouteServiceWrapper.getInstance().saveApiRouteInstance4Rest(discoverApiService,
- routeWay[i]);
- }
+ DiscoverInfo discoverInfo = ConfigUtil.getInstance().getDiscoverInfo();
+ if (discoverInfo.isEnabled()) {
+ LOGGER.warn("starting to initial consul Configuration");
+ String[] routeWay = ConfigUtil.getInstance().getRouteWay();
+ try {
+ String sys_consulIp = ConfigUtil.getInstance().getConsul_ip();
+ if (StringUtils.isNotBlank(sys_consulIp)) {
+ consulIP = sys_consulIp.trim();
+ consulPort = RouteUtil.consulDeafultPort;
+ consulConfSource = "env:CONSUL_IP";
+ } else {
+ consulIP = discoverInfo.getIp();
+ consulPort = discoverInfo.getPort();
+ consulConfSource = "init discoverInfo";
+ }
- // iui
- IuiRouteInfo discoverIUIService = new IuiRouteInfo();
- discoverIUIService.setServiceName("msdiscover");
- discoverIUIService.setUrl("/iui/microservices");
- discoverIUIService.setHost("msb");
- discoverIUIService.setServers(servers);
+ LOGGER.warn("init consul sync Address from [ " + consulConfSource + " ]:" + consulIP + ":"
+ + consulPort);
- for (int i = 0; i < routeWay.length; i++) {
- IuiRouteServiceWrapper.getInstance()
- .saveIuiRouteInstance(discoverIUIService, routeWay[i]);
- }
+ // Registration service discovery routing
+ // api
+ ApiRouteInfo discoverApiService = new ApiRouteInfo();
+ discoverApiService.setServiceName("msdiscover");
+ discoverApiService.setUrl("/api/microservices/v1");
+ discoverApiService.setVersion("v1");
+ discoverApiService.setMetricsUrl("/admin/metrics");
+ discoverApiService.setApiJson("/api/microservices/v1/swagger.json");
+ discoverApiService.setHost("msb");
+ RouteServer[] servers = new RouteServer[1];
+ servers[0] = new RouteServer(discoverInfo.getIp(), String.valueOf(discoverInfo.getPort()));
+ discoverApiService.setServers(servers);
- /*
- * ConsulClientApp consulClientApp = new ConsulClientApp(consulIP, consulPort);
- * consulClientApp.startServiceListen();
- */
- // SyncDataManager syncDataManager = new SyncDataManager();
- // Monitor serviceList change
- SyncDataManager.initSyncTask(consulIP, consulPort);
+ for (int i = 0; i < routeWay.length; i++) {
+ ApiRouteServiceWrapper.getInstance().saveApiRouteInstance4Rest(discoverApiService, routeWay[i]);
+ }
- LOGGER.warn("start monitor consul service--" + consulIP + ":" + consulPort);
- } catch (Exception e) {
- LOGGER.error("start monitor consul service fail:" + e.getMessage());
- }
- }
-
+ // iui
+ IuiRouteInfo discoverIUIService = new IuiRouteInfo();
+ discoverIUIService.setServiceName("msdiscover");
+ discoverIUIService.setUrl("/iui/microservices");
+ discoverIUIService.setHost("msb");
+ discoverIUIService.setServers(servers);
- }
+ for (int i = 0; i < routeWay.length; i++) {
+ IuiRouteServiceWrapper.getInstance().saveIuiRouteInstance(discoverIUIService, routeWay[i]);
+ }
+ /*
+ * ConsulClientApp consulClientApp = new ConsulClientApp(consulIP, consulPort);
+ * consulClientApp.startServiceListen();
+ */
- /**
- * @Title: initRouteInfoFromJson
- * @Description: TODO(According to the JSON file configuration initialization route data)
- * @return: void
- */
- public void initRouteInfoFromJson() {
- LOGGER.info("starting to initial Route Configuration");
- URL apiDocsPath = InitRouteServiceWrapper.class.getResource("/ext/initServices");
- if (apiDocsPath != null) {
- String path = apiDocsPath.getPath();
+ // SyncDataManager syncDataManager = new SyncDataManager();
+ // Monitor serviceList change
+ SyncDataManager.initSyncTask(consulIP, consulPort);
- LOGGER.info("read JsonFilefolder:" + path);
- try {
- File[] files = FileUtil.readFileFolder(path);
- for (int i = 0; i < files.length; i++) {
- File file = files[i];
- if (file.isFile() && file.getName().endsWith(".json")) {
- LOGGER.info("read JsonFile:" + file.getPath());
- String fileContent = FileUtil.readFile(file.getPath());
- saveInitService2redis(fileContent);
- } else {
- LOGGER.warn(file.getName() + " is not a right file");
- }
+ LOGGER.warn("start monitor consul service--" + consulIP + ":" + consulPort);
+ } catch (Exception e) {
+ LOGGER.error("start monitor consul service fail:" + e.getMessage());
+ }
}
- } catch (FileNotFoundException e) {
- // TODO Auto-generated catch block
- LOGGER.error("read initServices Files throw FileNotFoundException", e);
- } catch (IOException e) {
- // TODO Auto-generated catch block
- LOGGER.error("read initServices Files throw IOexception", e);
- }
+ }
+
+
+
+ /**
+ * @Title: initRouteInfoFromJson
+ * @Description: TODO(According to the JSON file configuration initialization route data)
+ * @return: void
+ */
+ public void initRouteInfoFromJson() {
+ LOGGER.info("starting to initial Route Configuration");
+ URL apiDocsPath = InitRouteServiceWrapper.class.getResource("/ext/initServices");
+ if (apiDocsPath != null) {
+ String path = apiDocsPath.getPath();
+
+ LOGGER.info("read JsonFilefolder:" + path);
+
+ try {
+ File[] files = FileUtil.readFileFolder(path);
+ for (int i = 0; i < files.length; i++) {
+ File file = files[i];
+ if (file.isFile() && file.getName().endsWith(".json")) {
+ LOGGER.info("read JsonFile:" + file.getPath());
+ String fileContent = FileUtil.readFile(file.getPath());
+ saveInitService2redis(fileContent);
+ } else {
+ LOGGER.warn(file.getName() + " is not a right file");
+ }
+ }
+
+
+
+ } catch (FileNotFoundException e) {
+ // TODO Auto-generated catch block
+ LOGGER.error("read initServices Files throw FileNotFoundException", e);
+ } catch (IOException e) {
+ // TODO Auto-generated catch block
+ LOGGER.error("read initServices Files throw IOexception", e);
+ }
+
+ }
+
+
}
- }
+ private void saveInitService2redis(String fileContent) {
+ String[] routeWay = ConfigUtil.getInstance().getRouteWay();
+ String iuiRootPath = ConfigUtil.getInstance().getIUI_ROOT_PATH();
+ try {
+ List<ApiRouteInfo> routeList =
+ JacksonJsonUtil.jsonToListBean(fileContent, new TypeReference<List<ApiRouteInfo>>() {});
+ for (ApiRouteInfo route : routeList) {
+ String url = route.getUrl();
- private void saveInitService2redis(String fileContent) {
+ if (RegExpTestUtil.urlRegExpTest(route.getServiceName())) {
- String[] routeWay = ConfigUtil.getInstance().getRouteWay();
- String iuiRootPath = ConfigUtil.getInstance().getIUI_ROOT_PATH();
+ for (int i = 0; i < routeWay.length; i++) {
+ try {
- try {
- List<ApiRouteInfo> routeList =
- JacksonJsonUtil.jsonToListBean(fileContent, new TypeReference<List<ApiRouteInfo>>() {});
- for (ApiRouteInfo route : routeList) {
- String url = route.getUrl();
+ CustomRouteServiceWrapper.getInstance().getCustomRouteInstance(route.getServiceName(),
+ route.getHost(), "", routeWay[i]);
- if (RegExpTestUtil.urlRegExpTest(route.getServiceName())) {
+ } catch (ExtendedNotFoundException e) {
- for (int i = 0; i < routeWay.length; i++) {
- try {
+ LOGGER.info("initCustomRoute: ServiceName--" + route.getServiceName());
- CustomRouteServiceWrapper.getInstance().getCustomRouteInstance(
- route.getServiceName(), route.getHost(), "", routeWay[i]);
+ CustomRouteInfo customRouteInfo = new CustomRouteInfo();
+ customRouteInfo.setControl(route.getControl());
+ customRouteInfo.setServers(route.getServers());
+ customRouteInfo.setServiceName(route.getServiceName());
+ customRouteInfo.setStatus(route.getStatus());
+ customRouteInfo.setUrl(route.getUrl());
+ customRouteInfo.setHost(route.getHost());
- } catch (ExtendedNotFoundException e) {
- LOGGER.info("initCustomRoute: ServiceName--" + route.getServiceName());
- CustomRouteInfo customRouteInfo = new CustomRouteInfo();
- customRouteInfo.setControl(route.getControl());
- customRouteInfo.setServers(route.getServers());
- customRouteInfo.setServiceName(route.getServiceName());
- customRouteInfo.setStatus(route.getStatus());
- customRouteInfo.setUrl(route.getUrl());
- customRouteInfo.setHost(route.getHost());
+ CustomRouteServiceWrapper.getInstance().saveCustomRouteInstance(customRouteInfo,
+ routeWay[i]);
+ }
+ }
+ } else {
+ if (RegExpTestUtil.apiRouteUrlRegExpTest(url) || url.startsWith("/api/microservices/")
+ || url.startsWith("/admin/microservices/")) {
- CustomRouteServiceWrapper.getInstance().saveCustomRouteInstance(customRouteInfo,
- routeWay[i]);
+ for (int i = 0; i < routeWay.length; i++) {
+ try {
- }
- }
- } else {
+ ApiRouteServiceWrapper.getInstance().getApiRouteInstance(route.getServiceName(),
+ route.getVersion(), route.getHost(), route.getPublish_port(),
+ routeWay[i]);
- if (RegExpTestUtil.apiRouteUrlRegExpTest(url) || url.startsWith("/api/microservices/") || url.startsWith("/admin/microservices/")) {
+ } catch (ExtendedNotFoundException e) {
+ LOGGER.info("initapiRoute: ServiceName--" + route.getServiceName());
- for (int i = 0; i < routeWay.length; i++) {
- try {
+ if (url.startsWith("/api/microservices")) {
+ if (StringUtils.isNotBlank(System.getenv("dwApp_server_connector_port"))) {
+ replaceApigatewayPort(route.getServers(),
+ System.getenv("dwApp_server_connector_port"));
+ }
+ }
- ApiRouteServiceWrapper.getInstance().getApiRouteInstance(route.getServiceName(),
- route.getVersion(), route.getHost(), route.getPublish_port(), routeWay[i]);
+ if (url.startsWith("/admin/microservices")) {
+ replaceApigatewayPort(route.getServers(), ConfigUtil.getInstance().getServerPort());
+ }
- } catch (ExtendedNotFoundException e) {
- LOGGER.info("initapiRoute: ServiceName--" + route.getServiceName());
+ ApiRouteServiceWrapper.getInstance().saveApiRouteInstance4Rest(route, routeWay[i]);
- if (url.startsWith("/api/microservices")) {
- if (StringUtils.isNotBlank(System.getenv("dwApp_server_connector_port"))) {
- replaceApigatewayPort(route.getServers(),
- System.getenv("dwApp_server_connector_port"));
- }
- }
-
- if (url.startsWith("/admin/microservices")) {
- replaceApigatewayPort(route.getServers(),ConfigUtil.getInstance().getServerPort());
- }
+ }
+ }
- ApiRouteServiceWrapper.getInstance().saveApiRouteInstance4Rest(route, routeWay[i]);
- }
- }
+ } else if (RegExpTestUtil.iuiRouteUrlRegExpTest(url) || url.equals("/iui/microservices")) {
+ for (int i = 0; i < routeWay.length; i++) {
+ try {
- } else if (RegExpTestUtil.iuiRouteUrlRegExpTest(url) || url.equals("/iui/microservices")) {
+ IuiRouteServiceWrapper.getInstance().getIuiRouteInstance(route.getServiceName(),
+ route.getHost(), "", routeWay[i]);
- for (int i = 0; i < routeWay.length; i++) {
- try {
+ } catch (ExtendedNotFoundException e) {
- IuiRouteServiceWrapper.getInstance().getIuiRouteInstance(route.getServiceName(),
- route.getHost(), "", routeWay[i]);
+ LOGGER.info(" initiuiRoute: ServiceName--" + route.getServiceName());
+ IuiRouteInfo iuiRouteInfo = new IuiRouteInfo();
+ iuiRouteInfo.setControl(route.getControl());
+ iuiRouteInfo.setServers(route.getServers());
+ iuiRouteInfo.setServiceName(route.getServiceName());
+ iuiRouteInfo.setStatus(route.getStatus());
+ iuiRouteInfo.setHost(route.getHost());
- } catch (ExtendedNotFoundException e) {
- LOGGER.info(" initiuiRoute: ServiceName--" + route.getServiceName());
- IuiRouteInfo iuiRouteInfo = new IuiRouteInfo();
- iuiRouteInfo.setControl(route.getControl());
- iuiRouteInfo.setServers(route.getServers());
- iuiRouteInfo.setServiceName(route.getServiceName());
- iuiRouteInfo.setStatus(route.getStatus());
- iuiRouteInfo.setHost(route.getHost());
+ if (url.equals("/iui/microservices")) {
+ iuiRouteInfo.setUrl("/" + iuiRootPath + "/microservices");
+ if (StringUtils.isNotBlank(System.getenv("dwApp_server_connector_port"))) {
+ replaceApigatewayPort(iuiRouteInfo.getServers(),
+ System.getenv("dwApp_server_connector_port"));
+ }
+ } else {
+ iuiRouteInfo.setUrl(route.getUrl());
+ }
+ IuiRouteServiceWrapper.getInstance().saveIuiRouteInstance(iuiRouteInfo, routeWay[i]);
- if (url.equals("/iui/microservices")) {
- iuiRouteInfo.setUrl("/" + iuiRootPath + "/microservices");
- if (StringUtils.isNotBlank(System.getenv("dwApp_server_connector_port"))) {
- replaceApigatewayPort(iuiRouteInfo.getServers(),
- System.getenv("dwApp_server_connector_port"));
- }
- } else {
- iuiRouteInfo.setUrl(route.getUrl());
+
+ }
+ }
+
+ } else {
+ LOGGER.error("init Service throw exception——serviceName: " + route.getServiceName() + ",url:"
+ + url);
+ }
}
- IuiRouteServiceWrapper.getInstance()
- .saveIuiRouteInstance(iuiRouteInfo, routeWay[i]);
- }
}
- } else {
- LOGGER.error("init Service throw exception——serviceName: " + route.getServiceName()
- + ",url:" + url);
- }
+ } catch (Exception e) {
+ // TODO Auto-generated catch block
+ LOGGER.error("read initServices Files throw exception", e);
}
+ }
+ private void replaceApigatewayPort(RouteServer[] servers, String apigatewayPort) {
+ for (int i = 0; i < servers.length; i++) {
+ servers[i].setPort(apigatewayPort);
+ }
+ }
- }
+ public void initMetricsConfig(ApiRouteAppConfig configuration) {
- } catch (Exception e) {
- // TODO Auto-generated catch block
- LOGGER.error("read initServices Files throw exception", e);
+ SimpleServerFactory simpleServerFactory = (SimpleServerFactory) configuration.getServerFactory();
+ HttpConnectorFactory httpConnectorFactory = (HttpConnectorFactory) simpleServerFactory.getConnector();
+ String metricsUrl = "http://127.0.0.1:" + httpConnectorFactory.getPort()
+ + simpleServerFactory.getAdminContextPath() + "/metrics";
+ ConfigUtil.getInstance().setMetricsUrl(metricsUrl);
}
- }
- private void replaceApigatewayPort(RouteServer[] servers, String apigatewayPort) {
- for (int i = 0; i < servers.length; i++) {
- servers[i].setPort(apigatewayPort);
+ private boolean checkRedisConnect() {
+ Jedis jedis = null;
+ try {
+ jedis = JedisUtil.borrowJedisInstance();
+ return true;
+ } catch (Exception e) {
+ LOGGER.error("checkRedisConnect call redis throw exception", e);
+ } finally {
+ JedisUtil.returnJedisInstance(jedis);
+ }
+
+ return false;
}
- }
-
- public void initMetricsConfig(ApiRouteAppConfig configuration) {
-
- SimpleServerFactory simpleServerFactory =
- (SimpleServerFactory) configuration.getServerFactory();
- HttpConnectorFactory httpConnectorFactory =
- (HttpConnectorFactory) simpleServerFactory.getConnector();
- String metricsUrl =
- "http://127.0.0.1:" + httpConnectorFactory.getPort()
- + simpleServerFactory.getAdminContextPath() + "/metrics";
- ConfigUtil.getInstance().setMetricsUrl(metricsUrl);
- }
-
-
- private boolean checkRedisConnect() {
- Jedis jedis = null;
- try {
- jedis = JedisUtil.borrowJedisInstance();
- return true;
- } catch (Exception e) {
- LOGGER.error("checkRedisConnect call redis throw exception", e);
- }finally {
- JedisUtil.returnJedisInstance(jedis);
- }
-
- return false;
- }
Code Review / msb / apigateway.git / blobdiff