Skip to content

G
gic-cloud
Commit 6b5a2a53 by 陶光胜
Options

取数平台调整

parent faf7bcba
Showing with 3 additions and 1 deletions
gic-cloud-data-hook/src/main/java/com/gic/cloud/data/hook/router/CustomRouter.java
...@@ -27,11 +27,13 @@ public class CustomRouter implements Router { ...@@ -27,11 +27,13 @@ public class CustomRouter implements Router {
@Override @Override
public <T> List<Invoker<T>> route(List<Invoker<T>> invokers, URL url, Invocation invocation) throws RpcException { public <T> List<Invoker<T>> route(List<Invoker<T>> invokers, URL url, Invocation invocation) throws RpcException {
System.out.println("start route = " + System.currentTimeMillis()); System.out.println("start route = " + System.currentTimeMillis());
if(url.getParameter("application", "").equals("gic-cloud-data-hook")){ if(url.getParameter("application", "").equals("gic-cloud-data-hook") &&
url.getParameter("interface").contains("com.gic.cloud.data.hook.service")){
String enterpriseId = SessionContextUtils.getLoginUserEnterpriseId(); String enterpriseId = SessionContextUtils.getLoginUserEnterpriseId();
Config config = ConfigService.getConfig("application"); Config config = ConfigService.getConfig("application");
String customRouterEnterpriseId = config.getProperty("customRouterEnterpriseId", ""); String customRouterEnterpriseId = config.getProperty("customRouterEnterpriseId", "");
String customRouterHost = config.getProperty("customRouterHost", ""); String customRouterHost = config.getProperty("customRouterHost", "");
System.out.println("end = " + System.currentTimeMillis());
List<Invoker<T>> list = new ArrayList<>(); List<Invoker<T>> list = new ArrayList<>();
if(enterpriseId.equals(customRouterEnterpriseId)){ if(enterpriseId.equals(customRouterEnterpriseId)){
//路由到新服务器 //路由到新服务器
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment