方法调用工具类

modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/server/bean/po/ExecutorGroupRegistryInfo.java

@@ -42,6 +42,10 @@ public class ExecutorGroupRegistryInfo extends BaseBean implements Serializable
     @ApiModelProperty("自动注册 0，手动注册 1")
     private String type;
 
+    @Column
+    @ApiModelProperty("执行器组路由策略")
+    private String routeStrategy;
+
     @Column(name = "UPDATE_TIME")
     @ApiModelProperty("更新时间")
     private Date updateTime;

modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/server/bean/po/ExecutorRegistryMethodDocInfo.java

@@ -52,6 +52,6 @@ public class ExecutorRegistryMethodDocInfo extends BaseBean implements Serializa
 
     @Column(name = "METHOD_ID")
     @ApiModelProperty("方法ID")
-    private Integer methodId;
+    private Long methodId;
     //todo 缺少参数信息
 }

modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/server/bean/po/ExecutorRegistryParamInfo.java

@@ -43,6 +43,6 @@ public class ExecutorRegistryParamInfo extends BaseBean implements Serializable
 
     @Column(name = "METHOD_ID")
     @ApiModelProperty("所属方法的ID")
-    private Integer methodId;
+    private Long methodId;
 
 }

modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/server/common/ReturnT.java

@@ -0,0 +1,56 @@
+package cn.estsh.i3plus.pojo.bsp.server.common;
+
+import java.io.Serializable;
+
+/**
+ * @author Castle
+ */
+public class ReturnT<T> implements Serializable {
+    public static final long serialVersionUID = 42L;
+
+    public static final int SUCCESS_CODE = 200;
+    public static final int FAIL_CODE = 500;
+
+    public static final ReturnT<String> SUCCESS = new ReturnT<>(null);
+    public static final ReturnT<String> FAIL = new ReturnT<>(FAIL_CODE, null);
+
+    private int code;
+    private String msg;
+    private T content;
+
+    public ReturnT(){}
+    public ReturnT(int code, String msg) {
+        this.code = code;
+        this.msg = msg;
+    }
+
+    public ReturnT(T content) {
+        this.code = SUCCESS_CODE;
+        this.content = content;
+    }
+
+    public int getCode() {
+        return code;
+    }
+    public void setCode(int code) {
+        this.code = code;
+    }
+    public String getMsg() {
+        return msg;
+    }
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+    public T getContent() {
+        return content;
+    }
+    public void setContent(T content) {
+        this.content = content;
+    }
+
+    @Override
+    public String toString() {
+        return "ReturnT [code=" + code + ", msg=" + msg + ", content=" + content + "]";
+    }
+
+}

modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/server/util/GsonTool.java

@@ -1,4 +1,4 @@
-package cn.estsh.i3plus.bspserver.util;
+package cn.estsh.i3plus.pojo.bsp.server.util;
 
 import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;

modules/i3plus-pojo-bsp/src/main/java/cn/estsh/i3plus/pojo/bsp/server/util/HttpUtils.java

@@ -1,8 +1,6 @@
-package cn.estsh.i3plus.bspserver.util;
+package cn.estsh.i3plus.pojo.bsp.server.util;
 
-import cn.estsh.i3plus.pojo.base.bean.BaseBean;
+import cn.estsh.i3plus.pojo.bsp.server.common.ReturnT;
-import cn.estsh.impp.framework.boot.util.ResultBean;
-import com.google.gson.Gson;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -14,7 +12,6 @@ import java.net.HttpURLConnection;
 import java.net.URL;
 import java.security.cert.CertificateException;
 import java.security.cert.X509Certificate;
-import java.util.Map;
 
 /**
  * @Description :
@@ -47,8 +44,8 @@ public class HttpUtils {
 
     private static final TrustManager[] trustAllCerts = new TrustManager[]{new X509TrustManager() {
         @Override
-        public java.security.cert.X509Certificate[] getAcceptedIssuers() {
+        public X509Certificate[] getAcceptedIssuers() {
-            return new java.security.cert.X509Certificate[]{};
+            return new X509Certificate[]{};
         }
 
         @Override
@@ -71,7 +68,7 @@ public class HttpUtils {
      * @param returnTargClassOfT
      * @return
      */
-    public static ResultBean postBody(String url, int timeout, Object requestObj, Class returnTargClassOfT) {
+    public static ReturnT postBody(String url, int timeout, Object requestObj, Class returnTargClassOfT) {
         HttpURLConnection connection = null;
         BufferedReader bufferedReader = null;
         try {
@@ -110,7 +107,6 @@ public class HttpUtils {
                 dataOutputStream.close();
             }
 
-
             // valid StatusCode
             int statusCode = connection.getResponseCode();
             if (statusCode != 200) {
@@ -126,17 +122,13 @@ public class HttpUtils {
                 result.append(line);
             }
             String resultJson = result.toString();
-
             // parse returnT
             try {
-
+                return GsonTool.fromJson(resultJson, ReturnT.class);
-                ReturnT returnT = GsonTool.fromJson(resultJson, ReturnT.class);
-                return returnT;
             } catch (Exception e) {
                 logger.error("rpc remoting (url=" + url + ") response content invalid(" + resultJson + ").", e);
                 return new ReturnT<String>(ReturnT.FAIL_CODE, "rpc remoting (url=" + url + ") response content invalid(" + resultJson + ").");
             }
-
         } catch (Exception e) {
             logger.error(e.getMessage(), e);
             return new ReturnT<String>(ReturnT.FAIL_CODE, "rpc remoting error(" + e.getMessage() + "), for url : " + url);

pom.xml

@@ -180,6 +180,11 @@
                 <artifactId>xstream</artifactId>
                 <version>1.4.11.1</version>
             </dependency>
+            <dependency>
+                <groupId>com.google.code.gson</groupId>
+                <artifactId>gson</artifactId>
+                <version>2.8.6</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>