package com.stylefeng.guns.modular.system.util; import com.alibaba.fastjson.JSON; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.http.NameValuePair; 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.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.entity.ContentType; 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.message.BasicNameValuePair; import org.apache.http.ssl.SSLContexts; import org.apache.http.util.EntityUtils; import org.springframework.stereotype.Component; import javax.net.ssl.SSLContext; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.nio.charset.Charset; import java.security.KeyStore; import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.TimeUnit; /** * http工具类 */ @Component public class HttpClientUtil { private CloseableHttpClient httpClient; private CloseableHttpResponse httpResponse; private RequestConfig requestConfig; /** * 创建一个httpClient对象 */ // private void getHttpCline(){ // //1.创建连接池管理器 // PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(60000, // TimeUnit.MILLISECONDS); // connectionManager.setMaxTotal(1000); // connectionManager.setDefaultMaxPerRoute(50); // // //2.创建httpclient对象 // this.httpClient = HttpClients.custom() // .setConnectionManager(connectionManager) // .disableAutomaticRetries() // .build(); // } private PoolingHttpClientConnectionManager connectionManager; /** * 创建一个httpClient对象 */ private CloseableHttpClient getHttpCline(){ return HttpClients.custom() .setConnectionManager(connectionManager) .disableAutomaticRetries() .build(); } private RequestConfig getRequestConfig(){ return RequestConfig.custom() .setConnectTimeout(60000) .setSocketTimeout(60000) .build(); } /** * 创建一个POST请求实例 * @param url 请求地址 * @param params 请求参数 */ private CloseableHttpResponse setPostHttpRequset(String url, Map params, Map header, String contentType) throws Exception{ HttpPost httpPost = new HttpPost(url); httpPost.setConfig(this.getRequestConfig()); if(null != header){ for(String key : header.keySet()){ httpPost.setHeader(key, header.get(key)); } } List list = new ArrayList<>(); if(null != params){ Set keys = params.keySet(); for(String key : keys){ list.add(new BasicNameValuePair(key, null == params.get(key) ? null : params.get(key).toString())); } } switch (contentType){ case "form": httpPost.setEntity(new UrlEncodedFormEntity(list, "UTF-8")); break; case "json": ObjectMapper objectMapper = new ObjectMapper(); String s =objectMapper.writeValueAsString(params); httpPost.setEntity(new StringEntity(s, ContentType.create(ContentType.APPLICATION_JSON.getMimeType(), Charset.forName("UTF-8")))); break; } return getHttpCline().execute(httpPost); } /** * 获取get请求实例 * @param url 请求地址 * @param params 请求参数 */ private CloseableHttpResponse setGetHttpRequset(String url, Map params, Map header) throws Exception{ StringBuffer sb = new StringBuffer(); String p = ""; if(null != params){ Set keys = params.keySet(); for(String key : keys){ sb.append(key + "=" + params.get(key) + "&"); } p = "?" + sb.substring(0, sb.length() - 1); } HttpGet httpGet = new HttpGet(url + p); httpGet.setConfig(getRequestConfig()); if(null != header){ for(String key : header.keySet()){ httpGet.setHeader(key, header.get(key)); } } return getHttpCline().execute(httpGet); } /** * 获取get请求实例 * @param url 请求地址 * @param params 请求参数 */ // private CloseableHttpResponse setGetHttpRequset(String url, Map params, Map header) throws Exception{ // StringBuffer sb = new StringBuffer(); // String p = ""; // if(null != params){ // Set keys = params.keySet(); // for(String key : keys){ // sb.append(key + "=" + params.get(key) + "&"); // } // p = "?" + sb.substring(0, sb.length() - 1); // } // HttpGet httpGet = new HttpGet(url + p); // httpGet.setConfig(getRequestConfig()); // if(null != header){ // for(String key : header.keySet()){ // httpGet.setHeader(key, header.get(key)); // } // } // return getHttpCline().execute(httpGet); // } // /** // * 发送http请求 // * @param mothed "GET、POST、PUT、HEAD、DELETE、HEAD、OPTIONS" // * @param url 请求地址 // * @param params 请求参数 // * @param header 请求头 // * @param contentType 参数请求方式form/json // * @return // */ // public String pushHttpRequset(String mothed, String url, Map params, Map header, String contentType){ // String content = null; // switch (mothed){ // case "GET": // this.setGetHttpRequset(url, params, header); // break; // case "POST": // this.setPostHttpRequset(url, params, header, contentType); // break; // } // if(httpResponse.getStatusLine().getStatusCode() == 200){ // try { // content = EntityUtils.toString(httpResponse.getEntity()); // this.close(); // return content; // } catch (IOException e) { // e.printStackTrace(); // this.close(); // } // } // if(httpResponse.getStatusLine().getStatusCode() == 201){ // content = "{\"status\":201}"; // this.close(); // return content; // }else{ // try { // System.err.println("返回状态码：" + httpResponse.getStatusLine() + "。"); // content = EntityUtils.toString(httpResponse.getEntity()); // this.close(); // return content; // } catch (IOException e) { // e.printStackTrace(); // this.close(); // } // } // this.close(); // return content; // } /** * 发送http请求 * @param mothed "GET、POST、PUT、HEAD、DELETE、HEAD、OPTIONS" * @param url 请求地址 * @param params 请求参数 * @param header 请求头 * @param contentType 参数请求方式form/json * @return */ public HttpResult pushHttpRequset(String mothed, String url, Map params, Map header, String contentType) throws Exception{ String randome = UUID.randomUUID().toString(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:S"); System.err.println(sdf.format(new Date()) + "----（" + randome + "）请求参数：" + JSON.toJSONString(params)); CloseableHttpResponse httpResponse = null; switch (mothed){ case "GET": httpResponse = this.setGetHttpRequset(url, params, header); break; case "POST": httpResponse = setPostHttpRequset(url, params, header, contentType); break; } int statusCode = httpResponse.getStatusLine().getStatusCode(); String content = EntityUtils.toString(httpResponse.getEntity(), "UTF-8"); System.err.println(sdf.format(new Date()) + "----（" + randome + "）返回结果：" + content); HttpResult httpResult = HttpResult.getHttpResult(statusCode, content); this.close(httpResponse); return httpResult; } /** * 发送XML请求 * @param url 请求地址 * @param xml XML数据 * @param header 自定义请求头 * @return */ public HttpResult pushHttpRequsetXml(String url, String xml, Map header) throws Exception{ HttpPost httpPost = new HttpPost(url); httpPost.setConfig(getRequestConfig()); for(String key : header.keySet()){ httpPost.setHeader(key, header.get(key)); } httpPost.setHeader("Content-Type", "application/xml"); httpPost.setEntity(new StringEntity(xml, "UTF-8")); CloseableHttpResponse httpResponse = getHttpCline().execute(httpPost); int statusCode = httpResponse.getStatusLine().getStatusCode(); String content = EntityUtils.toString(httpResponse.getEntity(), "UTF-8"); HttpResult httpResult = HttpResult.getHttpResult(statusCode, content); this.close(httpResponse); return httpResult; } /** * 请求https发送XML请求 * @param url 接口路径 * @param xml 内容 * @param header 请求头 * @param certPassword 证书密码 * @param certPath 证书路径 * @param certType 证书类型 * @return * @throws Exception */ public String pushHttpsRequsetXml(String url, String xml, Map header, String certPassword, String certPath, String certType) throws Exception{ HttpPost httpPost = new HttpPost(url); for(String key : header.keySet()){ httpPost.setHeader(key, header.get(key)); } httpPost.setHeader("Content-Type", "application/xml"); httpPost.setEntity(new StringEntity(xml, "UTF-8")); CloseableHttpClient httpCline = this.initCert(certPassword, certPath, certType); CloseableHttpResponse httpResponse = httpCline.execute(httpPost); String content = null; if(httpResponse.getStatusLine().getStatusCode() == 200){ content = EntityUtils.toString(httpResponse.getEntity(), "UTF-8"); }else{ content = "返回状态码：" + httpResponse.getStatusLine() + "。" + EntityUtils.toString(httpResponse.getEntity()); } this.close(httpResponse); httpCline.close(); return content; } /** * 初始化https对象（带证书） * @param key 证书密码 * @param certPath 证书路径 * @param certType 证书类型 * @throws Exception */ private CloseableHttpClient initCert(String key, String certPath, String certType) throws Exception { KeyStore keyStore = KeyStore.getInstance(certType); InputStream inputStream = new FileInputStream(new File(certPath)); try { keyStore.load(inputStream, key.toCharArray()); } finally { inputStream.close(); } SSLContext sslcontext = SSLContexts.custom().loadKeyMaterial(keyStore, key.toCharArray()).build(); SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext, new String[] {"TLSv1"}, null, SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER); return HttpClients.custom().setSSLSocketFactory(sslsf).build(); } /** * 关闭资源 */ private void close(CloseableHttpResponse httpResponse){ try { if(null != httpResponse){ EntityUtils.consume(httpResponse.getEntity());//此处高能，通过源码分析，由EntityUtils是否回收HttpEntity httpResponse.close(); } } catch (Exception e) { e.printStackTrace(); }finally { try { if(null != httpResponse){ httpResponse.close(); } }catch (Exception e){ e.printStackTrace(); } } } }