【转载】HttpClient+ Spring实现多线程
HttpClient通过MultiThreadedHttpConnectionManager实现多线程通讯
HttpConnectionManagerParams设置connectionTimeout链接超时，soTimeout读取数据超时，maxTotalConnections，defaultMaxConnectionsPerHost等等参数
MultiThreadedHttpConnectionManager多线程中属性params是HttpConnectionManagerParams
Spring中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" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd"> <!-- httpclient线程池 --> <bean id="connectionManagerParams" value="10000"/> <property name="soTimeout" value="10000"/> <property name="maxTotalConnections" value="30"/> <property name="defaultMaxConnectionsPerHost" value="20"/> </bean> <bean id="connectionManager" ref="connectionManagerParams"/> </bean> <bean id="httpclient" ref="httpclient"/> </bean> </beans>
?
package com.chinaums.utils; import java.net.InetAddress; import java.net.NetworkInterface; import java.net.SocketException; import java.util.Enumeration; import java.util.List; import javax.servlet.http.HttpServletRequest; import org.apache.commons.httpclient.DefaultHttpMethodRetryHandler; import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.methods.GetMethod; import org.apache.commons.httpclient.methods.PostMethod; import org.apache.commons.httpclient.params.HttpMethodParams; /** * httpClient工具类 * * */ public class HttpClientUtil { private HttpClient httpclient; public void setHttpclient(HttpClient httpclient) { this.httpclient = httpclient; } public HttpClientUtil() { } /** * 以get方式发送http请求 * * @param url * @return */ public String sendRequest(String url) { GetMethod getMethod = new GetMethod(url); try { getMethod.getParams().setParameter(HttpMethodParams.RETRY_HANDLER,new DefaultHttpMethodRetryHandler()); // httpclient.getHttpConnectionManager().getParams().setConnectionTimeout(6000); // getMethod.getParams().setParameter(HttpMethodParams.SO_TIMEOUT,6000); httpclient.executeMethod(getMethod); return getMethod.getResponseBodyAsString(); } catch (Exception e) { e.printStackTrace(); return "FAIL"; } finally{ getMethod.releaseConnection(); } } /** * 以get方式发送http请求 * * @param url * @return */ public boolean isActive(String url) { boolean flag = false; GetMethod getMethod = new GetMethod(url); try { getMethod.getParams().setParameter(HttpMethodParams.RETRY_HANDLER,new DefaultHttpMethodRetryHandler()); int statusCode = httpclient.executeMethod(getMethod); if(statusCode==200){ flag = true; } return flag; } catch (Exception e) { e.printStackTrace(); return flag; } finally{ getMethod.releaseConnection(); } } /** * 以post方式发送http请求 * * @param url * @return */ public int sendRequestAsPost(String url) { PostMethod postMethod = new PostMethod(url); try { postMethod.getParams().setParameter(HttpMethodParams.RETRY_HANDLER,new DefaultHttpMethodRetryHandler()); httpclient.getHttpConnectionManager().getParams().setConnectionTimeout(1000); postMethod.getParams().setParameter(HttpMethodParams.SO_TIMEOUT,1000); int statusCode = httpclient.executeMethod(postMethod); return statusCode; } catch (Exception e) { e.printStackTrace(); return 500; } finally{ postMethod.releaseConnection(); } } /** * 验证请求是否是本机发出 * * @param request * true本机发出 false非本机发出 * @return */ public static boolean isRequestFromSelf(HttpServletRequest request) { if (getRemoteIpAddr(request).equals(getLocalIpAddr())) return true; else return false; } /** * 获取远程客户端IP地址 * * @param request * @return */ public static String getRemoteIpAddr(HttpServletRequest request) { String ip = request.getHeader("X-Forwarded-For"); if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) ip = request.getHeader("Proxy-Client-IP"); if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) ip = request.getHeader("WL-Proxy-Client-IP"); if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) ip = request.getHeader("HTTP_CLIENT_IP"); if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) ip = request.getHeader("HTTP_X_FORWARDED_FOR"); if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) ip = request.getRemoteAddr(); if ("0:0:0:0:0:0:0:1".equals(ip.trim())) ip = "server"; // 判断请求是否是本机发出,如果是本机发出,那么就获取本机地址 if ("127.0.0.1".equals(ip) || ip.equalsIgnoreCase("localhost")) ip = getLocalIpAddr(); return ip; } /** * 获取本机IP地址 * * @return */ public static String getLocalIpAddr() { try { Enumeration netInterfaces = NetworkInterface.getNetworkInterfaces(); InetAddress ip = null; String ipAddr = null; while (netInterfaces.hasMoreElements()) { NetworkInterface ni = (NetworkInterface) netInterfaces.nextElement(); ip = (InetAddress) ni.getInetAddresses().nextElement(); if (!ip.isSiteLocalAddress() && !ip.isLoopbackAddress() && ip.getHostAddress().indexOf(":") == -1) { ipAddr = ip.getHostAddress(); break; } } return ipAddr; } catch (SocketException e) { e.printStackTrace(); return null; } catch (Exception e) { e.printStackTrace(); return null; } } /** * 判断某回调地址是否是指定的网关地址 * * @param notifyUrl * @param getwayList * @return true 是网关 false不是网关地址 */ public static boolean isLocalNotifyUrl(String notifyUrl, List getwayList) { boolean flag = false; for (Object object : getwayList) { String getway = (String) object; if (notifyUrl.toLowerCase().contains(getway)) { flag = true; break; } } return flag; } public static void main(String[] arg){ HttpClient httpclient = new HttpClient(); String url = "http://www.163.com"; GetMethod method = new GetMethod(url); try { method.getParams().setParameter(HttpMethodParams.RETRY_HANDLER,new DefaultHttpMethodRetryHandler()); int statusCode = httpclient.executeMethod(method); System.out.println(statusCode); byte[] responseBody = method.getResponseBody(); System.out.println(new String(responseBody)); } catch (Exception e) { e.printStackTrace(); } finally{ method.releaseConnection(); } } } ?