如何编写一个支持长尾关键词的HTTP请求工具类？

本文共计683个文字，预计阅读时间需要3分钟。

javaimport net.sf.json.JSONObject;import org.apache.commons.lang.StringUtils;import org.apache.http.HttpEntity;import org.apache.http.client.methods.CloseableHttpResponse;import org.apache.http.client.methods.HttpGet;

HttpClientUtils.txt

import net.sf.json.JSONObject; import org.apache.commons.lang.StringUtils; import org.apache.http.HttpEntity; 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.client.protocol.HttpClientContext; import org.apache.http.config.Registry; import org.apache.http.config.RegistryBuilder; import org.apache.http.conn.socket.ConnectionSocketFactory; import org.apache.http.conn.socket.LayeredConnectionSocketFactory; import org.apache.http.conn.socket.PlainConnectionSocketFactory; import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.util.EntityUtils; import java.io.IOException; import java.util.Map; /** * Created by frt on 2017/10/30. * */ public class HttpClientUtils { private static PoolingHttpClientConnectionManager connectionManager = null; private static CloseableHttpClient httpClient = null; private static final String DEFAULT_CHARSET = "UTF-8"; private HttpClientUtils(){ } static { ConnectionSocketFactory plainFactory = PlainConnectionSocketFactory.getSocketFactory(); LayeredConnectionSocketFactory sslFactory = SSLConnectionSocketFactory.getSocketFactory(); Registry registry = RegistryBuilder. create() .register("http", plainFactory) .register("https", sslFactory) .build(); connectionManager = new PoolingHttpClientConnectionManager(registry); //设置最大连接数 connectionManager.setMaxTotal(200); //设置每个路由最大连接数 connectionManager.setDefaultMaxPerRoute(20); } private synchronized static CloseableHttpClient getHttpClient(){ if(httpClient==null){ httpClient = HttpClients.custom().setConnectionManager(connectionManager).build(); } return httpClient; } private static HttpEntity getHttpEntity(String url) throws IOException { CloseableHttpClient httpClient = HttpClientUtils.getHttpClient(); HttpGet httpGet = new HttpGet(url); CloseableHttpResponse response = httpClient.execute(httpGet, HttpClientContext.create()); return response.getEntity(); } private static String getQueryString(Map params) { if (params!=null && params.size()>0) { StringBuilder query = new StringBuilder(); for (String key : params.keySet()) { Object val = params.get(key); if (val == null) { continue; } if (val instanceof String || val instanceof Number) { query.append(key).append("=").append(val).append("&"); } else if (val instanceof Number[]) { Number[] arr = (Number[]) val; for (Number a : arr) { query.append(key).append("=").append(a).append("&"); } } else if (val instanceof String[]) { String[] arr = (String[]) val; for (String a : arr) { query.append(key).append("=").append(a).append("&"); } } else if (val instanceof int[]) { int[] arr = (int[]) val; for (int a : arr) { query.append(key).append("=").append(a).append("&"); } } else if (val instanceof double[]) { double[] arr = (double[]) val; for (double a : arr) { query.append(key).append("=").append(a).append("&"); } } else if (val instanceof long[]) { long[] arr = (long[]) val; for (long a : arr) { query.append(key).append("=").append(a).append("&"); } } } String temp = query.toString(); return temp.length()>0 ? temp.substring(0, temp.length() - 1) : temp; } return ""; } private static String getMethod(String url, String charset, Map params) throws IOException { String queryString = HttpClientUtils.getQueryString(params); String requestUrl = StringUtils.isBlank(queryString) ? url : url + "?" + queryString; HttpEntity httpEntity = HttpClientUtils.getHttpEntity(requestUrl); String result = EntityUtils.toString(httpEntity, charset); EntityUtils.consume(httpEntity); return result; } private static String postMethod(String url, String charset, Object param) throws IOException { CloseableHttpClient httpClient = HttpClientUtils.getHttpClient(); HttpPost httpPost = new HttpPost(url); httpPost.addHeader("Content-type", "application/json; charset=utf-8"); httpPost.setHeader("Accept", "application/json"); JSONObject jsonObject = JSONObject.fromObject(param); StringEntity stringEntity = new StringEntity(jsonObject.toString(), charset); stringEntity.setContentEncoding(charset); stringEntity.setContentType("application/json"); httpPost.setEntity(stringEntity); CloseableHttpResponse httpResponse = httpClient.execute(httpPost); HttpEntity httpEntity = httpResponse.getEntity(); String result = EntityUtils.toString(httpEntity, charset); EntityUtils.consume(httpEntity); return result; } public static String doGet(String url) throws IOException { return HttpClientUtils.getMethod(url, DEFAULT_CHARSET, null); } public static String doGet(String url, String charset) throws IOException { return HttpClientUtils.getMethod(url, charset, null); } public static String doGet(String url, Map params) throws IOException { return HttpClientUtils.getMethod(url, DEFAULT_CHARSET, params); } public static String doGet(String url, String charset, Map params) throws IOException { return HttpClientUtils.getMethod(url, charset, params); } public static String doPost(String url, Object param) throws IOException { return HttpClientUtils.postMethod(url, DEFAULT_CHARSET, param); } public static String doPost(String url, String charset, Object param) throws IOException { return HttpClientUtils.postMethod(url, charset, param); } }