[心缘地方]同学录
首页 | 功能说明 | 站长通知 | 最近更新 | 编码查看转换 | 代码下载 | 常见问题及讨论 | 《深入解析ASP核心技术》 | 王小鸭自动发工资条VBA版
登录系统:用户名: 密码: 如果要讨论问题,请先注册。

[整理]httpclient 4.5 使用连接池的写法。

上一篇:[备忘]maven工程导出,多一个jar包
下一篇:[整理]activiti,版本5.19.0.2,整合rest接口到我的工程~~

添加日期:2016/4/14 21:02:12 快速返回   返回列表 阅读8180次


package com.xxxx.client.util;

import java.io.IOException;
import java.nio.charset.Charset;

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.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.protocol.HttpClientContext;
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.util.EntityUtils;

/**
 * HTTP请求工具类.
 * 
 */
public class HttpUtil {

    private static CloseableHttpClient httpclient = null;

    private static IdleConnectionMonitorThread scanThread = null;

    /**
     * 初始化client对象.
     */
    public static void init() {

        // 连接池设置
        PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
        cm.setMaxTotal(20); // 最多20个连接
        cm.setDefaultMaxPerRoute(20); // 每个路由20个连接

        // 创建client对象
        httpclient = HttpClients.custom().setConnectionManager(cm).build();

        // 扫描无效连接的线程
        scanThread = new IdleConnectionMonitorThread(cm);
        scanThread.start();
    }

    /**
     * 关闭连接池.
     */
    public static void close() {
        if (httpclient != null) {
            try {
                httpclient.close();
            } catch (IOException e) {
            }
        }
        if (scanThread != null) {
            scanThread.shutdown();
        }
    }

    /**
     * Get方式取得URL的内容.
     * 
     * @param url
     *            访问的网址
     * @return
     */
    public static String getUrlContent(String url) {

        // 参数检查
        if (httpclient == null) {
            throw new RuntimeException("httpclient not init.");
        }
        if (url == null || url.trim().length() == 0) {
            throw new RuntimeException("url is blank.");
        }

        HttpGet httpGet = new HttpGet(url);
        CloseableHttpResponse response = null;
        try {

            // 执行请求
            response = httpclient.execute(httpGet, HttpClientContext.create());

            // 转换结果
            HttpEntity entity1 = response.getEntity();
            String html = EntityUtils.toString(entity1);

            // 消费掉内容
            EntityUtils.consume(entity1);
            return html;
        } catch (IOException e) {

            return "";
        } finally {
            if (response != null) {
                try {
                    response.close();
                } catch (IOException e) {
                }
            }
            httpGet.releaseConnection();
        }
    }

    /**
     * Post方式取得URL的内容,默认为"application/x-www-form-urlencoded"格式,charset为UTF-8.
     * 
     * @param url
     *            访问的网址
     * @param content
     *            提交的数据
     * @return
     */
    public static String postToUrl(String url, String content) {
        return postToUrl(url, content, "application/x-www-form-urlencoded",
                "UTF-8");
    }

    /**
     * json字符串形式请求
     * 
     * @param url
     * @param content
     * @return
     */
    public static String postForJson(String url, String content) {
        return postToUrl(url, content, "application/json", "UTF-8");
    }

    /**
     * Post方式取得URL的内容.
     * 
     * @param url
     *            访问的网址
     * @param content
     *            提交的数据
     * @return
     */
    public static String postToUrl(String url, String content,
            String contentType, String charset) {

        // 参数检查
        if (httpclient == null) {
            throw new RuntimeException("httpclient not init.");
        }
        if (url == null || url.trim().length() == 0) {
            throw new RuntimeException("url is blank.");
        }

        HttpPost httpPost = new HttpPost(url);

        // 设置内容
        ContentType type = ContentType.create(contentType,
                Charset.forName(charset));
        StringEntity reqEntity = new StringEntity(content, type);
        httpPost.setEntity(reqEntity);
        httpPost.addHeader("User-Agent",
                "Mozilla/4.0 (compatible; MSIE .0; Windows NT 6.1; Trident/4.0; SLCC2;)");
        httpPost.addHeader("Accept-Encoding", "*");

        // 设置请求和传输超时时间
        RequestConfig requestConfig = RequestConfig.custom()
                .setSocketTimeout(30000).setConnectTimeout(30000).build();
        httpPost.setConfig(requestConfig);

        CloseableHttpResponse response = null;
        try {
            // 执行请求
            response = httpclient.execute(httpPost, HttpClientContext.create());

            // 转换结果
            HttpEntity entity1 = response.getEntity();
            String html = EntityUtils.toString(entity1, charset);

            // 消费掉内容
            EntityUtils.consume(entity1);
            return html;
        } catch (IOException ex) {
            ex.printStackTrace();
            return "-1";
        } finally {
            if (response != null) {
                try {
                    response.close();
                } catch (IOException e) {
                }
            }
            httpPost.releaseConnection();
        }
    }

    public static void main(String[] args) {
        HttpUtil.init();
        long a = System.currentTimeMillis();
        for (int i = 0; i < 20; i++) {
            String html = postForJson("https://www.baidu.com/",
                    "{\"frm\":\"frm\",\"ipcc\":\"ipcc\"}");
            System.out.println(html.length());
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        }
        System.out.println(System.currentTimeMillis() - a);
        HttpUtil.close();

    }
}




package com.xxxx.client.util;

import org.apache.http.conn.HttpClientConnectionManager;

/**
 * 关闭HTTP空闲连接、无效连接.
 * 
 */
public class IdleConnectionMonitorThread extends Thread {

    private final HttpClientConnectionManager connMgr;
    private volatile boolean shutdown;

    public IdleConnectionMonitorThread(HttpClientConnectionManager connMgr) {
        super();
        this.connMgr = connMgr;
    }

    @Override
    public void run() {
        try {
            while (!shutdown) {
                synchronized (this) {
                    wait(5000);

                    // 关闭无效连接
                    connMgr.closeExpiredConnections();
                    
                    // 可选, 关闭空闲超过30秒的
                    //connMgr.closeIdleConnections(30, TimeUnit.SECONDS);
                }
            }
        } catch (InterruptedException ex) {
            // terminate
        }
    }

    public void shutdown() {
        shutdown = true;
        synchronized (this) {
            notifyAll();
        }
    }

}



系统启动时,调用init方法。
关闭时,调用close方法。
如spring里可以这样:
<bean id="calClient" class="com.xxxx.client.CalClient" init-method="init"  destroy-method="cleanUp">
</bean>


    /**
     * 初始化HttpClient.
     */
    public void init() {
        HttpUtil.init();
    }

    /**
     * 关闭连接池.
     */
    public void cleanUp() {
        HttpUtil.close();
    }





另:tomcat的长连接设置,这样写:
<Connector keepAliveTimeout="30000".../>
单位是毫秒,默认好像是15秒。

也就是说,httpclient的连接池里,一个连接创建后,

多次的请求都走这个连接,直到空闲超过15秒,被tomcat咔嚓掉。

下次的请求,创建一个新的连接,如此反复。
 

评论 COMMENTS
没有评论 No Comments.

添加评论 Add new comment.
昵称 Name:
评论内容 Comment:
验证码(不区分大小写)
Validation Code:
(not case sensitive)
看不清?点这里换一张!(Change it here!)
 
评论由管理员查看后才能显示。the comment will be showed after it is checked by admin.
CopyRight © 心缘地方 2005-2999. All Rights Reserved