httpClient连接池

╰半夏微凉° 2021-09-26 09:14 377阅读 0赞

项目dome github [https://github.com/gyn781369549/httpClient][https_github.com_gyn781369549_httpClient]  
httpClient 4.2.1版本  
实现 post get 请求 https 请求  
pom.xml依赖的包

<dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>
        
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>4.2.1</version>
        </dependency>
        
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.41</version>
        </dependency>

package httpClient.util;
    
    import java.io.ByteArrayInputStream;
    import java.io.IOException;
    import java.security.cert.CertificateException;
    import java.security.cert.X509Certificate;
    import java.util.Date;
    import javax.net.ssl.SSLContext;
    import javax.net.ssl.TrustManager;
    import javax.net.ssl.X509TrustManager;
    import org.apache.commons.logging.Log;
    import org.apache.commons.logging.LogFactory;
    import org.apache.http.HttpEntity;
    import org.apache.http.HttpResponse;
    import org.apache.http.HttpVersion;
    import org.apache.http.ParseException;
    import org.apache.http.client.HttpClient;
    import org.apache.http.client.methods.HttpGet;
    import org.apache.http.client.methods.HttpPost;
    import org.apache.http.conn.scheme.PlainSocketFactory;
    import org.apache.http.conn.scheme.Scheme;
    import org.apache.http.conn.scheme.SchemeRegistry;
    import org.apache.http.conn.ssl.SSLSocketFactory;
    import org.apache.http.entity.StringEntity;
    import org.apache.http.impl.client.DefaultHttpClient;
    import org.apache.http.impl.client.DefaultHttpRequestRetryHandler;
    import org.apache.http.impl.conn.PoolingClientConnectionManager;
    import org.apache.http.params.BasicHttpParams;
    import org.apache.http.params.CoreConnectionPNames;
    import org.apache.http.params.HttpConnectionParams;
    import org.apache.http.params.HttpParams;
    import org.apache.http.params.HttpProtocolParams;
    import org.apache.http.util.EntityUtils;
    import com.alibaba.fastjson.JSONObject;
    
    
    
    public class httpUtil { 
        private static final Log log = LogFactory.getLog(httpUtil.class);
        private static HttpClient httpClient = getHttpClient();
        private static HttpClient postClient = null;
        private static HttpResponse httpResponse = null;
    
        /** * 适合多线程的HttpClient,用httpClient4.2.1实现 * * @return DefaultHttpClient */
        public static DefaultHttpClient getHttpClient() {
            // 设置组件参数, HTTP协议的版本,1.1/1.0/0.9
            HttpParams params = new BasicHttpParams();
    
            HttpProtocolParams.setVersion(params, HttpVersion.HTTP_1_1);
            HttpProtocolParams.setUserAgent(params, "HttpComponents/1.1");
            HttpProtocolParams.setUseExpectContinue(params, false);
    
            // 设置连接超时时间
            final int REQUEST_TIMEOUT = 15 * 1000; // 设置请求超时2秒钟
            final int SO_TIMEOUT = 15 * 1000; // 设置等待数据超时时间2秒钟
            final long CONN_MANAGER_TIMEOUT = 500L; //
            // 该值就是连接不够用的时候等待超时时间，一定要设置，而且不能太大
            //
    
            HttpConnectionParams.setConnectionTimeout(params, REQUEST_TIMEOUT);
            HttpConnectionParams.setSoTimeout(params, SO_TIMEOUT);
            params.setParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, REQUEST_TIMEOUT);
            params.setParameter(CoreConnectionPNames.SO_TIMEOUT, SO_TIMEOUT);
            // params.setLongParameter(ClientPNames.CONN_MANAGER_TIMEOUT,CONN_MANAGER_TIMEOUT);
            params.setBooleanParameter(CoreConnectionPNames.STALE_CONNECTION_CHECK, true);// 在提交请求之前
                                                                                            // 测试连接是否可用
            // 设置访问协议
            SchemeRegistry schreg = new SchemeRegistry();
            schreg.register(new Scheme("http", 80, PlainSocketFactory.getSocketFactory()));
            schreg.register(new Scheme("https", 443, SSLSocketFactory.getSocketFactory()));
    
            // 多连接的线程安全的管理器
            PoolingClientConnectionManager pccm = new PoolingClientConnectionManager(schreg);
            pccm.setMaxTotal(200); // 客户端总并行链接最大数 MaxtTotal是整个池子的大小；
            pccm.setDefaultMaxPerRoute(200); // 每个主机的最大并行链接数
    
            DefaultHttpClient httpClient = new DefaultHttpClient(pccm, params);
            httpClient.setHttpRequestRetryHandler(new DefaultHttpRequestRetryHandler(0, false));// 另外设置http
                                                                                                // client的重试次数，默认是3次；当前是禁用掉（如果项目量不到，这个默认即可）
            return httpClient;
        }
    
        /** * 发送get请求 * * @param url * @return * @throws IOException */
        public static String sendGet(String url) throws IOException {
            int code = 0;
            HttpGet get = new HttpGet(url);
            try {
    
                String cont = null;
    
                if (httpClient == null) {
                    httpClient = getHttpClient();
                }
    
                httpResponse = httpClient.execute(get);
    
                code = httpResponse.getStatusLine().getStatusCode();
                System.out.println(
                        new Date("yyyy mm dd hh mm ss") + ",124row WechatKit.sendGet code:" + code + ",URL " + url);
                if (code >= 200 && code < 300) {
    
                    HttpEntity entity = httpResponse.getEntity();
                    if (entity != null) {
                        cont = EntityUtils.toString(entity);
                        System.out.println(cont);
                        return cont;
                    } else {
                        return Integer.toString(code);
                    }
    
                } else {
                    return Integer.toString(code);
                }
    
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                // if(get!=null){ 
                // get.reset();
                // }
                if (httpResponse != null) {
                    EntityUtils.consume(httpResponse.getEntity());
                }
            }
            return Integer.toString(code);
    
        }
    
        /** * 通过post发送! * * @param url * @param json * @return * @throws IOException * @throws ParseException */
        public static String post(String url, JSONObject json, String token) throws ParseException, IOException {
            HttpPost post = new HttpPost(url);
            int code = 0;
            try {
    
                if (postClient == null) {
                    postClient = getClient(true);
                }
    
                StringEntity s = new StringEntity(json.toString());
                s.setContentEncoding("UTF-8");
                s.setContentType("application/json");// :
                                                        // {“Content-Type”:”application/json”,”Authorization”:”Bearer
                                                        // ${token}”}
                // post.addHeader("Content-Type", "application/json");
                if (token != null) {
                    post.addHeader("Authorization", "Bearer " + token);
                }
                post.setEntity(s);
    
                httpResponse = postClient.execute(post);
                code = httpResponse.getStatusLine().getStatusCode();
                System.out.println("postcode:" + code);
                if (code >= 200 && code < 300) {
                    HttpEntity entity = httpResponse.getEntity();
                    if (entity != null) {
                        String charset = EntityUtils.toString(entity);
                        System.out.println("post返回的东西:" + charset);
                        return charset;
                    } else {
                        return null;
                    }
                } else {
                    return null;
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                if (httpResponse != null) {
                    EntityUtils.consume(httpResponse.getEntity());
                }
                if (post != null) { // 不要忘记释放，尽量通过该方法实现，
    
                    post.releaseConnection();
    
                    // 存在风险，不要用
    
                    // postMethod.setParameter("Connection", "close");
    
                    // InputStream is = postMethod.getResponseBodyAsStream();
    
                    // is.clsoe();也会关闭并释放连接的
    
                }
            }
            return null;
    
        }
        /** * 通过post发送! * * @param url * @param json * @return * @throws IOException * @throws ParseException */
        public static byte[] post(String url, JSONObject json) throws ParseException, IOException {
            HttpPost post = new HttpPost(url);
            int code = 0;
            byte[] responseContent=null;
            try {
    
                if (postClient == null) {
                    postClient = getClient(true);
                }
    
                StringEntity s = new StringEntity(json.toString());
                s.setContentEncoding("UTF-8");
                s.setContentType("text/plain");// :
                                                        // {“Content-Type”:”application/json”,”Authorization”:”Bearer
                                                        // ${token}”}
                // post.addHeader("Content-Type", "application/json");
    
                post.setEntity(s);
    
                httpResponse = postClient.execute(post);
                code = httpResponse.getStatusLine().getStatusCode();
                System.out.println("postcode:" + code);
                if (code >= 200 && code < 300) {
                     responseContent = EntityUtils.toByteArray(httpResponse.getEntity()); 
                     return responseContent;
                } else {
                    return null;
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                if (httpResponse != null) {
                    EntityUtils.consume(httpResponse.getEntity());
                }
                if (post != null) { // 不要忘记释放，尽量通过该方法实现，
    
                    post.releaseConnection();
    
                    // 存在风险，不要用
    
                    // postMethod.setParameter("Connection", "close");
    
                    // InputStream is = postMethod.getResponseBodyAsStream();
    
                    // is.clsoe();也会关闭并释放连接的
    
                }
            }
            return null;
    
        }
    
        /** * * * @param isSSL * @return */
        public static HttpClient getClient(boolean isSSL) {
    
            HttpClient httpClient = getHttpClient();
            if (isSSL) {
                X509TrustManager xtm = new X509TrustManager() {
                    public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
                    }
    
                    public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
                    }
    
                    public X509Certificate[] getAcceptedIssuers() {
                        return null;
                    }
                };
    
                try {
                    SSLContext ctx = SSLContext.getInstance("TLS");
    
                    ctx.init(null, new TrustManager[] { xtm }, null);
    
                    SSLSocketFactory socketFactory = new SSLSocketFactory(ctx);
    
                    httpClient.getConnectionManager().getSchemeRegistry().register(new Scheme("https", 443, socketFactory));
    
                } catch (Exception e) {
                    throw new RuntimeException();
                }
            }
    
            return httpClient;
        }
    
        public static void main(String[] args) throws ParseException, IOException {
    
    
        }
    
    }

[https_github.com_gyn781369549_httpClient]: https://github.com/gyn781369549/httpClient