From aa925d851857f50eff0556411366690d9a78a0e5 Mon Sep 17 00:00:00 2001
From: 44323 <443237572@qq.com>
Date: 星期一, 27 十一月 2023 17:30:26 +0800
Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/PlayPai
---
cloud-server-other/src/main/java/com/dsh/other/util/HttpClientUtil.java | 111 ++++++++++++++++++++++++++++---------------------------
1 files changed, 57 insertions(+), 54 deletions(-)
diff --git a/cloud-server-other/src/main/java/com/dsh/other/util/HttpClientUtil.java b/cloud-server-other/src/main/java/com/dsh/other/util/HttpClientUtil.java
index 9094805..b33680b 100644
--- a/cloud-server-other/src/main/java/com/dsh/other/util/HttpClientUtil.java
+++ b/cloud-server-other/src/main/java/com/dsh/other/util/HttpClientUtil.java
@@ -42,7 +42,7 @@
private static PoolingHttpClientConnectionManager connectionManager;
- public HttpClientUtil(){
+ public HttpClientUtil() {
//1.创建连接池管理器
connectionManager = new PoolingHttpClientConnectionManager(60000,
TimeUnit.MILLISECONDS);
@@ -53,14 +53,14 @@
/**
* 创建一个httpClient对象
*/
- private static CloseableHttpClient getHttpCline(){
- return HttpClients.custom()
+ private static CloseableHttpClient getHttpCline() {
+ return HttpClients.custom()
.setConnectionManager(connectionManager)
.disableAutomaticRetries()
.build();
}
- private static RequestConfig getRequestConfig(){
+ private static RequestConfig getRequestConfig() {
RequestConfig.Builder builder = RequestConfig.custom();
builder.setSocketTimeout(60000)//3.1设置客户端等待服务端返回数据的超时时间
.setConnectTimeout(30000)//3.2设置客户端发起TCP连接请求的超时时间
@@ -70,34 +70,34 @@
}
-
/**
* 创建一个POST请求实例
- * @param url 请求地址
- * @param params 请求参数
+ *
+ * @param url 请求地址
+ * @param params 请求参数
*/
- private CloseableHttpResponse setPostHttpRequset(String url, Map<String, Object> params, Map<String, String> header, String contentType) throws Exception{
+ private CloseableHttpResponse setPostHttpRequset(String url, Map<String, Object> params, Map<String, String> header, String contentType) throws Exception {
HttpPost httpPost = new HttpPost(url);
httpPost.setConfig(this.getRequestConfig());
- if(null != header){
- for(String key : header.keySet()){
+ if (null != header) {
+ for (String key : header.keySet()) {
httpPost.setHeader(key, header.get(key));
}
}
List<NameValuePair> list = new ArrayList<>();
- if(null != params){
+ if (null != params) {
Set<String> keys = params.keySet();
- for(String key : keys){
+ for (String key : keys) {
list.add(new BasicNameValuePair(key, null == params.get(key) ? null : params.get(key).toString()));
}
}
- switch (contentType){
+ switch (contentType) {
case "form":
httpPost.setEntity(new UrlEncodedFormEntity(list, "UTF-8"));
break;
case "json":
ObjectMapper objectMapper = new ObjectMapper();
- String s =objectMapper.writeValueAsString(params);
+ String s = objectMapper.writeValueAsString(params);
httpPost.setEntity(new StringEntity(s, ContentType.create(ContentType.APPLICATION_JSON.getMimeType(), Charset.forName("UTF-8"))));
break;
}
@@ -107,23 +107,24 @@
/**
* 获取get请求实例
- * @param url 请求地址
- * @param params 请求参数
+ *
+ * @param url 请求地址
+ * @param params 请求参数
*/
- private CloseableHttpResponse setGetHttpRequset(String url, Map<String, Object> params, Map<String, String> header) throws Exception{
+ private CloseableHttpResponse setGetHttpRequset(String url, Map<String, Object> params, Map<String, String> header) throws Exception {
StringBuffer sb = new StringBuffer();
String p = "";
- if(null != params){
+ if (null != params) {
Set<String> keys = params.keySet();
- for(String key : keys){
+ for (String key : keys) {
sb.append(key + "=" + params.get(key) + "&");
}
p = "?" + sb.substring(0, sb.length() - 1);
}
HttpGet httpGet = new HttpGet(url + p);
httpGet.setConfig(getRequestConfig());
- if(null != header){
- for(String key : header.keySet()){
+ if (null != header) {
+ for (String key : header.keySet()) {
httpGet.setHeader(key, header.get(key));
}
}
@@ -133,19 +134,20 @@
/**
* 发送http请求
- * @param mothed "GET、POST、PUT、HEAD、DELETE、HEAD、OPTIONS"
- * @param url 请求地址
- * @param params 请求参数
- * @param header 请求头
- * @param contentType 参数请求方式form/json
+ *
+ * @param mothed "GET、POST、PUT、HEAD、DELETE、HEAD、OPTIONS"
+ * @param url 请求地址
+ * @param params 请求参数
+ * @param header 请求头
+ * @param contentType 参数请求方式form/json
* @return
*/
- public HttpResult pushHttpRequset(String mothed, String url, Map<String, Object> params, Map<String, String> header, String contentType) throws Exception{
+ public HttpResult pushHttpRequset(String mothed, String url, Map<String, Object> params, Map<String, String> header, String contentType) throws Exception {
String randome = UUID.randomUUID().toString();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.S");
logger.info(sdf.format(new Date()) + "----（" + randome + "）请求参数：" + JSON.toJSONString(params));
CloseableHttpResponse httpResponse = null;
- switch (mothed){
+ switch (mothed) {
case "GET":
httpResponse = this.setGetHttpRequset(url, params, header);
break;
@@ -164,15 +166,16 @@
/**
* 发送XML请求
- * @param url 请求地址
- * @param xml XML数据
- * @param header 自定义请求头
+ *
+ * @param url 请求地址
+ * @param xml XML数据
+ * @param header 自定义请求头
* @return
*/
- public static HttpResult pushHttpRequsetXml(String url, String xml, Map<String, String> header) throws Exception{
+ public static HttpResult pushHttpRequsetXml(String url, String xml, Map<String, String> header) throws Exception {
HttpPost httpPost = new HttpPost(url);
httpPost.setConfig(getRequestConfig());
- for(String key : header.keySet()){
+ for (String key : header.keySet()) {
httpPost.setHeader(key, header.get(key));
}
httpPost.setHeader("Content-Type", "application/xml");
@@ -186,21 +189,21 @@
}
-
/**
* 请求https发送XML请求
- * @param url 接口路径
- * @param xml 内容
- * @param header 请求头
- * @param certPassword 证书密码
- * @param certPath 证书路径
- * @param certType 证书类型
+ *
+ * @param url 接口路径
+ * @param xml 内容
+ * @param header 请求头
+ * @param certPassword 证书密码
+ * @param certPath 证书路径
+ * @param certType 证书类型
* @return
* @throws Exception
*/
- public static String pushHttpsRequsetXml(String url, String xml, Map<String, String> header, String certPassword, String certPath, String certType) throws Exception{
+ public static String pushHttpsRequsetXml(String url, String xml, Map<String, String> header, String certPassword, String certPath, String certType) throws Exception {
HttpPost httpPost = new HttpPost(url);
- for(String key : header.keySet()){
+ for (String key : header.keySet()) {
httpPost.setHeader(key, header.get(key));
}
httpPost.setHeader("Content-Type", "application/xml");
@@ -208,9 +211,9 @@
CloseableHttpClient httpCline = initCert(certPassword, certPath, certType);
CloseableHttpResponse httpResponse = httpCline.execute(httpPost);
String content = null;
- if(httpResponse.getStatusLine().getStatusCode() == 200){
+ if (httpResponse.getStatusLine().getStatusCode() == 200) {
content = EntityUtils.toString(httpResponse.getEntity(), "UTF-8");
- }else{
+ } else {
content = "返回状态码：" + httpResponse.getStatusLine() + "。" + EntityUtils.toString(httpResponse.getEntity());
}
close(httpResponse);
@@ -221,9 +224,10 @@
/**
* 初始化https对象（带证书）
- * @param key 证书密码
- * @param certPath 证书路径
- * @param certType 证书类型
+ *
+ * @param key 证书密码
+ * @param certPath 证书路径
+ * @param certType 证书类型
* @throws Exception
*/
private static CloseableHttpClient initCert(String key, String certPath, String certType) throws Exception {
@@ -236,30 +240,29 @@
}
SSLContext sslcontext = SSLContexts.custom().loadKeyMaterial(keyStore, key.toCharArray()).build();
SSLConnectionSocketFactory sslsf =
- new SSLConnectionSocketFactory(sslcontext, new String[] {"TLSv1"}, null,
+ new SSLConnectionSocketFactory(sslcontext, new String[]{"TLSv1"}, null,
SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);
return HttpClients.custom().setSSLSocketFactory(sslsf).build();
}
-
/**
* 关闭资源
*/
- private static void close(CloseableHttpResponse httpResponse){
+ private static void close(CloseableHttpResponse httpResponse) {
try {
- if(null != httpResponse){
+ if (null != httpResponse) {
EntityUtils.consume(httpResponse.getEntity());//此处高能，通过源码分析，由EntityUtils是否回收HttpEntity
httpResponse.close();
}
} catch (Exception e) {
e.printStackTrace();
- }finally {
+ } finally {
try {
- if(null != httpResponse){
+ if (null != httpResponse) {
httpResponse.close();
}
- }catch (Exception e){
+ } catch (Exception e) {
e.printStackTrace();
}
}
--
Gitblit v1.7.1