--- /dev/null
+/**\r
+* Copyright (C) 2016 ZTE, Inc. and others. All rights reserved. (ZTE)\r
+*\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
+* You may obtain a copy of the License at\r
+*\r
+* http://www.apache.org/licenses/LICENSE-2.0\r
+*\r
+* Unless required by applicable law or agreed to in writing, software\r
+* distributed under the License is distributed on an "AS IS" BASIS,\r
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+* See the License for the specific language governing permissions and\r
+* limitations under the License.\r
+*/\r
+\r
+package org.openo.msb;\r
+\r
+import io.dropwizard.Application;\r
+import io.dropwizard.assets.AssetsBundle;\r
+import io.dropwizard.jetty.HttpConnectorFactory;\r
+import io.dropwizard.server.SimpleServerFactory;\r
+import io.dropwizard.setup.Bootstrap;\r
+import io.dropwizard.setup.Environment;\r
+import io.swagger.jaxrs.config.BeanConfig;\r
+import io.swagger.jaxrs.listing.ApiListingResource;\r
+\r
+import java.io.BufferedWriter;\r
+import java.io.File;\r
+import java.io.FileNotFoundException;\r
+import java.io.FileWriter;\r
+import java.io.IOException;\r
+import java.net.URL;\r
+import java.util.List;\r
+\r
+import net.sf.json.JSONObject;\r
+\r
+import org.apache.commons.lang3.StringUtils;\r
+import org.openo.msb.api.ApiRouteInfo;\r
+import org.openo.msb.api.ConsulInfo;\r
+import org.openo.msb.api.CustomRouteInfo;\r
+import org.openo.msb.api.DiscoverInfo;\r
+import org.openo.msb.api.IuiRouteInfo;\r
+import org.openo.msb.api.RouteServer;\r
+import org.openo.msb.api.exception.ExtendedNotFoundException;\r
+import org.openo.msb.health.ApiRouteHealthCheck;\r
+import org.openo.msb.resources.ApiRouteResource;\r
+import org.openo.msb.resources.CustomRouteResource;\r
+import org.openo.msb.resources.IuiRouteResource;\r
+import org.openo.msb.resources.MetricsResource;\r
+import org.openo.msb.resources.MicroServiceResource;\r
+import org.openo.msb.resources.ServiceAccessResource;\r
+import org.openo.msb.wrapper.ApiRouteServiceWrapper;\r
+import org.openo.msb.wrapper.CustomRouteServiceWrapper;\r
+import org.openo.msb.wrapper.IuiRouteServiceWrapper;\r
+import org.openo.msb.wrapper.serviceListener.MicroServiceChangeListener;\r
+import org.openo.msb.wrapper.util.FileUtil;\r
+import org.openo.msb.wrapper.util.JacksonJsonUtil;\r
+import org.openo.msb.wrapper.util.JedisUtil;\r
+import org.openo.msb.wrapper.util.MetricsUtil;\r
+import org.openo.msb.wrapper.util.MicroServiceDB;\r
+import org.openo.msb.wrapper.util.RegExpTestUtil;\r
+import org.openo.msb.wrapper.util.RouteUtil;\r
+import org.slf4j.Logger;\r
+import org.slf4j.LoggerFactory;\r
+\r
+import com.fasterxml.jackson.annotation.JsonInclude;\r
+\r
+public class ApiRouteApp extends Application<ApiRouteAppConfig> {\r
+\r
+ private static final Logger LOGGER = LoggerFactory.getLogger(ApiRouteApp.class);\r
+\r
+ public static void main(String[] args) throws Exception {\r
+ new ApiRouteApp().run(args);\r
+\r
+ }\r
+\r
+ private ApiRouteAppConfig config;\r
+\r
+ @Override\r
+ public String getName() {\r
+ return " MicroService Bus ";\r
+ }\r
+\r
+ @Override\r
+ public void initialize(Bootstrap<ApiRouteAppConfig> bootstrap) {\r
+ \r
+ \r
+ }\r
+\r
+ @Override\r
+ public void run(ApiRouteAppConfig configuration, Environment environment) {\r
+ \r
+ initRootPath();\r
+ \r
+ \r
+ new AssetsBundle("/iui-metrics", "/"+RouteUtil.IUI_ROOT_PATH+"/microservices/metrics",\r
+ "index.html", "iui-metrics").run(environment); \r
+ \r
+ new AssetsBundle("/iui-route", "/"+RouteUtil.IUI_ROOT_PATH+"/microservices", "index.html",\r
+ "iui-microservices").run(environment); \r
+ \r
+ new AssetsBundle("/api-doc", "/"+RouteUtil.IUI_ROOT_PATH+"/microservices/api-doc",\r
+ "index.html", "api-doc").run(environment);\r
+ \r
+ new AssetsBundle("/ext", "/"+RouteUtil.IUI_ROOT_PATH+"/microservices/ext",\r
+ "index.html", "ext").run(environment);\r
+ \r
+ \r
+ \r
+\r
+ final ApiRouteHealthCheck healthCheck =\r
+ new ApiRouteHealthCheck(configuration.getDefaultWorkspace());\r
+ environment.healthChecks().register("template", healthCheck);\r
+ environment.jersey().register(new ApiRouteResource());\r
+ environment.jersey().register(new IuiRouteResource());\r
+ environment.jersey().register(new MetricsResource());\r
+ environment.jersey().register(new CustomRouteResource());\r
+ environment.jersey().register(new ServiceAccessResource());\r
+ environment.jersey().register(new MicroServiceResource());\r
+\r
+ config = configuration;\r
+\r
+ initSwaggerConfig(environment, configuration);\r
+ initRedisConfig(configuration);\r
+ checkRedisConnect();\r
+ initMetricsConfig(configuration);\r
+ initVisualRangeMatches();\r
+\r
+ registerServiceChangeListener();\r
+\r
+\r
+ }\r
+\r
+ private void initMetricsConfig(ApiRouteAppConfig configuration) {\r
+\r
+ SimpleServerFactory simpleServerFactory =\r
+ (SimpleServerFactory) configuration.getServerFactory();\r
+ HttpConnectorFactory httpConnectorFactory =\r
+ (HttpConnectorFactory) simpleServerFactory.getConnector();\r
+ MetricsUtil.adminContextPath =\r
+ "http://127.0.0.1:" + httpConnectorFactory.getPort()\r
+ + simpleServerFactory.getAdminContextPath() + "/metrics";\r
+ }\r
+\r
+ private void initSwaggerConfig(Environment environment, ApiRouteAppConfig configuration) {\r
+\r
+ environment.jersey().register(new ApiListingResource());\r
+ environment.getObjectMapper().setSerializationInclusion(JsonInclude.Include.NON_NULL);\r
+\r
+ BeanConfig config = new BeanConfig();\r
+ config.setTitle("MicroService Bus rest API");\r
+ config.setVersion("1.0.0");\r
+ config.setResourcePackage("org.openo.msb.resources");\r
+ SimpleServerFactory simpleServerFactory =\r
+ (SimpleServerFactory) configuration.getServerFactory();\r
+ String basePath = simpleServerFactory.getApplicationContextPath();\r
+ String rootPath = simpleServerFactory.getJerseyRootPath();\r
+\r
+ rootPath = rootPath.substring(0, rootPath.indexOf("/*"));\r
+\r
+ basePath =\r
+ basePath.equals("/") ? rootPath : (new StringBuilder()).append(basePath)\r
+ .append(rootPath).toString();\r
+\r
+ LOGGER.info("getApplicationContextPath： " + basePath);\r
+ config.setBasePath(basePath);\r
+ config.setScan(true);\r
+ }\r
+ \r
+ \r
+ private void initRootPath(){\r
+ try {\r
+ \r
+ URL urlRootPath = ApiRouteApp.class.getResource("/ext/initUrlRootPath/initUrlRootPath.json");\r
+ if (urlRootPath != null) {\r
+ String path = urlRootPath.getPath();\r
+ \r
+ LOGGER.info("read initUrlRootPath:" + path);\r
+ \r
+ String fileContent = FileUtil.readFile(path);\r
+ JSONObject jsonObj = JSONObject.fromObject(fileContent);\r
+ RouteUtil.IUI_ROOT_PATH=jsonObj.get("iuiRootPath").toString();\r
+ RouteUtil.API_ROOT_PATH=jsonObj.get("apiRootPath").toString();\r
+ }\r
+ } catch (Exception e) {\r
+ // TODO Auto-generated catch block\r
+ LOGGER.error("read initUrlRootPath Files throw exception", e);\r
+ }\r
+ \r
+ }\r
+ private void initRedisConfig(ApiRouteAppConfig configuration) {\r
+\r
+ String path = this.getClass().getProtectionDomain().getCodeSource().getLocation().getPath();\r
+ String jarPath = path.substring(0, path.lastIndexOf("/"));\r
+\r
+ LOGGER.info("jarpath: " + jarPath);\r
+ LOGGER.info("getDefaultWorkspace " + configuration.getDefaultWorkspace());\r
+\r
+ String confDir =\r
+ jarPath + "/" + configuration.getDefaultWorkspace() + "/"\r
+ + configuration.getPropertiesDir();\r
+ String propertiesPath = confDir + "/" + configuration.getPropertiesName();\r
+\r
+ JedisUtil.propertiesPath = propertiesPath;\r
+\r
+ LOGGER.info("propertiesPath: " + propertiesPath);\r
+ LOGGER.info("confDir: " + confDir);\r
+\r
+ try {\r
+ File dirFile = new File(confDir);\r
+\r
+ if (!dirFile.exists()) {\r
+ dirFile.mkdirs();\r
+ }\r
+ } catch (Exception e) {\r
+ // TODO Auto-generated catch block\r
+ LOGGER.info("create RedisConfig confDir error: " + confDir + e.getMessage());\r
+ }\r
+\r
+\r
+ try {\r
+ File propertiesFile = new File(propertiesPath);\r
+ if (!propertiesFile.exists()) {\r
+\r
+\r
+ propertiesFile.createNewFile();\r
+\r
+ BufferedWriter output = new BufferedWriter(new FileWriter(propertiesFile));\r
+ StringBuilder contentBuilder = new StringBuilder();\r
+ contentBuilder.append("redis.host=127.0.0.1\n").append("redis.port=6379\n")\r
+ .append("#connectionTimeout\n").append("redis.connectionTimeout=2000\n")\r
+ .append("#redis dbIndex，defaule:0\n")\r
+ .append("redis.db_index=0\n\n")\r
+ .append("#--------------redis pool config--------------\n")\r
+ .append("#maxTotal\n").append("redis.pool.maxTotal=100\n")\r
+ .append("#maxIdle\n").append("redis.pool.maxIdle=20\n")\r
+ .append("#maxWaitMillis:ms\n")\r
+ .append("redis.pool.maxWaitMillis=1000\n")\r
+ .append("#testOnBorrow\n")\r
+ .append("redis.pool.testOnBorrow=false\n")\r
+ .append("#testOnReturn\n")\r
+ .append("redis.pool.testOnReturn=true\n")\r
+ .append("#nginx Port\n").append("server.port=10080\n");\r
+\r
+ output.write(contentBuilder.toString());\r
+ output.close();\r
+\r
+ }\r
+ } catch (IOException e) {\r
+ // TODO Auto-generated catch block\r
+ LOGGER.info("create RedisConfig File error: " + propertiesPath + e.getMessage());\r
+ }\r
+ }\r
+\r
+\r
+ private void checkRedisConnect() {\r
+\r
+ new Thread(new Runnable() {\r
+ public void run() {\r
+ int n = 0;\r
+ while (true) {\r
+ if (ApiRouteServiceWrapper.checkRedisConnect() == false) {\r
+ n++;\r
+ System.out.println(n\r
+ + "/10 : Initial Route Configuration——redis connection fail...");\r
+\r
+ try {\r
+ Thread.sleep(10000);\r
+ } catch (InterruptedException e) {\r
+ LOGGER.error("Thread.sleep throw except:"+e.getMessage());\r
+ }\r
+\r
+\r
+ if (n >= 10) {\r
+ System.out.println("Initial Route Configuration fail,timeout exit");\r
+ LOGGER.error("Initial Route Configuration——redis connection fail,timeout exit...");\r
+ break;\r
+ }\r
+ } else {\r
+ System.out.println("starting to initial Route Configuration");\r
+ // initRouteInfoFromConfig();\r
+ initRouteInfoFromJson();\r
+ System.out.println("starting to initial consul Configuration");\r
+ runConsulClientApp();\r
+\r
+ break;\r
+ }\r
+ }\r
+\r
+ }\r
+ }).start();\r
+ }\r
+\r
+\r
+ \r
+\r
+ /**\r
+ * @Title: initVisualRangeMatches\r
+ * @Description: TODO(According to the environment variable or a JSON file configuration initialization VisualRange filter conditions)\r
+ * @return: void\r
+ */\r
+ private void initVisualRangeMatches(){\r
+ try {\r
+ if(System.getenv("APIGATEWAY_VISUAL_RANGE")==null)\r
+ {\r
+ \r
+ URL visualRangePath = ApiRouteApp.class.getResource("/ext/initVisualRange/initVisualRangeMatches.json");\r
+ if (visualRangePath != null) {\r
+ String path = visualRangePath.getPath();\r
+ \r
+ LOGGER.info("read initVisualRangeMatches:" + path);\r
+ \r
+ String fileContent = FileUtil.readFile(path);\r
+ JSONObject jsonObj = JSONObject.fromObject(fileContent);\r
+ String visualRangeArray=jsonObj.get("visualRange").toString();\r
+ \r
+ \r
+ RouteUtil.visualRangeMatches=StringUtils.split(visualRangeArray, ","); \r
+ \r
+ \r
+ \r
+ }\r
+ }\r
+ else{\r
+ RouteUtil.visualRangeMatches=StringUtils.split(System.getenv("APIGATEWAY_VISUAL_RANGE"), ",");\r
+ }\r
+ } catch (Exception e) {\r
+ // TODO Auto-generated catch block\r
+ LOGGER.error("read initVisualRangeMatches Files or env(APIGATEWAY_VISUAL_RANGE) throw exception", e);\r
+ }\r
+ }\r
+\r
+ /**\r
+ * @Title: initRouteInfoFromJson\r
+ * @Description: TODO(按照JSON文件配置初始化route数据)\r
+ * @return: void\r
+ */\r
+ private void initRouteInfoFromJson() {\r
+\r
+ URL apiDocsPath = ApiRouteApp.class.getResource("/ext/initServices");\r
+ if (apiDocsPath != null) {\r
+ String path = apiDocsPath.getPath();\r
+\r
+ LOGGER.info("read JsonFilefolder:" + path);\r
+\r
+ try {\r
+ File[] files = FileUtil.readFileFolder(path);\r
+ for (int i = 0; i < files.length; i++) {\r
+ File file = files[i];\r
+ if (file.isFile() && file.getName().endsWith(".json")) {\r
+ LOGGER.info("read JsonFile:" + file.getPath());\r
+ String fileContent = FileUtil.readFile(file.getPath());\r
+ saveInitService2redis(fileContent);\r
+ } else {\r
+ LOGGER.warn(file.getName() + " is not a right file");\r
+ }\r
+ }\r
+\r
+\r
+\r
+ } catch (FileNotFoundException e) {\r
+ // TODO Auto-generated catch block\r
+ LOGGER.error("read initServices Files throw FileNotFoundException", e);\r
+ } catch (IOException e) {\r
+ // TODO Auto-generated catch block\r
+ LOGGER.error("read initServices Files throw IOexception", e);\r
+ }\r
+\r
+ }\r
+\r
+\r
+\r
+ }\r
+\r
+\r
+\r
+ private void saveInitService2redis(String fileContent) {\r
+ try {\r
+ List<ApiRouteInfo> routeList =\r
+ (List<ApiRouteInfo>) JacksonJsonUtil.jsonToListBean(fileContent);\r
+ for (ApiRouteInfo route : routeList) {\r
+ String url = route.getUrl();\r
+\r
+ if (RegExpTestUtil.urlRegExpTest(route.getServiceName())) {\r
+ \r
+ try{\r
+ CustomRouteInfo dbCustomRoute =\r
+ CustomRouteServiceWrapper.getInstance().getCustomRouteInstance(\r
+ route.getServiceName());\r
+ }\r
+ catch(ExtendedNotFoundException e){\r
+\r
+ LOGGER.info("initCustomRoute: ServiceName--" + route.getServiceName());\r
+\r
+ CustomRouteInfo customRouteInfo = new CustomRouteInfo();\r
+ customRouteInfo.setControl(route.getControl());\r
+ customRouteInfo.setServers(route.getServers());\r
+ customRouteInfo.setServiceName(route.getServiceName());\r
+ customRouteInfo.setStatus(route.getStatus());\r
+ customRouteInfo.setUrl(route.getUrl());\r
+\r
+\r
+ CustomRouteServiceWrapper.getInstance().saveCustomRouteInstance(\r
+ customRouteInfo, "");\r
+\r
+\r
+ }\r
+ } else {\r
+\r
+ if (RegExpTestUtil.apiRouteUrlRegExpTest(url) || url.startsWith("/api/microservices/")) {\r
+\r
+\r
+ try{\r
+ ApiRouteInfo dbApiRoute =\r
+ ApiRouteServiceWrapper.getInstance().getApiRouteInstance(\r
+ route.getServiceName(), route.getVersion());\r
+ }\r
+ catch(ExtendedNotFoundException e){\r
+ LOGGER.info("initapiRoute: ServiceName--" + route.getServiceName());\r
+ ApiRouteServiceWrapper.getInstance().saveApiRouteInstance(route, "");\r
+ }\r
+\r
+ \r
+ } else if (RegExpTestUtil.iuiRouteUrlRegExpTest(url) || url.equals("/iui/microservices")) {\r
+ \r
+ try{\r
+ IuiRouteInfo dbIuiRoute =\r
+ IuiRouteServiceWrapper.getInstance().getIuiRouteInstance(\r
+ route.getServiceName());\r
+ }\r
+ catch(ExtendedNotFoundException e){\r
+ \r
+ LOGGER.info(" initiuiRoute: ServiceName--" + route.getServiceName());\r
+ IuiRouteInfo iuiRouteInfo = new IuiRouteInfo();\r
+ iuiRouteInfo.setControl(route.getControl());\r
+ iuiRouteInfo.setServers(route.getServers());\r
+ iuiRouteInfo.setServiceName(route.getServiceName());\r
+ iuiRouteInfo.setStatus(route.getStatus());\r
+ \r
+ if(url.equals("/iui/microservices")){\r
+ iuiRouteInfo.setUrl("/"+RouteUtil.IUI_ROOT_PATH+"/microservices");\r
+ }\r
+ else{\r
+ iuiRouteInfo.setUrl(route.getUrl());\r
+ }\r
+\r
+ IuiRouteServiceWrapper.getInstance().saveIuiRouteInstance(iuiRouteInfo);\r
+\r
+ }\r
+\r
+ } else {\r
+ LOGGER.error("init Service throw exception——serviceName: " + route.getServiceName()+",url:"+url);\r
+ }\r
+ }\r
+\r
+\r
+\r
+ }\r
+\r
+ } catch (Exception e) {\r
+ // TODO Auto-generated catch block\r
+ LOGGER.error("read initServices Files throw exception", e);\r
+ }\r
+\r
+ }\r
+\r
+\r
+\r
+ /**\r
+ * The listener registration service changes\r
+ */\r
+ private void registerServiceChangeListener() {\r
+ MicroServiceDB.getInstance().addServiceChangeListener(new MicroServiceChangeListener());\r
+ }\r
+\r
+ // Open the consul to monitor subscription service\r
+ private void runConsulClientApp() {\r
+ DiscoverInfo config_discoverInfo = config.getDiscoverInfo();\r
+ \r
+ ConsulInfo config_consulInfo=config.getConsulInfo();\r
+ \r
+ RouteUtil.discoverInfo.setEnabled(config_discoverInfo.isEnabled()); \r
+ \r
+ if (config_discoverInfo.isEnabled()) {\r
+ try{\r
+ if(System.getenv("SDCLIENT_SVC_PORT")==null)\r
+ {\r
+ //yml \r
+ RouteUtil.discoverInfo.setIp(config_discoverInfo.getIp()); \r
+ RouteUtil.discoverInfo.setPort(config_discoverInfo.getPort());\r
+ \r
+ }\r
+ else{\r
+ \r
+ String discoverAddress=System.getenv("SDCLIENT_SVC_PORT").split("//")[1];\r
+ String sdIP=discoverAddress.split(":")[0];\r
+ int sdPort=Integer\r
+ .parseInt(discoverAddress.split(":")[1]);\r
+ \r
+ RouteUtil.discoverInfo.setIp(sdIP);\r
+ RouteUtil.discoverInfo.setPort(sdPort);\r
+ \r
+ config_consulInfo.setIp(sdIP);\r
+ config_consulInfo.setPort(sdPort);\r
+ \r
+ \r
+ }\r
+ \r
+ \r
+ \r
+ //Registration service discovery routing\r
+ //api\r
+ ApiRouteInfo discoverApiService=new ApiRouteInfo();\r
+ discoverApiService.setServiceName("msdiscover");\r
+ discoverApiService.setUrl("/api/microservices/v1");\r
+ discoverApiService.setVersion("v1");\r
+ discoverApiService.setMetricsUrl("/admin/metrics");\r
+ discoverApiService.setApiJson("/api/microservices/v1/swagger.json");\r
+ \r
+ RouteServer[] servers=new RouteServer[1];\r
+ servers[0]=new RouteServer(RouteUtil.discoverInfo.getIp(),String.valueOf(RouteUtil.discoverInfo.getPort()));\r
+ discoverApiService.setServers(servers);\r
+ \r
+ ApiRouteServiceWrapper.getInstance().saveApiRouteInstance(discoverApiService, "");\r
+ \r
+ //iui\r
+ IuiRouteInfo discoverIUIService=new IuiRouteInfo();\r
+ discoverIUIService.setServiceName("msdiscover");\r
+ discoverIUIService.setUrl("/iui/microservices");\r
+ discoverIUIService.setServers(servers);\r
+ IuiRouteServiceWrapper.getInstance().saveIuiRouteInstance(discoverIUIService);\r
+ \r
+ \r
+\r
+ ConsulClientApp consulClientApp = new ConsulClientApp(config_consulInfo.getIp(), config_consulInfo.getPort());\r
+ // Monitor service change\r
+ consulClientApp.startServiceListen();\r
+ LOGGER.info("start monitor consul service--" +config_consulInfo.getIp() + ":"\r
+ + config_consulInfo.getPort());\r
+ }\r
+ catch(Exception e){\r
+ LOGGER.error("start monitor consul service fail:"+e.getMessage()); \r
+ }\r
+ }\r
+ \r
+ \r
+ }\r
+\r
+}\r
Code Review / msb / apigateway.git / blobdiff