HttpUtil工具类，发送Get/Post请求，支持Http和Https协议
使用用Httpclient封装的HttpUtil工具类，发送Get/Post请求
1. maven引入httpclient依赖 <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpclient</artifactId> <version>4.5.12</version> </dependency> 2. GET请求 public static String doGet(String path, Map<String, String> param, Map<String, String> headers) { HttpGet httpGet = null; CloseableHttpResponse response = null; CloseableHttpClient httpClient = wrapClient(path); // 创建uri URIBuilder builder = null; try { builder = new URIBuilder(path); if (param != null) { for (String key : param.keySet()) { builder.addParameter(key, param.get(key)); } } URI uri = builder.build(); // 创建http GET请求 httpGet = new HttpGet(uri); if (headers != null && headers.size() > 0) { for (Map.Entry<String, String> entry : headers.entrySet()) { httpGet.addHeader(entry.getKey(), entry.getValue()); } } // 执行请求 response = httpClient.execute(httpGet); // 判断返回状态是否为200 if (response.getStatusLine().getStatusCode() == 200) { return EntityUtils.toString(response.getEntity(), "UTF-8"); } } catch (Exception e) { throw new RuntimeException("[发送Get请求错误：]" + e.getMessage()); } finally { try { httpGet.releaseConnection(); response.close(); if (httpClient != null) { httpClient.close(); } } catch (IOException e) { e.printStackTrace(); } } return null; } 3. POST请求 public static String doPostJson(String url, String jsonParam, Map<String, String> headers) { HttpPost httpPost = null; CloseableHttpResponse response = null; CloseableHttpClient httpClient = wrapClient(url); try { httpPost = new HttpPost(url); //addHeader，如果Header没有定义则添加，已定义则不变，setHeader会重新赋值 httpPost.addHeader("Content-type","application/json;charset=utf-8"); httpPost.setHeader("Accept", "application/json"); StringEntity entity = new StringEntity(jsonParam, StandardCharsets.UTF_8); // entity.setContentType("text/json"); // entity.setContentEncoding(new BasicHeader("Content-Type", "application/json;charset=UTF-8")); httpPost.setEntity(entity); //是否有header if (headers != null && headers.size() > 0) { for (Map.Entry<String, String> entry : headers.entrySet()) { httpPost.addHeader(entry.getKey(), entry.getValue()); } } // 执行请求 response = httpClient.execute(httpPost); // 判断返回状态是否为200 if (response.getStatusLine().getStatusCode() == 200) { return EntityUtils.toString(response.getEntity(), "UTF-8"); } } catch (Exception e) { throw new RuntimeException("[发送POST请求错误：]" + e.getMessage()); } finally { try { httpPost.releaseConnection(); response.close(); if (httpClient != null) { httpClient.close(); } } catch (IOException e) { e.printStackTrace(); } } return null; } 3. 获取httpclient的方法这里会根据url自动匹配需要的是http的还是https的client
private static CloseableHttpClient wrapClient(String url) { CloseableHttpClient client = HttpClientBuilder.create().build(); if (url.startsWith("https")) { client = getCloseableHttpsClients(); } return client; } 4. 对于https的需要自己实现一下client private static CloseableHttpClient getCloseableHttpsClients() { // 采用绕过验证的方式处理https请求 SSLContext sslcontext = createIgnoreVerifySSL(); // 设置协议http和https对应的处理socket链接工厂的对象 Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder.<ConnectionSocketFactory>create() .register("http", PlainConnectionSocketFactory.INSTANCE) .register("https", new SSLConnectionSocketFactory(sslcontext)).build(); PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry); HttpClients.custom().setConnectionManager(connManager); // 创建自定义的httpsclient对象 CloseableHttpClient client = HttpClients.custom().setConnectionManager(connManager).build(); return client; } private static SSLContext createIgnoreVerifySSL() { // 创建套接字对象 SSLContext sslContext = null; try { //指定TLS版本 sslContext = SSLContext.getInstance("TLSv1.2"); } catch (NoSuchAlgorithmException e) { throw new RuntimeException("[创建套接字失败:] " + e.getMessage()); } // 实现X509TrustManager接口，用于绕过验证 X509TrustManager trustManager = new X509TrustManager() { @Override public void checkClientTrusted(java.security.cert.X509Certificate[] paramArrayOfX509Certificate, String paramString) throws CertificateException { } @Override public void checkServerTrusted(java.security.cert.X509Certificate[] paramArrayOfX509Certificate, String paramString) throws CertificateException { } @Override public java.security.cert.X509Certificate[] getAcceptedIssuers() { return null; } }; try { //初始化sslContext对象 sslContext.init(null, new TrustManager[]{trustManager}, null); } catch (KeyManagementException e) { throw new RuntimeException("[初始化套接字失败:] " + e.getMessage()); } return sslContext; }以上全部都测试通过，如果有错误，欢迎大佬们指出，感谢！！！
备注：完整版的点这里
让坚持成为品质，让优秀成为习惯！加油！