技术经验分享：Javahttpclent请求httpclentUtils工具类-阿里云开发者社区

第一种写法:

import java.io.IOException;

import java.io.InterruptedIOException;

import java.io.UnsupportedEncodingException;

import java.net.SocketTimeoutException;

import java.net.URLEncoder;

import java.net.UnknownHostException;

import java.nio.charset.Charset;

import java.security.KeyManagementException;

import java.security.KeyStoreException;

import java.security.NoSuchAlgorithmException;

import java.security.cert.CertificateException;

import java.security.cert.X509Certificate;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import javax.activation.MimetypesFileTypeMap;

import javax.net.ssl.SSLContext;

import javax.net.ssl.SSLException;

import org.apache.commons.lang3.StringUtils;

import org.apache.http.Header;

import org.apache.http.HttpEntity;

import org.apache.http.HttpEntityEnclosingRequest;

import org.apache.http.HttpHost;

import org.apache.http.HttpRequest;

import org.apache.http.NameValuePair;

import org.apache.http.ParseException;

import org.apache.http.client.ClientProtocolException;

import org.apache.http.client.HttpRequestRetryHandler;

import org.apache.http.client.config.RequestConfig;

import org.apache.http.client.config.RequestConfig.Builder;

import org.apache.http.client.entity.UrlEncodedFormEntity;

import org.apache.http.client.methods.CloseableHttpResponse;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.client.methods.HttpPost;

import org.apache.http.client.protocol.HttpClientContext;

import org.apache.http.conn.ConnectTimeoutException;

import org.apache.http.conn.ssl.SSLConnectionSocketFactory;

import org.apache.http.conn.ssl.TrustStrategy;

import org.apache.http.entity.ContentType;

import org.apache.http.entity.mime.MultipartEntityBuilder;

import org.apache.http.impl.client.CloseableHttpClient;

import org.apache.http.impl.client.HttpClients;

import org.apache.http.message.BasicNameValuePair;

import org.apache.http.protocol.HTTP;

import org.apache.http.protocol.HttpContext;

import org.apache.http.ssl.SSLContextBuilder;

import org.apache.http.util.EntityUtils;

import lombok.extern.slf4j.Slf4j;import net.sf.json.JSONObject;

import net.sf.json.JsonConfig;

import net.sf.json.util.PropertyFilter;

@Slf4j

public class HttpclientUtils {

private final static int CONNECT_TIMEOUT = 4000; // 连接超时毫秒

private final static int SOCKET_TIMEOUT = 30000; // 传输超时毫秒

private final static int REQUESTCONNECT_TIMEOUT = 3000; // 获取请求超时毫秒

private final static String ENCODE_CHARSET = "utf-8"; // 响应报文解码字符集

static class RetryHandler implements HttpRequestRetryHandler {

@Override

public boolean retryRequest(IOException exception, int executionCount, HttpContext context) {

if (executionCount >= 3) {

// Do not retry if over max retry count

return false;

}

if (exception instanceof InterruptedIOException) {

// Timeout

return false;

}

if (exception instanceof UnknownHostException) {

// Unknown host

return false;

}

if (exception instanceof ConnectTimeoutException) {

// Connection refused

return false;

}

if (exception instanceof SSLException) {

// SSL handshake exception

return false;

}

HttpClientContext clientContext = HttpClientContext.adapt(context);

HttpRequest request = clientContext.getRequest();

boolean idempotent = !(request instanceof HttpEntityEnclosingRequest);

if (idempotent) {

// Retry if the request is considered idempotent

return true;

}

return false;

}

};

public static CloseableHttpClient createSSLClientDefault(HttpHost proxy) {

try {

SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {

// 信任所有

@Override

public boolean isTrusted(X509Certificate【】 chain, String authType) throws CertificateException {

//代码效果参考：http://www.lyjsj.net.cn/wx/art_22942.html

return true;

}

}).build();

SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext);

HttpRequestRetryHandler retryHandler = new RetryHandler();

Builder buider = RequestConfig.custom().setConnectionRequestTimeout(REQUESTCONNECT_TIMEOUT).setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT);

if (null //代码效果参考：http://www.lyjsj.net.cn/wz/art_22940.html

!= proxy) {

buider.setProxy(proxy);

}

RequestConfig requestConfig = buider.build();

HttpClients.custom().setSSLSocketFactory(sslsf).setDefaultRequestConfig(requestConfig).setRetryHandler(retryHandler).build();

} catch (KeyManagementException | NoSuchAlgorithmException | KeyStoreException e) {

log.error(e.getMessage(), e);

}

return HttpClients.createDefault();

}

public static String buildMap(Map map) {

StringBuffer sb = new StringBuffer();

if (map != null && map.size() > 0) {

for (String key : map.keySet()) {

sb.append(key + "=");

if (null == map.get(key)) {

sb.append("&");

} else {

//代码效果参考：http://www.lyjsj.net.cn/wz/art_22938.html

String value = String.valueOf(map.get(key));

try {

value = URLEncoder.encode(value, "UTF-8");

} catch (UnsupportedEncodingException e) {

log.error(e.getMessage(), e);

}

sb.append(value + "&");

}

return sb.toString();

}

发送HTTP_GET请求

@see 1)该方法会自动关闭连接,释放资源

@see 2)方法内设置了连接和读取超时时间,单位为毫秒,超时或发生其它异常时方法会自动返回"通信失败"字符串

@see 3)请求参数含中文时,经测试可直接传入中文,HttpClient会自动编码发给Server,应用时应根据实际效果决定传入前是否转码

@see 4)该方法会自动获取到响应消息头中【Content-Type:text/html; charset=GBK】的charset值作为响应报文的解码字符集

@see 5)若响应消息头中无Content-Type属性,则会使用HttpClient内部默认的ISO-8859-1作为响应报文的解码字符集

@param reqURL 请求地址(含参数)

@return 远程主机响应正文 HttpHost proxy = new HttpHost("192.168.15.4", 3128);

public static JSONObject sendGetRequest(String reqURL, Map map, HttpHost proxy) {

String param = buildMap(map);

if (null != param) {

reqURL += "?" + param;

}

JSONObject respContent = new JSONObject(); // 响应内容

// reqURL = URLDecoder.decode(reqURL, ENCODE_CHARSET);

HttpGet httpget = new HttpGet(reqURL);

httpget.setHeader("Connection", "close");

CloseableHttpResponse response = null;

try {

response = createSSLClientDefault(proxy).execute(httpget, HttpClientContext.create()); // 执行GET请求

HttpEntity entity = response.getEntity(); // 获取响应实体

if (null != entity) {

Charset respCharset = Charset.forName(ENCODE_CHARSET);

respContent = JSONObject.fromObject(EntityUtils.toString(entity, respCharset), getJsonConfig());

log.info("发送get请求返回结果:{}", respContent);

EntityUtils.consume(entity);

} else {

log.error("发送get请求返回错误:{}", response);

}

} catch (ConnectTimeoutException cte) {

log.error("请求通信【" + reqURL + "】时连接超时,堆栈轨迹如下", cte);