配置http连接池：
1.在spring-context.xml配置文件中引入
<import resource="classpath:spring/spring-httpclient.xml" /> 2.连接池配置文件spring-httpclient.xml <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"> <!--配置一个httpClient 连接池 --> <bean id="poolHttpClientConnectionManager" class="org.apache.http.impl.conn.PoolingHttpClientConnectionManager"> <!-- 最大链接数 --> <property name="maxTotal" value="200"/> <!-- 设置每个主机地址的并发数 --> <property name="defaultMaxPerRoute" value="20"/> </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="1000"/> <!-- 从连接池中获取到连接的最长时间 --> <property name="socketTimeout" value="10000"/> <!-- 提交请求前测试连接是否可用 --> <property name="connectionRequestTimeout" value="500"/> </bean> <bean class="org.apache.http.client.config.RequestConfig" factory-bean="requestConfigBuilder" factory-method="build"></bean> <!-- 定期清理无效的连接 --> <bean class="com.a.b.common.utils.http.IdleConnectionEvictor" destroy-method="shutdown"> <constructor-arg index="0" ref="poolingHttpClientConnectionManager" /> <!-- 间隔一分钟清理一次 --> <constructor-arg index="1" value="60000" /> </bean> </beans> 3.类IdleConnectionEvictor public class IdleConnectionEvictor extends Thread{ private final HttpClientConnectionManager connMgr; private Integer waitTime; private volatile boolean shutdown; private static final Logger logger = Logger.getLogger(HttpPoolUtil.class); public IdleConnectionEvictor(HttpClientConnectionManager connMgr, Integer waitTime) { this.connMgr = connMgr; this.waitTime = waitTime; this.start(); } @Override public void run() { try { while (!shutdown) { synchronized (this) { wait(waitTime); // 关闭失效的连接 connMgr.closeExpiredConnections(); } } } catch (InterruptedException ex) { logger.error("清理异常"); } } /** * 销毁释放资源 */ public void shutdown() { shutdown = true; synchronized (this) { notifyAll(); } } }