HttpClientProxyUtil HTTPClient请求工具类源码

package com.rapido.weixin.utils;

import java.io.IOException;
import java.net.SocketTimeoutException;
import java.net.URI;
import java.security.KeyManagementException;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;

import javax.net.ssl.SSLContext;

import org.apache.http.HttpEntity;
import org.apache.http.HttpHeaders;
import org.apache.http.HttpResponse;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.ConnectTimeoutException;
import org.apache.http.conn.ConnectionPoolTimeoutException;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.conn.ssl.SSLContextBuilder;
import org.apache.http.conn.ssl.TrustStrategy;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.apache.log4j.Logger;

/**
* HTTPClient 请求代理类
* @author X-rapido
* @description 发送Get Post请求,本项目 HTTPClient4.3版本
*
* 也可以使用新浪FetchURL是SAE为开发者提供的分布式网页抓取服务，用来同步的抓取http页面，FetchURL针对国内的网络的做了优化
* 内部有调度系统，尽可能保证用户快速的抓取到目标页面，更多内容详见：http://baike.haosou.com/doc/7565440-7839533.html
*/
public class HttpClientProxyUtil {
private static Logger logger = Logger.getLogger(HttpClientProxyUtil.class);

/**
* 使用HTTPClient进行POST请求
* @param api_url 请求路径
* @param param 请求格式有name1=value1&name2=value2、json、xml、map或其他形式，具体要看接收方的取值
* @return
*/
public static String sendGet(String api_url, String param) {
logger.info("请求URL：" + api_url +"，参数：" + param);

CloseableHttpClient httpClient = null;
try {
httpClient = HttpClients.createDefault();   // 生成一个httpclient对象
HttpGet httpGet = new HttpGet(api_url + "?" + param);
// 连接超时时间，10秒, 传输超时时间，30秒，不设置超时的话，一旦服务器没有响应，等待时间N久(>24小时)。
RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(10000).setConnectTimeout(30000).build();
httpGet.setConfig(requestConfig);   // 设置请求器的配置

// 配置请求的HEADER部分
httpGet.addHeader(HttpHeaders.ACCEPT, "application/xml");

HttpResponse response = httpClient.execute(httpGet);    //执行请求Http
HttpEntity entity = response.getEntity();

//          logger.info("执行请求：" + httpPost.getRequestLine());
//          logger.info("响应的所有HEADER内容：" + Arrays.toString(response.getAllHeaders()));

// 判断响应实体是否为空
if (entity != null) {
String content = EntityUtils.toString(entity, "UTF-8");
logger.info("响应内容：" + content);
return content;
}
} catch (ConnectionPoolTimeoutException e) {
e.printStackTrace();
logger.error("http get throw ConnectionPoolTimeoutException(等待超时)");
} catch (ConnectTimeoutException e) {
e.printStackTrace();
logger.error("http get throw ConnectTimeoutException(联接超时)");
} catch (SocketTimeoutException e) {
e.printStackTrace();
logger.error("http get throw SocketTimeoutException(通讯超时)");
} catch (Exception e) {
e.printStackTrace();
logger.error("http get throw Exception");
} finally {
if (httpClient != null) {
try {
httpClient.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return "";
}

/**
* 使用HTTPClient进行POST请求
* @param api_url 请求路径
* @param param 请求格式有name1=value1&name2=value2、json、xml、map或其他形式，具体要看接收方的取值
* @return
*/
public static String sendPost(String api_url, String param) {
logger.info("请求URL：" + api_url +"，参数：" + param);

CloseableHttpClient httpClient = null;
try {
httpClient = HttpClients.createDefault();   // 生成一个httpclient对象
HttpPost httpPost = new HttpPost(api_url);
// 得指明使用UTF-8编码，否则到API服务器XML的中文不能被成功识别
StringEntity postEntity = new StringEntity(param, "UTF-8");
httpPost.addHeader("Content-Type", "text/xml");
httpPost.setEntity(postEntity);

// 连接超时时间，10秒, 传输超时时间，30秒，4.3版本不设置超时的话，一旦服务器没有响应，等待时间N久(>24小时)。
RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(10000).setConnectTimeout(30000).build();
httpPost.setConfig(requestConfig);// 设置请求器的配置

HttpResponse response = httpClient.execute(httpPost);   //执行请求Http
HttpEntity entity = response.getEntity();

//          logger.info("执行请求：" + httpPost.getRequestLine());
//          logger.info("响应的所有HEADER内容：" + Arrays.toString(response.getAllHeaders()));

// 判断响应实体是否为空
if (entity != null) {
String content = EntityUtils.toString(entity, "UTF-8");
logger.info("响应内容：" + content);
return content;
}
} catch (ConnectionPoolTimeoutException e) {
e.printStackTrace();
logger.error("http get throw ConnectionPoolTimeoutException(等待超时)");
} catch (ConnectTimeoutException e) {
e.printStackTrace();
logger.error("http get throw ConnectTimeoutException(联接超时)");
} catch (SocketTimeoutException e) {
e.printStackTrace();
logger.error("http get throw SocketTimeoutException(通讯超时)");
} catch (Exception e) {
e.printStackTrace();
logger.error("http get throw Exception");
} finally {
if (httpClient != null) {
try {
httpClient.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return "";
}

public static CloseableHttpClient createSSLClientDefault() {
//      ManagedHttpClientConnectionFactory
try {
SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
// 信任所有
public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException {
return true;
}
}).build();
SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext);
return HttpClients.custom().setSSLSocketFactory(sslsf).build();
} catch (KeyManagementException e) {
e.printStackTrace();
} catch (NoSuchAlgorithmException e) {
e.printStackTrace();
} catch (KeyStoreException e) {
e.printStackTrace();
}
return HttpClients.createDefault();
}

/**
* 请求Https请求
* @param url
* @return
*/
public static String requestHttps(String url){
logger.info("请求URL：" + url);

CloseableHttpClient httpClient = createSSLClientDefault();
HttpGet httpGet = new HttpGet();
try {
httpGet.setURI(new URI(url));

RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(10000).setConnectTimeout(30000).build();
httpGet.setConfig(requestConfig);   // 设置请求器的配置

// 配置请求的HEADER部分
httpGet.addHeader(HttpHeaders.ACCEPT, "application/xml");

HttpResponse response = httpClient.execute(httpGet);    //执行请求Http
HttpEntity entity = response.getEntity();

//          logger.info("执行请求：" + httpPost.getRequestLine());
//          logger.info("响应的所有HEADER内容：" + Arrays.toString(response.getAllHeaders()));

// 判断响应实体是否为空
if (entity != null) {
String content = EntityUtils.toString(entity, "UTF-8");
logger.info("响应内容：" + content);
return content;
}
} catch (Exception e) {
e.printStackTrace();
}
return "";
}
}