org.apache.httpcomponents:httpclient 工具类

Posted 2020-09-22

基于httpclient 版本4.4.1

因为http连接需要三次握手，在需要频繁调用时浪费资源和时间

故采用连接池的方式连接

　　根据实际需要更改  连接池最大连接数、路由最大连接数

　　另一个需要注意的是

 

　　　// 释放Socket流
     response.close();
     // 释放Connection
     // httpClient.close();

  1 import org.apache.http.HttpEntity;
  2 import org.apache.http.NameValuePair;
  3 import org.apache.http.client.config.RequestConfig;
  4 import org.apache.http.client.entity.UrlEncodedFormEntity;
  5 import org.apache.http.client.methods.CloseableHttpResponse;
  6 import org.apache.http.client.methods.HttpGet;
  7 import org.apache.http.client.methods.HttpPost;
  8 import org.apache.http.client.methods.HttpRequestBase;
  9 import org.apache.http.client.utils.URIBuilder;
 10 import org.apache.http.config.SocketConfig;
 11 import org.apache.http.entity.StringEntity;
 12 import org.apache.http.impl.client.CloseableHttpClient;
 13 import org.apache.http.impl.client.HttpClients;
 14 import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
 15 import org.apache.http.message.BasicNameValuePair;
 16 import org.apache.http.util.EntityUtils;
 17 
 18 import java.io.IOException;
 19 import java.io.UnsupportedEncodingException;
 20 import java.net.URISyntaxException;
 21 import java.util.ArrayList;
 22 import java.util.Map;
 23 
 24 /**
 25  * Created by lidada on 2017/6/9.
 26  */
 27 public class HttpClientUtils {
 28     private static PoolingHttpClientConnectionManager cm;
 29     private static String EMPTY_STR = "";
 30     private static String CONTENT_TYPE_UTF_8 = "UTF-8";
 31     private static String CONTENT_TYPE_GBK = "GBK";
 32     private static String CONTENT_TYPE_JSON = "application/json";
 33     private static final int CONNECTION_TIMEOUT_MS = 60000;
 34     private static final int SO_TIMEOUT_MS = 60000;
 35 
 36     private static void init() {
 37         if (cm == null) {
 38             cm = new PoolingHttpClientConnectionManager();
 39             cm.setMaxTotal(50);// 整个连接池最大连接数
 40             cm.setDefaultMaxPerRoute(5);// 每路由最大连接数，默认值是2
 41             SocketConfig sc = SocketConfig.custom().setSoTimeout(SO_TIMEOUT_MS).build();
 42             cm.setDefaultSocketConfig(sc);
 43         }
 44     }
 45 
 46     /**
 47      * 通过连接池获取HttpClient
 48      *
 49      * @return
 50      */
 51     private static CloseableHttpClient getHttpClient() {
 52         init();
 53         return HttpClients.custom().setConnectionManager(cm).setConnectionManagerShared(true) .build();
 54     }
 55 
 56     public static String httpGetRequest(String url) {
 57         HttpGet httpGet = new HttpGet(url);
 58         return getResult(httpGet);
 59     }
 60 
 61     public static String httpGetRequest(String url, Map<String, Object> params) throws URISyntaxException {
 62         URIBuilder ub = new URIBuilder();
 63         ub.setPath(url);
 64 
 65         ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
 66         ub.setParameters(pairs);
 67 
 68         HttpGet httpGet = new HttpGet(ub.build());
 69         return getResult(httpGet);
 70     }
 71 
 72     public static String httpGetRequest(String url, Map<String, Object> headers, Map<String, Object> params)
 73             throws URISyntaxException {
 74         URIBuilder ub = new URIBuilder();
 75         ub.setPath(url);
 76 
 77         ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
 78         ub.setParameters(pairs);
 79 
 80         HttpGet httpGet = new HttpGet(ub.build());
 81         for (Map.Entry<String, Object> param : headers.entrySet()) {
 82             httpGet.addHeader(param.getKey(), String.valueOf(param.getValue()));
 83         }
 84         return getResult(httpGet);
 85     }
 86 
 87     public static String httpPostRequest(String url) {
 88         HttpPost httpPost = new HttpPost(url);
 89         return getResult(httpPost);
 90     }
 91 
 92     public static String httpPostRequest(String url, Map<String, Object> params) throws UnsupportedEncodingException {
 93         HttpPost httpPost = new HttpPost(url);
 94         ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
 95         httpPost.setEntity(new UrlEncodedFormEntity(pairs, CONTENT_TYPE_UTF_8));
 96         return getResult(httpPost);
 97     }
 98 
 99     public static String httpPostRequest(String url, Map<String, Object> headers, Map<String, Object> params)
100             throws UnsupportedEncodingException {
101         HttpPost httpPost = new HttpPost(url);
102 
103         for (Map.Entry<String, Object> param : headers.entrySet()) {
104             httpPost.addHeader(param.getKey(), String.valueOf(param.getValue()));
105         }
106 
107         ArrayList<NameValuePair> pairs = covertParams2NVPS(params);
108         httpPost.setEntity(new UrlEncodedFormEntity(pairs, CONTENT_TYPE_UTF_8));
109 
110         return getResult(httpPost);
111     }
112 
113     public static String httpPostJSON(String url, String json) throws UnsupportedEncodingException {
114         HttpPost httpPost = new HttpPost(url);
115         StringEntity s = new StringEntity(json);
116         s.setContentEncoding(CONTENT_TYPE_UTF_8);
117         s.setContentType(CONTENT_TYPE_JSON);// 发送json数据需要设置contentType
118         httpPost.setEntity(s);
119         return getResult(httpPost);
120     }
121 
122 
123     private static ArrayList<NameValuePair> covertParams2NVPS(Map<String, Object> params) {
124         ArrayList<NameValuePair> pairs = new ArrayList<>();
125         for (Map.Entry<String, Object> param : params.entrySet()) {
126             pairs.add(new BasicNameValuePair(param.getKey(), String.valueOf(param.getValue())));
127         }
128 
129         return pairs;
130     }
131 
132     /**
133      * 处理Http请求
134      *
135      * @param request
136      * @return
137      */
138     private static String getResult(HttpRequestBase request) {
139 
140         RequestConfig.Builder config = RequestConfig.copy(RequestConfig.DEFAULT);
141         config.setConnectionRequestTimeout(CONNECTION_TIMEOUT_MS);
142         config.setSocketTimeout(SO_TIMEOUT_MS);
143 
144         request.setConfig(config.build());
145 
146         // CloseableHttpClient httpClient = HttpClients.createDefault();
147         CloseableHttpClient httpClient = getHttpClient();
148         CloseableHttpResponse response = null;
149         try {
150             response = httpClient.execute(request);
151             // response.getStatusLine().getStatusCode();
152             HttpEntity entity = response.getEntity();
153             if (entity != null) {
154                 // long len = entity.getContentLength();// -1 表示长度未知
155                 return EntityUtils.toString(entity);
156             }
157         } catch (IOException e) {
158             e.printStackTrace();
159         } finally {
160             try {
161                 // 释放Socket流
162                 response.close();
163                 // 释放Connection
164                 // httpClient.close();
165             } catch (IOException e) {
166                 e.printStackTrace();
167             }
168         }
169 
170         return EMPTY_STR;
171     }
172 
173 }