HttpClient工具栏

Posted 2020-11-27 yan-zm

  1 　　 private static int SOCKET_TIME_OUT = 60*1000;        //传输间隔超时      
  2     private static int CONNECT_TIME_OUT = 60*1000;        //链接建立超时 
  3     
  4     /**
  5      * @author Yanzm
  6      * @param url 请求路径
  7      * @param jsonString Json格式的请求参数
  8      * @return
  9      */
 10     public static String doPost(String url,String jsonString){
 11         CloseableHttpClient httpClient= HttpClients.createDefault();
 12         CloseableHttpResponse response = null;
 13         String resultStr = null;
 14         HttpPost post = new HttpPost(url);
 15         
 16         RequestConfig requestConfig = RequestConfig.custom()
 17                 .setSocketTimeout(SOCKET_TIME_OUT)
 18                 .setConnectTimeout(CONNECT_TIME_OUT).build();
 19         post.setConfig(requestConfig);
 20         
 21         try {
 22             post.addHeader("Accept","application/json");
 23             StringEntity entity = new StringEntity(jsonString);
 24         
 25             post.setEntity(entity);
 26             response = httpClient.execute(post);
 27             if (response.getStatusLine().getStatusCode() == 200) {
 28                 resultStr = EntityUtils.toString(response.getEntity(), "UTF-8");
 29                 if (StringUtils.isNotBlank(resultStr)) {
 30                     return resultStr;
 31                 }else {
 32                     log.info("请求响应正常，返回的数据为空");
 33                     return resultStr;
 34                 }
 35             }else {
 36                 log.error("响应异常，状态码为：{}",response.getStatusLine().getStatusCode());
 37                 return StringUtils.EMPTY;
 38             }
 39         } catch (Exception e) {
 40             log.error("httpClient 接口调用异常");
 41             e.printStackTrace();
 42         }finally {
 43             if (response != null) {
 44                 try {
 45                     response.close();
 46                 } catch (IOException e) {
 47                     log.error("httpClient response 关闭异常");
 48                     e.printStackTrace();
 49                 }
 50             }
 51             if (httpClient != null) {
 52                 try {
 53                     httpClient.close();
 54                 } catch (IOException e) {
 55                     log.error("httpClient 关闭异常");
 56                     e.printStackTrace();
 57                 }
 58             }
 59         }
 60         return resultStr;
 61     }
 62     
 63     /**
 64      * @author Yanzm
 65      * @param  url 请求路径
 66      * @return
 67      */
 68     public static String doGet(String url){
 69         CloseableHttpClient httpClient= HttpClients.createDefault();
 70         CloseableHttpResponse response = null;
 71         String resultStr = null;
 72         HttpGet get = new HttpGet(url);
 73         
 74         RequestConfig requestConfig = RequestConfig.custom()
 75                 .setSocketTimeout(SOCKET_TIME_OUT)
 76                 .setConnectTimeout(CONNECT_TIME_OUT).build();
 77         get.setConfig(requestConfig);
 78         
 79         try {
 80             get.addHeader("Accept","application/json");
 81             
 82             response = httpClient.execute(get);
 83             log.info("Connect to {}",url);
 84             if (response.getStatusLine().getStatusCode() == 200) {
 85                 resultStr = EntityUtils.toString(response.getEntity(), "UTF-8");
 86                 if (StringUtils.isNotBlank(resultStr)) {
 87                     return resultStr;
 88                 }else {
 89                     log.info("请求响应正常，返回的数据为空");
 90                     return resultStr;
 91                 }
 92             }else {
 93                 log.error("响应异常，状态码为：{}",response.getStatusLine().getStatusCode());
 94                 return StringUtils.EMPTY;
 95             }
 96         } catch (Exception e) {
 97             log.error("httpClient 接口调用异常");
 98             e.printStackTrace();
 99         }finally {
100             if (response != null) {
101                 try {
102                     response.close();
103                 } catch (IOException e) {
104                     log.error("httpClient response 关闭异常");
105                     e.printStackTrace();
106                 }
107             }
108             if (httpClient != null) {
109                 try {
110                     httpClient.close();
111                 } catch (IOException e) {
112                     log.error("httpClient 关闭异常");
113                     e.printStackTrace();
114                 }
115             }
116         }
117         return resultStr;
118     }
119     
120     public static void setSocketTimeOut(int timeOut) {
121         SOCKET_TIME_OUT = timeOut;
122     }
123     
124     public static void setConnectTimeOut(int timeOut) {
125         CONNECT_TIME_OUT = timeOut;
126     }