httpclient范例（基于4.3x版本以上）

╰半夏微凉° 2021-11-23 10:18 225阅读 0赞

import lombok.extern.slf4j.Slf4j;
    import org.apache.http.HttpEntity;
    import org.apache.http.client.config.RequestConfig;
    import org.apache.http.client.methods.CloseableHttpResponse;
    import org.apache.http.client.methods.HttpPost;
    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.util.EntityUtils;
    
    import javax.net.ssl.SSLContext;
    import javax.net.ssl.TrustManager;
    import javax.net.ssl.X509TrustManager;
    import java.io.IOException;
    import java.security.cert.CertificateException;
    import java.security.cert.X509Certificate;
    
    @Slf4j
    public class HttpUtils { 
    
        public static String postMessage(String url, String postData, int timeout)  { 
            CloseableHttpClient httpclient = null;
            HttpPost httpPost = null;
            CloseableHttpResponse response = null;
            try { 
                httpclient = getClient(url);
                byte[] data = new byte[0];
                httpPost = new HttpPost(url);
    
                // httpPost.addHeader("Content-Type","application/xml;charset=utf-8");
                // 配置请求的超时设置
                RequestConfig requestConfig = RequestConfig.custom()
                        .setConnectionRequestTimeout(timeout)
                        .setConnectTimeout(timeout).setSocketTimeout(timeout).build();
                httpPost.setConfig(requestConfig);
                httpPost.setEntity(new StringEntity(postData, "UTF-8"));
                response = httpclient.execute(httpPost);
                HttpEntity entity = response.getEntity();
                data = EntityUtils.toByteArray(entity);
                EntityUtils.consume(entity);
                return new String(data);
            } catch (Exception e) { 
                e.printStackTrace();
                log.error("请求异常:", e);
            } finally { 
            // 注意关闭
                if (response != null) { 
                    try { 
                        response.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
                if (httpPost != null) { 
                    httpPost.releaseConnection();
                }
                if (httpclient != null) { 
                    try { 
                        httpclient.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
            }
            return null;
        }
    
    
        private static CloseableHttpClient getClient(String url) throws Exception { 
            if (url.startsWith("https")) { 
                //忽略证书校验
                SSLContext sc = SSLContext.getInstance("TLS");
                sc.init(null, new TrustManager[]{ truseAllManager}, null);
                SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sc, SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
                /** * 通过setSSLSocketFactory(sslsf)保证httpclient实例能发送Https请求 */
                return HttpClients.custom().setSSLSocketFactory(sslsf).disableAutomaticRetries().build();
            } else { 
                return HttpClients.custom().disableAutomaticRetries().disableAutomaticRetries().build();
            }
        }
    
        public static TrustManager truseAllManager = new X509TrustManager() { 
    
            public X509Certificate[] getAcceptedIssuers() { 
                return null;
            }
    
            public void checkServerTrusted(X509Certificate[] arg0, String arg1)
                    throws CertificateException { 
            }
    
            public void checkClientTrusted(X509Certificate[] arg0, String arg1)
                    throws CertificateException { 
            }
        };
    
    }