package com.panzhihua.common.utlis;
|
import com.panzhihua.common.constants.HttpConstant;
|
import org.apache.http.client.HttpClient;
|
import org.apache.http.client.config.RequestConfig;
|
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.config.Registry;
|
import org.apache.http.config.RegistryBuilder;
|
import org.apache.http.conn.socket.ConnectionSocketFactory;
|
import org.apache.http.conn.socket.LayeredConnectionSocketFactory;
|
import org.apache.http.conn.socket.PlainConnectionSocketFactory;
|
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
|
|
import javax.net.ssl.SSLContext;
|
import java.security.NoSuchAlgorithmException;
|
/**
|
* @program: springcloud_k8s_panzhihuazhihuishequ
|
* @description:
|
* @author: huang.hongfa weixin hhf9596 qq 959656820
|
* @create: 2021-01-08 10:26
|
**/
|
public class HttpClientFactory {
|
|
private static HttpClientFactory instance = null;
|
|
private HttpClientFactory()
|
{
|
}
|
|
public synchronized static HttpClientFactory getInstance()
|
{
|
if (instance == null)
|
{
|
instance = new HttpClientFactory();
|
}
|
return instance;
|
}
|
|
|
public synchronized HttpClient getHttpClient()
|
{
|
HttpClient httpClient = null;
|
if (HttpConstant.IS_KEEP_ALIVE)
|
{
|
//获取长连接
|
httpClient = new KeepAliveHttpClientBuilder().getKeepAliveHttpClient();
|
} else
|
{
|
// 获取短连接
|
httpClient = new HttpClientBuilder().getHttpClient();
|
}
|
return httpClient;
|
}
|
|
public HttpPost httpPost(String httpUrl)
|
{
|
HttpPost httpPost = null;
|
httpPost = new HttpPost(httpUrl);
|
if (HttpConstant.IS_KEEP_ALIVE)
|
{
|
// 设置为长连接，服务端判断有此参数就不关闭连接。
|
httpPost.setHeader("Connection", "Keep-Alive");
|
}
|
return httpPost;
|
}
|
|
|
|
private static class KeepAliveHttpClientBuilder{
|
|
private static HttpClient httpClient;
|
|
/**
|
* 获取http长连接
|
*/
|
private synchronized HttpClient getKeepAliveHttpClient()
|
{
|
if (httpClient == null)
|
{
|
LayeredConnectionSocketFactory sslsf = null;
|
try {
|
sslsf = new SSLConnectionSocketFactory(SSLContext.getDefault());
|
} catch (NoSuchAlgorithmException e) {
|
e.printStackTrace();
|
}
|
|
Registry<ConnectionSocketFactory> socketFactoryRegistry = RegistryBuilder
|
.<ConnectionSocketFactory> create().register("https", sslsf)
|
.register("http", new PlainConnectionSocketFactory()).build();
|
PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
|
cm.setMaxTotal(HttpConstant.MAX_TOTAL);
|
cm.setDefaultMaxPerRoute(HttpConstant.MAX_CONN_PER_ROUTE);
|
|
RequestConfig requestConfig = RequestConfig.custom()
|
.setConnectTimeout(HttpConstant.CONNECT_TIMEOUT)
|
.setSocketTimeout(HttpConstant.SOCKET_TIMEOUT).build();
|
// 创建连接
|
httpClient = HttpClients.custom().setDefaultRequestConfig(requestConfig).setConnectionManager(cm).build();
|
}
|
|
return httpClient;
|
}
|
}
|
|
|
private static class HttpClientBuilder{
|
private HttpClient httpClient;
|
/**
|
* 获取http短连接
|
*/
|
private synchronized HttpClient getHttpClient()
|
{
|
if(httpClient == null){
|
RequestConfig requestConfig = RequestConfig.custom()
|
// 设置请求超时时间
|
.setConnectTimeout(HttpConstant.CONNECT_TIMEOUT)
|
// 设置响应超时时间
|
.setSocketTimeout(HttpConstant.SOCKET_TIMEOUT).build();
|
// 创建连接
|
httpClient = HttpClients.custom().setDefaultRequestConfig(requestConfig).build();
|
}
|
return httpClient;
|
}
|
}
|
|
|
}
|
