import com.chinatelecom.personalcustom.PersonalCustomConst; import com.chinatelecom.personalcustom.model.WapLogBean; import com.fasterxml.jackson.databind.ObjectMapper; import com.ning.http.client.AsyncHttpClient; import com.ning.http.client.AsyncHttpClient.BoundRequestBuilder; import com.ning.http.client.AsyncHttpClientConfig; import com.ning.http.client.providers.netty.NettyResponse; import org.apache.commons.httpclient.*; import org.apache.commons.httpclient.methods.GetMethod; import org.apache.commons.httpclient.methods.PostMethod; import org.apache.commons.httpclient.methods.StringRequestEntity; import org.apache.commons.httpclient.params.HttpConnectionManagerParams; import org.apache.commons.httpclient.params.HttpMethodParams; import org.jboss.netty.handler.codec.http.HttpHeaders; import java.net.URLEncoder; import java.util.Map; import java.util.Map.Entry; import java.util.Set; public class HttpUtil { /** * 请求超时时间 */ private static final int SO_TIMEOUT = 45000; /** * 请求失败时重试次数 */ private static final int RETRY_COUNT = 5; /** * 最大允许连接数 */ private static final int MAX_TOTAL_CONNECTION = 200; /** * 异步请求对象 */ private static AsyncHttpClient asyncHttpClient; private static MultiThreadedHttpConnectionManager connectionManager = new MultiThreadedHttpConnectionManager(); static { HttpConnectionManagerParams params = new HttpConnectionManagerParams(); params.setMaxTotalConnections(MAX_TOTAL_CONNECTION); connectionManager.setParams(params); } /** * 设置异步请求参数 */ static { AsyncHttpClientConfig.Builder builder = new AsyncHttpClientConfig.Builder(); builder.setMaximumConnectionsTotal(300); builder.setMaximumConnectionsPerHost(90); builder.setRequestTimeoutInMs(SO_TIMEOUT); asyncHttpClient = new AsyncHttpClient(builder.build()); } /** * 获取同步请求连接 */ private static HttpClient getHttpClientInstance() { HttpClient client = new HttpClient(connectionManager); client.getParams().setParameter(HttpMethodParams.HTTP_CONTENT_CHARSET,"UTF-8"); client.getParams().setParameter(HttpMethodParams.RETRY_HANDLER,new DefaultHttpMethodRetryHandler(RETRY_COUNT, true)); client.getParams().setSoTimeout(SO_TIMEOUT); return client; } /** * POST请求 */ public static HttpResponse post(String url, Map<String,Object> params) throws Exception { HttpResponse response = new HttpResponse(); HttpClient client = getHttpClientInstance(); PostMethod postMethod = new PostMethod(url); postMethod.addRequestHeader(HttpHeaders.Names.USER_AGENT, PersonalCustomConst.USER_AGENT); postMethod.setRequestHeader(HttpHeaders.Names.CONTENT_TYPE, "UTF-8"); ObjectMapper mapper = new ObjectMapper(); try { StringRequestEntity stringRequestEntity = new StringRequestEntity(mapper.writeValueAsString(params)); postMethod.setRequestEntity(stringRequestEntity); int returnCode = client.executeMethod(postMethod); response.setStatusCode(returnCode); response.setBody(postMethod.getResponseBodyAsString()); } finally { postMethod.releaseConnection(); } return response; } /** * POST请求 */ public static HttpResponse post(String url, String params) throws Exception { HttpResponse response = new HttpResponse(); HttpClient client = getHttpClientInstance(); PostMethod postMethod = new PostMethod(url); postMethod.addRequestHeader(HttpHeaders.Names.USER_AGENT, PersonalCustomConst.USER_AGENT); postMethod.setRequestHeader(HttpHeaders.Names.CONTENT_TYPE, "UTF-8"); try { StringRequestEntity stringRequestEntity = new StringRequestEntity(params); postMethod.setRequestEntity(stringRequestEntity); int returnCode = client.executeMethod(postMethod); response.setStatusCode(returnCode); response.setBody(postMethod.getResponseBodyAsString()); } finally { postMethod.releaseConnection(); } return response; } /** * GET请求 */ public static HttpResponse get(String url, Map<String,String> params) throws Exception { HttpResponse response = new HttpResponse(); HttpClient client = getHttpClientInstance(); GetMethod getMethod = null; try { StringBuffer buffer = new StringBuffer(); buffer.append(url).append("?t=").append(System.currentTimeMillis()); Set<Entry<String, String>> entries = params.entrySet(); for (Entry<String, String> entry : entries) { if (entry != null && entry.getValue() != null) { buffer.append("&").append(entry.getKey()).append("=").append(URLEncoder.encode(entry.getValue(),"UTF-8")); } } getMethod = new GetMethod(buffer.toString()); getMethod.setRequestHeader(HttpHeaders.Names.CONTENT_TYPE, "UTF-8"); getMethod.getParams().setContentCharset("UTF-8"); int returnCode = client.executeMethod(getMethod); response.setStatusCode(returnCode); response.setBody(getMethod.getResponseBodyAsString()); } finally { if(getMethod != null){ getMethod.releaseConnection(); } } return response; } /** * 异步get请求 */ public static HttpResponse aysnGet(String url,Map<String, Object> params,WapLogBean wapLogBean) throws Exception { HttpResponse response = new HttpResponse(); try { StringBuffer buffer = new StringBuffer(); buffer.append(url); if(params != null && params.size() > 0){ buffer.append("?t=").append(System.currentTimeMillis()); Set<Entry<String, Object>> entries = params.entrySet(); for (Entry<String, Object> entry : entries) { if (entry != null && entry.getValue() != null) { buffer.append("&").append(entry.getKey()).append("=").append(entry.getValue()); } } } wapLogBean.setServerUrl(buffer.toString()); BoundRequestBuilder builder = asyncHttpClient.prepareGet(buffer.toString()); builder = builder.addHeader(HttpHeaders.Names.USER_AGENT,PersonalCustomConst.USER_AGENT); NettyResponse nettyResponse = (NettyResponse) builder.execute().get(); response.setStatusCode(nettyResponse.getStatusCode()); response.setBody(nettyResponse.getResponseBody()); } catch (Exception e) { throw e; } return response; } /** * 异步post请求 */ public static HttpResponse aysnPost(String url,Map<String, Object> params, String userAgent) throws Exception { HttpResponse response = new HttpResponse(); try { BoundRequestBuilder builder = asyncHttpClient.preparePost(url); builder = builder.addHeader(HttpHeaders.Names.USER_AGENT,userAgent); if(params != null && params.size() > 0){ builder = builder.setBody(JsonUtil.entityToJson(params)); } NettyResponse nettyResponse = (NettyResponse) builder.execute().get(); response.setStatusCode(nettyResponse.getStatusCode()); response.setBody(nettyResponse.getResponseBody()); } catch (Exception e) { throw e; } return response; } /** * 发送HTTP请求 */ @SuppressWarnings("deprecation") public static String post(String url,String body, String userAgent, String contentType) throws Exception { String result = null; HttpClient client = getHttpClientInstance(); PostMethod method = new PostMethod(url); method.addRequestHeader("User-Agent", userAgent); method.setRequestHeader("Content-Type", contentType); method.setRequestBody(body); try { client.executeMethod(method); result = method.getResponseBodyAsString(); } finally { method.releaseConnection(); } return result; } public static void destroy() { if(asyncHttpClient != null){ asyncHttpClient.close(); } } }
