update...

潘钊
1 parent 7ac2ae05
Showing 2 changed files with 103 additions and 3 deletions
src/main/java/com/bsth/data/led_http/LedHttpPushHandler.java
src/main/java/com/bsth/data/utils/HttpClientUtils_tms.java
 package com.bsth.data.led_http;
  
-import com.bsth.data.utils.HttpClientUtils;
+import com.bsth.data.utils.HttpClientUtils_tms;
 import com.bsth.entity.ac.CarInOutEntity;
 import com.bsth.entity.real.RealCarPark;
 import com.bsth.util.ConfigUtil;
@@ -41,7 +41,7 @@ public class LedHttpPushHandler {
  
         try {
             logger.info("push http led out:" + params);
-            HttpClientUtils.get(url);
+            HttpClientUtils_tms.get(url);
         } catch (Exception e) {
             logger.error("", e);
         }
@@ -53,7 +53,7 @@ public class LedHttpPushHandler {
  
         try {
             logger.info("push http led in:" + params);
-            HttpClientUtils.get(url);
+            HttpClientUtils_tms.get(url);
         } catch (Exception e) {
             logger.error("", e);
         }
+package com.bsth.data.utils;
+
+import org.apache.http.HttpEntity;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+
+/**
+ * 快速超时，内网用
+ * Created by panzhao on 2017/8/2.
+ */
+public class HttpClientUtils_tms {
+
+    static Logger logger = LoggerFactory.getLogger(HttpClientUtils_tms.class);
+
+    public static StringBuilder get(String url) throws Exception {
+        CloseableHttpClient httpClient = null;
+        CloseableHttpResponse response = null;
+        StringBuilder stringBuffer = null;
+        try {
+            httpClient = HttpClients.createDefault();
+            HttpGet get = new HttpGet(url);
+            //超时时间
+            RequestConfig requestConfig = RequestConfig.custom()
+                    .setConnectTimeout(2500).setConnectionRequestTimeout(2000)
+                    .setSocketTimeout(2500).build();
+            get.setConfig(requestConfig);
+            get.addHeader("Content-Encoding", "gzip");
+
+            response = httpClient.execute(get);
+            stringBuffer = getResult(response.getEntity());
+        } catch (Exception e) {
+            logger.error("", e);
+        } finally {
+            if (null != httpClient)
+                httpClient.close();
+            if (null != response)
+                response.close();
+        }
+        return stringBuffer;
+    }
+
+    /**
+     * raw post data
+     * @param url
+     * @param data
+     * @return
+     */
+    public static StringBuilder post(String url, String data) throws Exception {
+        CloseableHttpClient httpClient = null;
+        CloseableHttpResponse response = null;
+        StringBuilder stringBuffer = null;
+        try {
+            httpClient = HttpClients.createDefault();
+            HttpPost post = new HttpPost(url);
+
+            post.setHeader("Accept", "application/json");
+            post.setHeader("Content-Type", "application/json");
+            //超时时间
+            RequestConfig requestConfig = RequestConfig.custom()
+                    .setConnectTimeout(2500).setConnectionRequestTimeout(2000)
+                    .setSocketTimeout(2500).build();
+            post.setConfig(requestConfig);
+            post.setEntity((new StringEntity(data, "UTF-8")));
+
+            response = httpClient.execute(post);
+            stringBuffer = getResult(response.getEntity());
+        } catch (Exception e) {
+            logger.error("", e);
+        } finally {
+            if (null != httpClient)
+                httpClient.close();
+            if (null != response)
+                response.close();
+        }
+        return stringBuffer;
+    }
+
+    private static StringBuilder getResult(HttpEntity entity) throws IOException {
+        StringBuilder stringBuffer = null;
+        if (null != entity) {
+            BufferedReader br = new BufferedReader(new InputStreamReader(entity.getContent()));
+            stringBuffer = new StringBuilder();
+            String str = "";
+            while ((str = br.readLine()) != null)
+                stringBuffer.append(str);
+        }
+        return stringBuffer;
+    }
+}