1 files changed, 117 insertions, 0 deletions
diff --git a/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/util/HttpClientUtil.java b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/util/HttpClientUtil.java
new file mode 100644
index 0000000..eb5ed1e
--- /dev/null
+++ b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/util/HttpClientUtil.java
@@ -0,0 +1,117 @@
+package org.onap.msb.apiroute.wrapper.util;
+
+import java.io.IOException;
+
+import org.apache.http.client.ClientProtocolException;
+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.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class HttpClientUtil {
+
+  private static final Logger logger = LoggerFactory.getLogger(HttpClientUtil.class);
+  
+  private static int connectionTimeOut = 2*1000;
+  
+
+  public static String httpGet(String url){
+    String result = null;
+    CloseableHttpClient httpClient = HttpClients.createDefault();
+    HttpGet httpGet = new HttpGet(url);
+    httpGet.addHeader("Content-type", "application/json; charset=utf-8");
+    httpGet.setHeader("Accept", "application/json");
+    try {
+      CloseableHttpResponse res = httpClient.execute(httpGet);
+      result = EntityUtils.toString(res.getEntity());
+      if (res.getStatusLine().getStatusCode() != CommonUtil.SC_OK) {
+        logger.error(result);
+      }
+      res.close();
+    } catch (ClientProtocolException e) {
+      logger.error(url + ":httpGetWithJSON connect faild");
+    } catch (IOException e) {
+      logger.error( url + ":httpGetWithJSON connect faild");
+    } finally {
+      try {
+        httpClient.close();
+      } catch (IOException e) {
+        logger.error(url + ":close  httpClient faild");
+      }
+    }
+
+    return result;
+
+  }
+  
+  public static HttpGetResult httpGetStatusAndBody(String url){
+	    HttpGetResult result= new HttpGetResult();
+	    String body = null;
+	    CloseableHttpClient httpClient = HttpClients.createDefault();
+	    HttpGet httpGet = new HttpGet(url);
+	    httpGet.addHeader("Content-type", "application/json; charset=utf-8");
+	    httpGet.setHeader("Accept", "application/json");
+	    
+	    RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(connectionTimeOut).build();
+	    httpGet.setConfig(requestConfig);
+	    
+	    try {
+	      CloseableHttpResponse res = httpClient.execute(httpGet);
+	      body = EntityUtils.toString(res.getEntity());
+	      if (res.getStatusLine().getStatusCode() != CommonUtil.SC_OK) {
+	        logger.error(body);
+	      }
+	      result.setBody(body);
+	      result.setStatusCode(res.getStatusLine().getStatusCode());
+	      res.close();
+	    } catch (ClientProtocolException e) {
+	      logger.error(url + ":httpGetWithJSON connect faild",e);
+	    } catch (IOException e) {
+	      logger.error( url + ":httpGetWithJSON connect faild",e);
+	    } finally {
+	      try {
+	        httpClient.close();
+	      } catch (IOException e) {
+	        logger.error(url + ":close  httpClient faild");
+	      }
+	    }
+
+	    return result;
+
+	  }
+
+  public static int httpGetStatus(String url)  throws Exception{
+    int iStatus=500;
+    CloseableHttpClient httpClient = HttpClients.createDefault();
+
+
+    HttpGet httpGet = new HttpGet(url);
+    RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(10000).setConnectTimeout(10000).build();//设置请求和传输超时时间
+    httpGet.setConfig(requestConfig);
+    httpGet.addHeader("Content-type", "application/json; charset=utf-8");
+    httpGet.setHeader("Accept", "application/json");
+    try {
+      CloseableHttpResponse res = httpClient.execute(httpGet);
+    
+      iStatus=res.getStatusLine().getStatusCode();
+      res.close();
+    } catch (ClientProtocolException e) {
+      logger.error(url + " httpGet connect faild:"+e.getMessage());
+    } catch (IOException e) {
+      logger.error(url + " httpGet connect faild:"+e.getMessage());
+    } finally {
+      try {
+        httpClient.close();
+      } catch (IOException e) {
+        logger.error(url + " httpGet close faild:"+e.getMessage());
+      }
+    }
+
+    return iStatus;
+
+  }
+}