add rpc req timeout

ontio · Nov 6, 2019 · 194ef1d · 194ef1d
1 parent 5cfe174
commit 194ef1d
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/src/main/java/com/github/ontio/network/rest/http.java b/src/main/java/com/github/ontio/network/rest/http.java
@@ -135,7 +135,7 @@ public static String delete(String url, Map<String, String> params, Map<String,
     }
 
     public static String post(String url, Map<String, String> params, Map<String, Object> body) throws Exception {
-        //System.out.println(String.format("POST url=%s,%s,%s", url,JSON.toJSONString(params),JSON.toJSONString(body)));
+        System.out.println(String.format("POST url=%s,%s,%s", url,JSON.toJSONString(params),JSON.toJSONString(body)));
         if(url.startsWith("https")){
             return post(url+cvtParams(params), JSON.toJSONString(body), true);
         }else{
@@ -146,8 +146,8 @@ public static String post(String url, Map<String, String> params, Map<String, Ob
     private static String get(String url  ,boolean https) throws Exception {
     	URL u = new URL(url);
         HttpURLConnection http = (HttpURLConnection) u.openConnection();
-        http.setConnectTimeout(50000);
-        http.setReadTimeout(50000);
+        http.setConnectTimeout(20000);
+        http.setReadTimeout(20000);
         http.setRequestMethod("GET");
         http.setRequestProperty("Content-Type","application/json");
         if(https) {

diff --git a/src/main/java/com/github/ontio/network/rpc/Interfaces.java b/src/main/java/com/github/ontio/network/rpc/Interfaces.java
@@ -82,6 +82,8 @@ public Object send(Object request) throws IOException {
         try {
             HttpURLConnection connection = (HttpURLConnection) url.openConnection();
             connection.setRequestMethod("POST");
+            connection.setConnectTimeout(10000);
+            connection.setReadTimeout(10000);
             connection.setDoOutput(true);
             try (OutputStreamWriter w = new OutputStreamWriter(connection.getOutputStream())) {
                 w.write(JSON.toJSONString(request));

diff --git a/src/main/java/com/github/ontio/sdk/manager/ConnectMgr.java b/src/main/java/com/github/ontio/sdk/manager/ConnectMgr.java
@@ -49,6 +49,7 @@ public ConnectMgr(String url, String type, Object lock) {
     }
 
     public ConnectMgr(String url, String type) {
+        url = url.replace("://localhost","://127.0.0.1");
         if (type.equals("rpc")) {
             setConnector(new RpcClient(url));
         } else if (type.equals("restful")) {