Http 工具類 連線池 多中請求方式 HttpClient4 Util 引數 XML請求 json 請求 form 表單請求
阿新 • • 發佈：2019-01-09
import com.google.common.base.Strings; import com.google.common.collect.Lists; import org.apache.http.*; import org.apache.http.client.config.RequestConfig; import org.apache.http.client.entity.UrlEncodedFormEntity; 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.utils.URIBuilder; import org.apache.http.config.Registry; import org.apache.http.config.RegistryBuilder; import org.apache.http.conn.ConnectionKeepAliveStrategy; 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.HttpClientBuilder; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.message.BasicHeaderElementIterator; import org.apache.http.message.BasicNameValuePair; import org.apache.http.protocol.HTTP; import org.apache.http.protocol.HttpContext; import org.apache.http.util.EntityUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.net.ssl.SSLContext; import javax.net.ssl.TrustManager; import javax.net.ssl.X509TrustManager; import java.io.IOException; import java.security.KeyManagementException; import java.security.NoSuchAlgorithmException; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; public class HttpClient4Util { private final static Logger logger = LoggerFactory.getLogger(HttpClient4Util.class); private final static int connectCheckWait = 60000; // 微妙 1分鐘 private final static int IdleConnection = 65;// 秒 private CloseableHttpClient httpclient; private RequestConfig requestConfig; private PoolingHttpClientConnectionManager connManager; private static HttpClient4Util httpClient4UtilNew; private volatile boolean shutdown; public synchronized static HttpClient4Util getInstance() { if (httpClient4UtilNew == null) { httpClient4UtilNew = new HttpClient4Util(); httpClient4UtilNew.init(); } return httpClient4UtilNew; } private HttpClient4Util() { } /** * 建構函式 * * @throws NoSuchAlgorithmException * @throws KeyManagementException */ public void init() { SSLContext sslCtx = null; try { sslCtx = SSLContext.getInstance("TLS"); } catch (NoSuchAlgorithmException e1) { logger.error("", e1); throw new RuntimeException(e1); } X509TrustManager trustManager = new X509TrustManager() { public X509Certificate[] getAcceptedIssuers() { return null; } public void checkClientTrusted(X509Certificate[] arg0, String arg1) throws CertificateException { } public void checkServerTrusted(X509Certificate[] arg0, String arg1) throws CertificateException { } }; try { sslCtx.init(null, new TrustManager[] { trustManager }, null); } catch (KeyManagementException e1) { logger.error("", e1); throw new RuntimeException(e1); } @SuppressWarnings("deprecation") LayeredConnectionSocketFactory sslSocketFactory = new SSLConnectionSocketFactory(sslCtx, SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER); RegistryBuilder<ConnectionSocketFactory> registryBuilder = RegistryBuilder.<ConnectionSocketFactory>create(); ConnectionSocketFactory plainSocketFactory = new PlainConnectionSocketFactory(); registryBuilder.register("http", plainSocketFactory); registryBuilder.register("https", sslSocketFactory); Registry<ConnectionSocketFactory> registry = registryBuilder.build(); // 設定連線管理器 connManager = new PoolingHttpClientConnectionManager(registry); // 設定最大連線數 connManager.setMaxTotal(200); // 設定每個路由基礎的連線 connManager.setDefaultMaxPerRoute(20); // 連線保持活躍策略 ConnectionKeepAliveStrategy myStrategy = new ConnectionKeepAliveStrategy() { @Override public long getKeepAliveDuration(HttpResponse response, HttpContext context) { // 獲取'keep-alive'HTTP報文頭 HeaderElementIterator it = new BasicHeaderElementIterator( response.headerIterator(HTTP.CONN_KEEP_ALIVE)); while (it.hasNext()) { HeaderElement he = it.nextElement(); String param = he.getName(); String value = he.getValue(); if (value != null && param.equalsIgnoreCase("timeout")) { try { return Long.parseLong(value) * 1000; } catch (NumberFormatException ignore) { } } } // 保持20秒活躍 return 20 * 1000; } }; httpclient = HttpClientBuilder.create().setConnectionManager(connManager).setKeepAliveStrategy(myStrategy) .build(); requestConfig = RequestConfig.custom().setConnectTimeout(5000).setSocketTimeout(20000).build(); shutdown = false; new Thread(new Runnable() { @Override public void run() { while (!shutdown) { try { synchronized (this) { wait(connectCheckWait); // 關閉過期的連線 connManager.closeExpiredConnections(); // 關閉超過40秒的空閒連線 connManager.closeIdleConnections(IdleConnection, TimeUnit.SECONDS); } } catch (Exception e) { logger.error(e.getLocalizedMessage(), e); } } } }).start(); } /** * 基本的Get請求 * * @param url * 請求URL * @param nameValuePairs * 請求List<NameValuePair>查詢引數 * @return */ public byte[] doGet(String url, Map<String, String> nameValuePairs) { CloseableHttpResponse response = null; HttpGet httpget = new HttpGet(); try { URIBuilder builder = new URIBuilder(url); // 填入查詢引數 if (nameValuePairs != null && !nameValuePairs.isEmpty()) { List<NameValuePair> params = new ArrayList<NameValuePair>(); for (String key : nameValuePairs.keySet()) { params.add(new BasicNameValuePair(key, nameValuePairs.get(key))); } builder.setParameters(params); } httpget.setURI(builder.build()); httpget.setConfig(requestConfig); response = httpclient.execute(httpget); HttpEntity entity = response.getEntity(); int stateCode = response.getStatusLine().getStatusCode(); if (200 != stateCode) { logger.error("非正常響應[" + stateCode + "]", new String(EntityUtils.toByteArray(entity), "UTF-8")); return null; } if (entity != null) { return EntityUtils.toByteArray(entity); } return null; } catch (Exception e) { logger.error("", e); // throw new RuntimeException(e); return null; } finally { try { if (response != null) { response.close(); } } catch (IOException e) { logger.error("", e); // throw e; } } } /** * * @param url * @param queryParams * @param formParams * @return */ public byte[] doPost(String url, Map<String, String> queryParams, Map<String, String> formParams) { if (Strings.isNullOrEmpty(url)) { return null; } CloseableHttpResponse response = null; HttpPost httppost = new HttpPost(); try { httppost.setConfig(requestConfig); URIBuilder builder = new URIBuilder(url); // 填入查詢引數 if (queryParams != null && !queryParams.isEmpty()) { List<NameValuePair> params = Lists.newArrayList(); for (String key : queryParams.keySet()) { params.add(new BasicNameValuePair(key, queryParams.get(key))); } builder.setParameters(params); } httppost.setURI(builder.build()); if (formParams != null && !formParams.isEmpty()) { List<NameValuePair> params = Lists.newArrayList(); for (String key : formParams.keySet()) { params.add(new BasicNameValuePair(key, formParams.get(key))); } StringEntity reqentity = new UrlEncodedFormEntity(params, "UTF-8"); reqentity.setContentEncoding("UTF-8"); httppost.setEntity(reqentity); } response = httpclient.execute(httppost); HttpEntity entity = response.getEntity(); int stateCode = response.getStatusLine().getStatusCode(); if (200 != stateCode) { logger.error("非正常響應[" + stateCode + "]", new String(EntityUtils.toByteArray(entity), "UTF-8")); return null; } if (entity != null) { return EntityUtils.toByteArray(entity); } } catch (Exception e) { logger.error("", e); // throw new RuntimeException(e); } finally { try { httppost.releaseConnection(); } catch (Exception e1) { logger.error("", e1); } try { if (response != null) { response.close(); } } catch (IOException e) { logger.error("", e); // throw e; } } return null; } /** * * @param url * @param queryParams * @param formParams * @return */ public byte[] doPost(String url, Map<String, String> queryParams, Map<String, String> formParams, int connTimeout, int reqTimeout) { if (Strings.isNullOrEmpty(url)) { return null; } CloseableHttpResponse response = null; HttpPost httppost = new HttpPost(); try { RequestConfig config = RequestConfig.custom().setConnectTimeout(connTimeout).setSocketTimeout(reqTimeout) .build(); httppost.setConfig(config); URIBuilder builder = new URIBuilder(url); // 填入查詢引數 if (queryParams != null && !queryParams.isEmpty()) { List<NameValuePair> params = Lists.newArrayList(); for (String key : queryParams.keySet()) { params.add(new BasicNameValuePair(key, queryParams.get(key))); } builder.setParameters(params); } httppost.setURI(builder.build()); if (formParams != null && !formParams.isEmpty()) { List<NameValuePair> params = Lists.newArrayList(); for (String key : formParams.keySet()) { params.add(new BasicNameValuePair(key, formParams.get(key))); } StringEntity reqentity = new UrlEncodedFormEntity(params, "UTF-8"); reqentity.setContentEncoding("UTF-8"); httppost.setEntity(reqentity); } response = httpclient.execute(httppost); HttpEntity entity = response.getEntity(); int stateCode = response.getStatusLine().getStatusCode(); if (200 != stateCode) { logger.error("非正常響應[" + stateCode + "]", new String(EntityUtils.toByteArray(entity), "UTF-8")); return null; } if (entity != null) { return EntityUtils.toByteArray(entity); } } catch (Exception e) { logger.error("", e); // throw new RuntimeException(e); } finally { try { httppost.releaseConnection(); } catch (Exception e1) { logger.error("", e1); } try { if (response != null) { response.close(); } } catch (IOException e) { logger.error("", e); // throw e; } } return null; } /** * * @param url * @param queryParams * @param formParams * @return */ public byte[] doPostJson(String url, String jsonData) { if (Strings.isNullOrEmpty(url)) { return null; } CloseableHttpResponse response = null; HttpPost httppost = new HttpPost(); try { URIBuilder builder = new URIBuilder(url); httppost.setURI(builder.build()); httppost.setConfig(requestConfig); httppost.setHeader("Content-Type", "application/json; charset=UTF-8"); StringEntity reqentity = new StringEntity(jsonData, "UTF-8"); reqentity.setContentType("application/json;charset=UTF-8"); reqentity.setContentEncoding("UTF-8"); httppost.setEntity(reqentity); response = httpclient.execute(httppost); HttpEntity entity = response.getEntity(); int stateCode = response.getStatusLine().getStatusCode(); if (200 != stateCode) { logger.error("非正常響應[" + stateCode + "]", new String(EntityUtils.toByteArray(entity), "UTF-8")); return null; } if (entity != null) { return EntityUtils.toByteArray(entity); } } catch (Exception e) { logger.error("", e); // throw new RuntimeException(e); } finally { try { httppost.releaseConnection(); } catch (Exception e1) { logger.error("", e1); } try { if (response != null) { response.close(); } } catch (IOException e) { logger.error("", e); // throw e; } } return null; } /** * * @param url * @param queryParams * @param formParams * @return */ public byte[] doPostXml(String url, String jsonData) { if (Strings.isNullOrEmpty(url)) { return null; } CloseableHttpResponse response = null; HttpPost httppost = new HttpPost(); try { URIBuilder builder = new URIBuilder(url); httppost.setURI(builder.build()); httppost.setConfig(requestConfig); httppost.setHeader("Content-Type", "application/xml; charset=UTF-8"); StringEntity reqentity = new StringEntity(jsonData, "UTF-8"); reqentity.setContentType("application/xml;charset=UTF-8"); reqentity.setContentEncoding("UTF-8"); httppost.setEntity(reqentity); response = httpclient.execute(httppost); HttpEntity entity = response.getEntity(); int stateCode = response.getStatusLine().getStatusCode(); if (200 != stateCode) { logger.error("非正常響應[" + stateCode + "]", new String(EntityUtils.toByteArray(entity), "UTF-8")); return null; } if (entity != null) { return EntityUtils.toByteArray(entity); } } catch (Exception e) { logger.error("", e); // throw new RuntimeException(e); } finally { try { httppost.releaseConnection(); } catch (Exception e1) { logger.error("", e1); } try { if (response != null) { response.close(); } } catch (IOException e) { logger.error("", e); // throw e; } } return null; } public void shutdown() throws IOException { shutdown = true; connManager.shutdown(); httpclient.close(); synchronized (this) { notifyAll(); } } }
希望對你有用