package com.ltkj.web.wxUtils; import cn.hutool.json.JSONUtil; import lombok.extern.slf4j.Slf4j; import org.apache.http.HttpEntity; import org.apache.http.HttpResponse; import org.apache.http.NameValuePair; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.HttpClient; 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 com.ltkj.web.wxUtils.HttpClientUtils; import org.apache.http.conn.ssl.DefaultHostnameVerifier; import org.apache.http.conn.util.PublicSuffixMatcher; import org.apache.http.conn.util.PublicSuffixMatcherLoader; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.message.BasicNameValuePair; import org.apache.http.util.EntityUtils; import org.springframework.stereotype.Component; import java.io.*; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLEncoder; import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.UUID; /** * httpClient 工具类 * * @create 2019-02-10 下午 2:49 */ @Component @Slf4j public class HttpClientUtils { /** * 默认参数设置 * setConnectTimeout：设置连接超时时间，单位毫秒。 * setConnectionRequestTimeout：设置从connect Manager获取Connection 超时时间，单位毫秒。 * setSocketTimeout：请求获取数据的超时时间，单位毫秒。访问一个接口，多少时间内无法返回数据，就直接放弃此次调用。 暂时定义15分钟 */ private RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(600000).setConnectTimeout(600000).setConnectionRequestTimeout(600000).build(); /** * 静态内部类---作用：单例产生类的实例 * * @author Administrator */ private static class LazyHolder { private static final HttpClientUtils INSTANCE = new HttpClientUtils(); } HttpClientUtils() { } public static HttpClientUtils getInstance() { return LazyHolder.INSTANCE; } /** * 发送 post请求 * * @param httpUrl 地址 */ public String sendHttpPost(String httpUrl) { HttpPost httpPost = new HttpPost(httpUrl);// 创建httpPost return sendHttpPost(httpPost); } /** * 发送 post请求 * * @param httpUrl 地址 * @param params 参数(格式:key1=value1&key2=value2) */ public String sendHttpPost(String httpUrl, String params) { HttpPost httpPost = new HttpPost(httpUrl);// 创建httpPost try { //设置参数 StringEntity stringEntity = new StringEntity(params, "UTF-8"); stringEntity.setContentType("application/x-www-form-urlencoded"); httpPost.setEntity(stringEntity); } catch (Exception e) { e.printStackTrace(); } return sendHttpPost(httpPost); } public static String sendPost(String httpUrl, Map maps) { try { // 1. 创建 URL 对象 URL url = new URL(httpUrl); // 2. 创建 HttpURLConnection 对象 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); // 3. 设置请求方法为 POST connection.setRequestMethod("POST"); // 4. 设置 Content-Type 头部字段 connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); // 6. 向服务器发送数据 String requestBody = JSONUtil.toJsonStr(maps); log.info(httpUrl+"入参: "+requestBody); // String requestBody1 = maps.toString(); byte[] postData = requestBody.getBytes("UTF-8"); connection.setDoOutput(true); try (OutputStream outputStream = connection.getOutputStream()) { outputStream.write(postData); } // 8. 获取响应数据 try (BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8))) { String line; StringBuilder response = new StringBuilder(); while ((line = reader.readLine()) != null) { response.append(line); } log.info("====================================================="); log.info(httpUrl+"出参"); log.info(response.toString()); connection.disconnect(); return response.toString(); } } catch (IOException e) { log.error(String.valueOf(e)); } return null; } public static String sendPostToken(String httpUrl, Map maps,String authorization) { try { // 1. 创建 URL 对象 URL url = new URL(httpUrl); // 2. 创建 HttpURLConnection 对象 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); // 3. 设置请求方法为 POST connection.setRequestMethod("POST"); // 4. 设置 Content-Type 头部字段 connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); connection.setRequestProperty("Authorization", authorization); // 6. 向服务器发送数据 String requestBody = JSONUtil.toJsonStr(maps); log.info(httpUrl+"入参: "+requestBody); // String requestBody1 = maps.toString(); byte[] postData = requestBody.getBytes("UTF-8"); connection.setDoOutput(true); try (OutputStream outputStream = connection.getOutputStream()) { outputStream.write(postData); } // 8. 获取响应数据 try (BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8))) { String line; StringBuilder response = new StringBuilder(); while ((line = reader.readLine()) != null) { response.append(line); } log.info("====================================================="); log.info(httpUrl+"出参"); log.info(response.toString()); connection.disconnect(); return response.toString(); } } catch (IOException e) { e.printStackTrace(); } return null; } public static String sendPostTokenFormUrlencoded(String httpUrl, Map maps, String authorization) { HttpURLConnection connection = null; OutputStreamWriter writer = null; BufferedReader reader = null; StringBuilder response = new StringBuilder(); try { // 创建 URL 对象 URL url = new URL(httpUrl); // 打开连接 connection = (HttpURLConnection) url.openConnection(); // 设置请求方法为 POST connection.setRequestMethod("POST"); // 设置请求头 Content-Type 为 application/x-www-form-urlencoded connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); // 如果需要 Authorization Header if (authorization != null && !authorization.isEmpty()) { connection.setRequestProperty("Authorization", authorization); } // 设置允许输出 connection.setDoOutput(true); // 构建表单数据 StringBuilder postData = new StringBuilder(); for (Map.Entry entry : maps.entrySet()) { if (postData.length() > 0) { postData.append("&"); } postData.append(URLEncoder.encode(entry.getKey(), "UTF-8")) .append("=") .append(URLEncoder.encode(entry.getValue().toString(), "UTF-8")); } // 获取输出流并写入表单数据 writer = new OutputStreamWriter(connection.getOutputStream()); writer.write(postData.toString()); writer.flush(); // 获取响应 reader = new BufferedReader(new InputStreamReader(connection.getInputStream())); String line; while ((line = reader.readLine()) != null) { response.append(line); } } catch (Exception e) { e.printStackTrace(); return null; } finally { // 关闭流 try { if (writer != null) writer.close(); if (reader != null) reader.close(); } catch (IOException e) { e.printStackTrace(); } if (connection != null) { connection.disconnect(); } } return response.toString(); } public static String sendPostTokenFormData(String httpUrl, Map maps, String authorization) { HttpURLConnection connection = null; DataOutputStream outStream = null; BufferedReader reader = null; StringBuilder response = new StringBuilder(); // 边界字符串 String boundary = "----WebKitFormBoundary" + UUID.randomUUID().toString().replaceAll("-", ""); String CRLF = "\r\n"; // 换行符 try { // 创建 URL 对象 URL url = new URL(httpUrl); // 打开连接 connection = (HttpURLConnection) url.openConnection(); // 设置请求方法为 POST connection.setRequestMethod("POST"); // 设置请求头 Content-Type 为 multipart/form-data connection.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + boundary); // 如果需要 Authorization Header if (authorization != null && !authorization.isEmpty()) { connection.setRequestProperty("Authorization", authorization); } // 设置允许输出 connection.setDoOutput(true); // 获取输出流 outStream = new DataOutputStream(connection.getOutputStream()); // 遍历传入的表单数据，并按照 multipart/form-data 格式写入 for (Map.Entry entry : maps.entrySet()) { outStream.writeBytes("--" + boundary + CRLF); outStream.writeBytes("Content-Disposition: form-data; name=\"" + entry.getKey() + "\"" + CRLF); outStream.writeBytes("Content-Type: text/plain; charset=UTF-8" + CRLF); outStream.writeBytes(CRLF); // 这里是分隔符，空一行 outStream.writeBytes(entry.getValue().toString() + CRLF); } // 结束 multipart/form-data 发送数据部分 outStream.writeBytes("--" + boundary + "--" + CRLF); // 刷新输出流 outStream.flush(); // 获取响应 reader = new BufferedReader(new InputStreamReader(connection.getInputStream())); String line; while ((line = reader.readLine()) != null) { response.append(line); } } catch (Exception e) { e.printStackTrace(); return null; } finally { // 关闭流 try { if (outStream != null) outStream.close(); if (reader != null) reader.close(); } catch (IOException e) { e.printStackTrace(); } if (connection != null) { connection.disconnect(); } } return response.toString(); } /** * 发送 post请求 * * @param httpUrl 地址 * @param maps 参数 */ public String sendHttpPost(String httpUrl, Map maps) { HttpPost httpPost = new HttpPost(httpUrl);// 创建httpPost // 创建参数队列 List nameValuePairs = new ArrayList(); for (String key : maps.keySet()) { nameValuePairs.add(new BasicNameValuePair(key, maps.get(key))); } try { httpPost.setEntity(new UrlEncodedFormEntity(nameValuePairs, "UTF-8")); } catch (Exception e) { e.printStackTrace(); } return sendHttpPost(httpPost); } /** * 发送Post请求 * * @param httpPost * @return */ private String sendHttpPost(HttpPost httpPost) { CloseableHttpClient httpClient = null; CloseableHttpResponse response = null; HttpEntity entity = null; String responseContent = null; try { // 创建默认的httpClient实例 httpClient = HttpClients.createDefault(); httpPost.setConfig(requestConfig); // 执行请求 long execStart = System.currentTimeMillis(); response = httpClient.execute(httpPost); long execEnd = System.currentTimeMillis(); System.out.println("=================执行post请求耗时：" + (execEnd - execStart) + "ms"); long getStart = System.currentTimeMillis(); entity = response.getEntity(); responseContent = EntityUtils.toString(entity, "UTF-8"); long getEnd = System.currentTimeMillis(); System.out.println("=================获取响应结果耗时：" + (getEnd - getStart) + "ms"); } catch (Exception e) { e.printStackTrace(); } finally { try { // 关闭连接,释放资源 if (response != null) { response.close(); } if (httpClient != null) { httpClient.close(); } } catch (IOException e) { e.printStackTrace(); } } return responseContent; } /** * 发送 get请求 * * @param httpUrl */ public String sendHttpGet(String httpUrl) { HttpGet httpGet = new HttpGet(httpUrl);// 创建get请求 return sendHttpGet(httpGet); } /** * 发送 get请求Https * * @param httpUrl */ public String sendHttpsGet(String httpUrl) { HttpGet httpGet = new HttpGet(httpUrl);// 创建get请求 return sendHttpsGet(httpGet); } /** * 发送Get请求 * * @param httpGet * @return */ private String sendHttpGet(HttpGet httpGet) { CloseableHttpClient httpClient = null; CloseableHttpResponse response = null; HttpEntity entity = null; String responseContent = null; try { // 创建默认的httpClient实例. httpClient = HttpClients.createDefault(); httpGet.setConfig(requestConfig); // 执行请求 response = httpClient.execute(httpGet); entity = response.getEntity(); responseContent = EntityUtils.toString(entity, "UTF-8"); } catch (Exception e) { e.printStackTrace(); } finally { try { // 关闭连接,释放资源 if (response != null) { response.close(); } if (httpClient != null) { httpClient.close(); } } catch (IOException e) { e.printStackTrace(); } } return responseContent; } /** * 发送Get请求Https * * @param httpGet * @return */ private String sendHttpsGet(HttpGet httpGet) { CloseableHttpClient httpClient = null; CloseableHttpResponse response = null; HttpEntity entity = null; String responseContent = null; try { // 创建默认的httpClient实例. PublicSuffixMatcher publicSuffixMatcher = PublicSuffixMatcherLoader.load(new URL(httpGet.getURI().toString())); DefaultHostnameVerifier hostnameVerifier = new DefaultHostnameVerifier(publicSuffixMatcher); httpClient = HttpClients.custom().setSSLHostnameVerifier(hostnameVerifier).build(); httpGet.setConfig(requestConfig); // 执行请求 response = httpClient.execute(httpGet); entity = response.getEntity(); responseContent = EntityUtils.toString(entity, "UTF-8"); } catch (Exception e) { e.printStackTrace(); } finally { try { // 关闭连接,释放资源 if (response != null) { response.close(); } if (httpClient != null) { httpClient.close(); } } catch (IOException e) { e.printStackTrace(); } } return responseContent; } /** * 发送xml数据 * * @param url * @param xmlData * @return * @throws ClientProtocolException * @throws IOException */ public static HttpResponse sendXMLDataByPost(String url, String xmlData) throws ClientProtocolException, IOException { HttpClient httpClient = HttpClients.createDefault(); HttpPost httppost = new HttpPost(url); StringEntity entity = new StringEntity(xmlData); httppost.setEntity(entity); httppost.setHeader("Content-Type", "text/xml;charset=UTF-8"); HttpResponse response = httpClient.execute(httppost); return response; } /** * 获得响应HTTP实体内容 * * @param response * @return * @throws IOException * @throws UnsupportedEncodingException */ public static String getHttpEntityContent(HttpResponse response) throws IOException, UnsupportedEncodingException { HttpEntity entity = response.getEntity(); if (entity != null) { InputStream is = entity.getContent(); BufferedReader br = new BufferedReader(new InputStreamReader(is, "UTF-8")); String line = br.readLine(); StringBuilder sb = new StringBuilder(); while (line != null) { sb.append(line + "\n"); line = br.readLine(); } return sb.toString(); } return ""; } public static String sendPost(String httpUrl, Map maps,String token) { try { // 1. 创建 URL 对象 URL url = new URL(httpUrl); // 2. 创建 HttpURLConnection 对象 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); // 3. 设置请求方法为 POST connection.setRequestMethod("POST"); // 4. 设置 Content-Type 头部字段 connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8"); //设置请求token connection.setRequestProperty("Authorization",token); // 6. 向服务器发送数据 String requestBody = JSONUtil.toJsonStr(maps); log.info(httpUrl+"入参: "+requestBody); // String requestBody1 = maps.toString(); byte[] postData = requestBody.getBytes("UTF-8"); connection.setDoOutput(true); try (OutputStream outputStream = connection.getOutputStream()) { outputStream.write(postData); } // 8. 获取响应数据 try (BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8))) { String line; StringBuilder response = new StringBuilder(); while ((line = reader.readLine()) != null) { response.append(line); } log.info("====================================================="); log.info(httpUrl+"出参"); log.info(response.toString()); connection.disconnect(); return response.toString(); } } catch (IOException e) { e.printStackTrace(); } return null; } }