httpClient工具类，,import com.c

httpClient工具类，,import com.c

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 &amp;&amp; entry.getValue() != null) {                      buffer.append("&amp;").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 &amp;&amp; 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 &amp;&amp; entry.getValue() != null) {                          buffer.append("&amp;").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 &amp;&amp; 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();          }      }  }