package com.ruoyi.system.utils.util;
|
|
import com.google.common.collect.Lists;
|
import com.ruoyi.common.exception.ServiceException;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.http.Consts;
|
import org.apache.http.HttpResponse;
|
import org.apache.http.HttpStatus;
|
import org.apache.http.client.ClientProtocolException;
|
import org.apache.http.client.config.RequestConfig;
|
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.methods.HttpUriRequest;
|
import org.apache.http.client.protocol.HttpClientContext;
|
import org.apache.http.client.utils.URIBuilder;
|
import org.apache.http.entity.StringEntity;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClientBuilder;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
|
import org.apache.http.message.BasicNameValuePair;
|
import org.apache.http.util.EntityUtils;
|
|
import java.io.IOException;
|
import java.net.URI;
|
import java.net.URISyntaxException;
|
import java.nio.charset.StandardCharsets;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
@Slf4j
|
public class HttpClientUtils {
|
|
//请求超时时间
|
private final static Integer TIME_OUT = 30000;
|
//http连接池
|
private static volatile PoolingHttpClientConnectionManager poolingHttpClientConnectionManager;
|
//请求配置
|
private static RequestConfig requestConfig;
|
|
public static PoolingHttpClientConnectionManager getPoolingHttpClientConnectionManager() {
|
if (poolingHttpClientConnectionManager == null) {
|
synchronized (HttpClientUtils.class) {
|
if (poolingHttpClientConnectionManager == null) {
|
poolingHttpClientConnectionManager = new PoolingHttpClientConnectionManager();
|
//连接池最大连接数
|
poolingHttpClientConnectionManager.setMaxTotal(1024);
|
//每个路由最大连接数
|
poolingHttpClientConnectionManager.setDefaultMaxPerRoute(64);
|
//配置请求的超时设置
|
requestConfig =
|
RequestConfig.custom().setConnectionRequestTimeout(TIME_OUT).setConnectTimeout(TIME_OUT).setSocketTimeout(TIME_OUT).build();
|
}
|
}
|
}
|
return poolingHttpClientConnectionManager;
|
}
|
|
public static CloseableHttpClient getHttpClient() {
|
return HttpClients.custom().setConnectionManager(getPoolingHttpClientConnectionManager()).setDefaultRequestConfig(requestConfig).build();
|
}
|
|
/**
|
* 请求发送执行
|
*
|
* @param httpMethd
|
* @return
|
*/
|
public static String registRequest(HttpUriRequest httpMethd) {
|
CloseableHttpClient httpClient = getHttpClient();
|
try (CloseableHttpResponse httpResponse = httpClient.execute(httpMethd, HttpClientContext.create())) {
|
int statusCode = httpResponse.getStatusLine().getStatusCode();
|
if (httpResponse.getStatusLine().getStatusCode() != HttpStatus.SC_OK) {
|
log.error("响应失败 statusCode {}", statusCode);
|
log.error("============响应失败 response {}", EntityUtils.toString(httpResponse.getEntity(), Consts.UTF_8));
|
httpMethd.abort();
|
}
|
log.debug("响应成功 statusCode {}", statusCode);
|
String response = EntityUtils.toString(httpResponse.getEntity(), Consts.UTF_8);
|
log.debug("响应成功 response {}", response);
|
return response;
|
} catch (Exception e) {
|
throw new RuntimeException("请求失败", e);
|
}
|
}
|
|
public static List<BasicNameValuePair> toPairs(Map<String, Object> params) {
|
List<BasicNameValuePair> pairs = Lists.newArrayList();
|
if (params != null && !params.isEmpty()) {
|
pairs = params.entrySet().stream().map(entry -> new BasicNameValuePair(entry.getKey(),
|
entry.getValue().toString())).collect(Collectors.toList());
|
}
|
return pairs;
|
}
|
|
/**
|
* get url请求
|
*
|
* @param url
|
* @return
|
*/
|
public static String get(String url, String token) {
|
HttpGet request = new HttpGet();
|
request.setHeader("Authorization", token);
|
try {
|
request.setURI(new URI(url));
|
return registRequest(request);
|
} catch (Exception e) {
|
log.error("<<<<<<<<<<<<<<<请求失败:{}", e.getMessage());
|
}
|
return null;
|
}
|
|
/***
|
* get请求(带参数)
|
* @param url
|
* @return String
|
*/
|
public static String getReq(String url, Map<String, String> params) {
|
String result = null;
|
try {
|
URIBuilder uriBuilder = new URIBuilder(url);
|
Iterator maplist = params.entrySet().iterator();
|
while (maplist.hasNext()) {
|
Map.Entry<String, String> map = (Map.Entry<String, String>) maplist.next();
|
uriBuilder.addParameter(map.getKey(), map.getValue());
|
}
|
CloseableHttpClient client = HttpClientBuilder.create().build();
|
HttpGet get = new HttpGet(uriBuilder.build());
|
get.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.81 Safari/537.36");
|
HttpResponse response = client.execute(get);
|
result = EntityUtils.toString(response.getEntity(), "UTF-8");
|
|
} catch (URISyntaxException e) {
|
e.printStackTrace();
|
} catch (ClientProtocolException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return result;
|
}
|
|
/**
|
* PSOT URL方式提交
|
*
|
* @param url 请求url
|
* @param params 请求参数
|
* @return
|
*/
|
public static String postFromUrl(String url, Map<String, Object> params) {
|
HttpPost request = new HttpPost(url);
|
request.setEntity(new UrlEncodedFormEntity(toPairs(params), Consts.UTF_8));
|
try {
|
return registRequest(request);
|
} catch (Exception e) {
|
log.error("请求失败", e);
|
}
|
return null;
|
}
|
|
/**
|
* PSOT JSON方式提交
|
*
|
* @param url 请求url
|
* @param params json串
|
* @return
|
*/
|
public static String postFromJson(String url, String params, String token) {
|
HttpPost request = new HttpPost(url);
|
request.setHeader("Content-type", "application/json");
|
request.setHeader("Accept", "application/json");
|
request.setHeader("Authorization", token);
|
RequestConfig requestConfig = RequestConfig.custom()
|
.setSocketTimeout(12000)
|
.setConnectTimeout(8000)
|
.build();
|
request.setConfig(requestConfig);
|
StringEntity entity = new StringEntity(params, StandardCharsets.UTF_8);
|
entity.setContentType("application/json");
|
request.setEntity(entity);
|
try {
|
return registRequest(request);
|
} catch (Exception e) {
|
log.info("<<<<<<<<<<<http请求失败:{}", e.getMessage());
|
throw new ServiceException("<<<<<<<<<<<http请求失败<<<<<<<<<<<<<<");
|
}
|
}
|
|
/**
|
* PSOT JSON方式提交,无token
|
*
|
* @param url 请求url
|
* @param params json串
|
* @return
|
*/
|
public static String postFrom(String url, String params) {
|
HttpPost request = new HttpPost(url);
|
request.setHeader("Content-type", "application/json");
|
request.setHeader("Accept", "application/json");
|
RequestConfig requestConfig = RequestConfig.custom()
|
.setSocketTimeout(8000)
|
.setConnectTimeout(6000)
|
.build();
|
request.setConfig(requestConfig);
|
StringEntity entity = new StringEntity(params, StandardCharsets.UTF_8);
|
entity.setContentType("application/json");
|
request.setEntity(entity);
|
try {
|
return registRequest(request);
|
} catch (Exception e) {
|
log.error("<<<<<<<<<<<<<<<请求失败:{}", e.getMessage());
|
}
|
return null;
|
}
|
}
|
