配置高性能的http连接池
2016-04-01 17:24
477 查看
spring整合httpClient
编写清理无效链接的线程
<!--配置一个httpClient 连接池 --> <bean id="poolingHttpClientConnectionManager" class="org.apache.http.impl.conn.PoolingHttpClientConnectionManager"> <!-- 最大链接数 --> <property name="maxTotal" value="${http.maxTotal}" /> <!-- 设置每个主机地址的并发数 --> <property name="defaultMaxPerRoute" value="${http.defaultMaxPerRoute}" /> </bean> <!-- 生成httpClientBuilder(用于得到httpClient) --> <bean id="httpClientBuilder" class="org.apache.http.impl.client.HttpClientBuilder"> <!-- 注入连接池 --> <property name="connectionManager" ref="poolingHttpClientConnectionManager" /> </bean> <!-- 配置httpClient (通过httpClientBuilder得到httpClient对象,并且要设置httpClient为多利模式) --> <bean class="org.apache.http.impl.client.CloseableHttpClient" factory-bean="httpClientBuilder" factory-method="build" scope="prototype"></bean> <!-- 构造(配置)请求参数 --> <bean id="requestConfigBuilder" class="org.apache.http.client.config.RequestConfig.Builder"> <!-- 创建连接的最长时间 --> <property name="connectTimeout" value="${http.connectTimeout}" /> <!-- 从连接池中获取到连接的最长时间 --> <property name="socketTimeout" value="${http.socketTimeout}" /> <!-- 数据传输的最长时间 --> <property name="staleConnectionCheckEnabled" value="${http.staleConnectionCheckEnabled}" /> <!-- 提交请求前测试连接是否可用 --> <property name="connectionRequestTimeout" value="${http.connectionRequestTimeout}" /> </bean> <bean class="org.apache.http.client.config.RequestConfig" factory-bean="requestConfigBuilder" factory-method="build"></bean> <!-- 清理无效链接 --> <bean class="com.liuzw.common.service.IdleConnectionEvictor"> <constructor-arg index="0" ref="poolingHttpClientConnectionManager" /> </bean>
编写清理无效链接的线程
package com.liuzw.common.service; import org.apache.http.conn.HttpClientConnectionManager; /** * 清理一些无用的链接 * @author schoolBoy 刘志伟 * @data 2015年5月18日 下午1:21:39 */ public class IdleConnectionEvictor extends Thread { private final HttpClientConnectionManager connMgr; private volatile boolean shutdown; public IdleConnectionEvictor(HttpClientConnectionManager connMgr) { this.connMgr = connMgr; this.start();//启动线程 } @Override public void run() { try { while (!shutdown) { synchronized (this) { wait(5000); // 关闭失效的连接 connMgr.closeExpiredConnections(); } } } catch (InterruptedException ex) { // 结束 } } public void shutdown() { shutdown = true; synchronized (this) { notifyAll(); } } }参数参考
http.maxTotal=200 http.defaultMaxPerRoute=20 http.connectTimeout=1000 http.connectionRequestTimeout=500 http.socketTimeout=10000 http.staleConnectionCheckEnabled=true
相关文章推荐
- C++ 用libcurl库进行http通讯网络编程
- linux网络流量监控工具
- linux网络基础
- RedHat 系统使用yum网络源
- Android 网络请求加密
- 关于配置httpd2.4.18+php5.6
- CHttpFile GET/POST 提交数据
- CentOS 网络地址设置
- HttpWebRequest用法实例
- iOS异步加载网络图片
- 关于网络通讯中的相关概念
- Android Volley完全解析(二),使用Volley加载网络图片
- xml数据作为表单参数在网络传递也需要用urlencode处理
- 基于TCP/IP 协议的简单C/S程序
- http://appxcode.com/index.php
- http压力测试工具
- 清理widows的网络连接
- HTTP 错误 500.0 - Internal Server Error 调用 GetFilterVersion 失败,在 ISAPI 筛选器 "D:\apache-tomcat-6.0.20\co
- http://kb.cnblogs.com/page/541862/
- 遗传算法入门(连载之二)