Divide the MSB source codes into two repos

[msb/apigateway.git] / apiroute / apiroute-service / src / main / java / org / onap / msb / apiroute / wrapper / util / HttpClientUtil.java

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 (file)
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;
+
+  }
+}