From 7ae1acd794d359908dcf61f22b60dcc3cf0a5c15 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期三, 19 六月 2024 16:54:29 +0800
Subject: [PATCH] 数据上传修改
---
UserZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/HttpClientUtil.java | 296 +++++++++++++++++++++++++++++------------------------------
1 files changed, 146 insertions(+), 150 deletions(-)
diff --git a/UserZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/HttpClientUtil.java b/UserZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/HttpClientUtil.java
index bcaea70..d613fd4 100644
--- a/UserZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/HttpClientUtil.java
+++ b/UserZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/util/HttpClientUtil.java
@@ -1,5 +1,6 @@
package com.stylefeng.guns.modular.system.util;
+import com.alibaba.fastjson.JSON;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.http.NameValuePair;
import org.apache.http.client.config.RequestConfig;
@@ -8,6 +9,7 @@
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
@@ -24,6 +26,7 @@
import java.io.InputStream;
import java.nio.charset.Charset;
import java.security.KeyStore;
+import java.text.SimpleDateFormat;
import java.util.*;
import java.util.concurrent.TimeUnit;
@@ -43,20 +46,29 @@
/**
* 创建一个httpClient对象
*/
- private void getHttpCline(){
- //1.创建连接池管理器
- PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(60000,
- TimeUnit.MILLISECONDS);
- connectionManager.setMaxTotal(1000);
- connectionManager.setDefaultMaxPerRoute(50);
-
- //2.创建httpclient对象
- this.httpClient = HttpClients.custom()
+// private void getHttpCline(){
+// //1.创建连接池管理器
+// PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(60000,
+// TimeUnit.MILLISECONDS);
+// connectionManager.setMaxTotal(1000);
+// connectionManager.setDefaultMaxPerRoute(50);
+//
+// //2.创建httpclient对象
+// this.httpClient = HttpClients.custom()
+// .setConnectionManager(connectionManager)
+// .disableAutomaticRetries()
+// .build();
+// }
+ private PoolingHttpClientConnectionManager connectionManager;
+ /**
+ * 创建一个httpClient对象
+ */
+ private CloseableHttpClient getHttpCline(){
+ return HttpClients.custom()
.setConnectionManager(connectionManager)
.disableAutomaticRetries()
.build();
}
-
private RequestConfig getRequestConfig(){
return RequestConfig.custom()
.setConnectTimeout(60000)
@@ -71,7 +83,7 @@
* @param url 请求地址
* @param params 请求参数
*/
- private void setPostHttpRequset(String url, Map<String, Object> params, Map<String, String> header, String contentType){
+ 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){
@@ -83,30 +95,20 @@
if(null != params){
Set<String> keys = params.keySet();
for(String key : keys){
- list.add(new BasicNameValuePair(key, params.get(key).toString()));
+ list.add(new BasicNameValuePair(key, null == params.get(key) ? null : params.get(key).toString()));
}
}
- try {
- switch (contentType){
- case "form":
- httpPost.setEntity(new UrlEncodedFormEntity(list, "UTF-8"));
- break;
- case "json":
- ObjectMapper objectMapper = new ObjectMapper();
- String s =objectMapper.writeValueAsString(params);
- System.err.println(s);
- httpPost.setEntity(new StringEntity(s, Charset.forName("UTF-8")));
- break;
- }
- this.getHttpCline();
- if(null == this.httpClient){
- this.getHttpCline();
- }
- httpResponse = this.httpClient.execute(httpPost);
- } catch (IOException e) {
- e.printStackTrace();
- this.close();
+ switch (contentType){
+ case "form":
+ httpPost.setEntity(new UrlEncodedFormEntity(list, "UTF-8"));
+ break;
+ case "json":
+ ObjectMapper objectMapper = new ObjectMapper();
+ String s =objectMapper.writeValueAsString(params);
+ httpPost.setEntity(new StringEntity(s, ContentType.create(ContentType.APPLICATION_JSON.getMimeType(), Charset.forName("UTF-8"))));
+ break;
}
+ return getHttpCline().execute(httpPost);
}
@@ -115,7 +117,7 @@
* @param url 请求地址
* @param params 请求参数
*/
- private void setGetHttpRequset(String url, Map<String, Object> params, Map<String, String> header){
+ private CloseableHttpResponse setGetHttpRequset(String url, Map<String, Object> params, Map<String, String> header) throws Exception{
StringBuffer sb = new StringBuffer();
String p = "";
if(null != params){
@@ -126,23 +128,86 @@
p = "?" + sb.substring(0, sb.length() - 1);
}
HttpGet httpGet = new HttpGet(url + p);
+ httpGet.setConfig(getRequestConfig());
if(null != header){
for(String key : header.keySet()){
httpGet.setHeader(key, header.get(key));
}
}
- this.getHttpCline();
- if(null == this.httpClient){
- this.getHttpCline();
- }
- try {
- httpResponse = this.httpClient.execute(httpGet);
- } catch (IOException e) {
- e.printStackTrace();
- this.close();
- }
+ return getHttpCline().execute(httpGet);
}
+ /**
+ * 获取get请求实例
+ * @param url 请求地址
+ * @param params 请求参数
+ */
+// private CloseableHttpResponse setGetHttpRequset(String url, Map<String, Object> params, Map<String, String> header) throws Exception{
+// StringBuffer sb = new StringBuffer();
+// String p = "";
+// if(null != params){
+// Set<String> keys = params.keySet();
+// 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()){
+// httpGet.setHeader(key, header.get(key));
+// }
+// }
+// return getHttpCline().execute(httpGet);
+// }
+// /**
+// * 发送http请求
+// * @param mothed "GET、POST、PUT、HEAD、DELETE、HEAD、OPTIONS"
+// * @param url 请求地址
+// * @param params 请求参数
+// * @param header 请求头
+// * @param contentType 参数请求方式form/json
+// * @return
+// */
+// public String pushHttpRequset(String mothed, String url, Map<String, Object> params, Map<String, String> header, String contentType){
+// String content = null;
+// switch (mothed){
+// case "GET":
+// this.setGetHttpRequset(url, params, header);
+// break;
+// case "POST":
+// this.setPostHttpRequset(url, params, header, contentType);
+// break;
+// }
+// if(httpResponse.getStatusLine().getStatusCode() == 200){
+// try {
+// content = EntityUtils.toString(httpResponse.getEntity());
+// this.close();
+// return content;
+// } catch (IOException e) {
+// e.printStackTrace();
+// this.close();
+// }
+// }
+// if(httpResponse.getStatusLine().getStatusCode() == 201){
+// content = "{\"status\":201}";
+// this.close();
+// return content;
+// }else{
+// try {
+// System.err.println("返回状态码：" + httpResponse.getStatusLine() + "。");
+// content = EntityUtils.toString(httpResponse.getEntity());
+// this.close();
+// return content;
+// } catch (IOException e) {
+// e.printStackTrace();
+// this.close();
+// }
+// }
+// this.close();
+// return content;
+// }
/**
* 发送http请求
@@ -153,46 +218,26 @@
* @param contentType 参数请求方式form/json
* @return
*/
- public String pushHttpRequset(String mothed, String url, Map<String, Object> params, Map<String, String> header, String contentType){
- String content = null;
+ 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");
+ System.err.println(sdf.format(new Date()) + "----（" + randome + "）请求参数：" + JSON.toJSONString(params));
+ CloseableHttpResponse httpResponse = null;
switch (mothed){
case "GET":
- this.setGetHttpRequset(url, params, header);
+ httpResponse = this.setGetHttpRequset(url, params, header);
break;
case "POST":
- this.setPostHttpRequset(url, params, header, contentType);
+ httpResponse = setPostHttpRequset(url, params, header, contentType);
break;
}
- if(httpResponse.getStatusLine().getStatusCode() == 200){
- try {
- content = EntityUtils.toString(httpResponse.getEntity());
- this.close();
- return content;
- } catch (IOException e) {
- e.printStackTrace();
- this.close();
- }
- }
- if(httpResponse.getStatusLine().getStatusCode() == 201){
- content = "{\"status\":201}";
- this.close();
- return content;
- }else{
- try {
- System.err.println("返回状态码：" + httpResponse.getStatusLine() + "。");
- content = EntityUtils.toString(httpResponse.getEntity());
- this.close();
- return content;
- } catch (IOException e) {
- e.printStackTrace();
- this.close();
- }
- }
- this.close();
- return content;
+ int statusCode = httpResponse.getStatusLine().getStatusCode();
+ String content = EntityUtils.toString(httpResponse.getEntity(), "UTF-8");
+ System.err.println(sdf.format(new Date()) + "----（" + randome + "）返回结果：" + content);
+ HttpResult httpResult = HttpResult.getHttpResult(statusCode, content);
+ this.close(httpResponse);
+ return httpResult;
}
-
-
/**
* 发送XML请求
* @param url 请求地址
@@ -200,46 +245,20 @@
* @param header 自定义请求头
* @return
*/
- public String pushHttpRequsetXml(String url, String xml, Map<String, String> header){
+ public 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()){
httpPost.setHeader(key, header.get(key));
}
httpPost.setHeader("Content-Type", "application/xml");
- try {
- httpPost.setEntity(new StringEntity(xml, "UTF-8"));
- this.getHttpCline();
- if(null == this.httpClient){
- this.getHttpCline();
- }
- httpResponse = this.httpClient.execute(httpPost);
- String content = null;
- if(httpResponse.getStatusLine().getStatusCode() == 200){
- try {
- content = EntityUtils.toString(httpResponse.getEntity(), "UTF-8");
- this.close();
- return content;
- } catch (IOException e) {
- e.printStackTrace();
- this.close();
- }
- }else{
- try {
- content = "返回状态码：" + httpResponse.getStatusLine() + "。" + EntityUtils.toString(httpResponse.getEntity());
- this.close();
- return content;
- } catch (IOException e) {
- e.printStackTrace();
- this.close();
- }
- }
- this.close();
- return content;
- } catch (IOException e) {
- e.printStackTrace();
- this.close();
- }
- return null;
+ httpPost.setEntity(new StringEntity(xml, "UTF-8"));
+ CloseableHttpResponse httpResponse = getHttpCline().execute(httpPost);
+ int statusCode = httpResponse.getStatusLine().getStatusCode();
+ String content = EntityUtils.toString(httpResponse.getEntity(), "UTF-8");
+ HttpResult httpResult = HttpResult.getHttpResult(statusCode, content);
+ this.close(httpResponse);
+ return httpResult;
}
@@ -261,34 +280,18 @@
httpPost.setHeader(key, header.get(key));
}
httpPost.setHeader("Content-Type", "application/xml");
- try {
- httpPost.setEntity(new StringEntity(xml, "UTF-8"));
- this.getHttpCline();
- this.initCert(certPassword, certPath, certType);
- httpResponse = this.httpClient.execute(httpPost);
- String content = null;
- if(httpResponse.getStatusLine().getStatusCode() == 200){
- try {
- content = EntityUtils.toString(httpResponse.getEntity(), "UTF-8");
- } catch (IOException e) {
- e.printStackTrace();
- this.close();
- }
- }else{
- try {
- content = "返回状态码：" + httpResponse.getStatusLine() + "。" + EntityUtils.toString(httpResponse.getEntity());
- } catch (IOException e) {
- e.printStackTrace();
- this.close();
- }
- }
- this.close();
- return content;
- } catch (IOException e) {
- e.printStackTrace();
- this.close();
+ httpPost.setEntity(new StringEntity(xml, "UTF-8"));
+ CloseableHttpClient httpCline = this.initCert(certPassword, certPath, certType);
+ CloseableHttpResponse httpResponse = httpCline.execute(httpPost);
+ String content = null;
+ if(httpResponse.getStatusLine().getStatusCode() == 200){
+ content = EntityUtils.toString(httpResponse.getEntity(), "UTF-8");
+ }else{
+ content = "返回状态码：" + httpResponse.getStatusLine() + "。" + EntityUtils.toString(httpResponse.getEntity());
}
- return null;
+ this.close(httpResponse);
+ httpCline.close();
+ return content;
}
@@ -299,11 +302,9 @@
* @param certType 证书类型
* @throws Exception
*/
- private void initCert(String key, String certPath, String certType) throws Exception {
+ private CloseableHttpClient initCert(String key, String certPath, String certType) throws Exception {
KeyStore keyStore = KeyStore.getInstance(certType);
-// ClassPathResource cp = new ClassPathResource(certPath);
InputStream inputStream = new FileInputStream(new File(certPath));
-// InputStream instream = cp.getInputStream();
try {
keyStore.load(inputStream, key.toCharArray());
} finally {
@@ -313,28 +314,23 @@
SSLConnectionSocketFactory sslsf =
new SSLConnectionSocketFactory(sslcontext, new String[] {"TLSv1"}, null,
SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);
- this.httpClient = HttpClients.custom().setSSLSocketFactory(sslsf).build();
+ return HttpClients.custom().setSSLSocketFactory(sslsf).build();
}
/**
* 关闭资源
*/
- private void close(){
+ private void close(CloseableHttpResponse httpResponse){
try {
- if(null != httpClient){
- httpClient.close();
- }
if(null != httpResponse){
+ EntityUtils.consume(httpResponse.getEntity());//此处高能，通过源码分析，由EntityUtils是否回收HttpEntity
httpResponse.close();
}
- } catch (IOException e) {
+ } catch (Exception e) {
e.printStackTrace();
}finally {
try {
- if(null != httpClient){
- httpClient.close();
- }
if(null != httpResponse){
httpResponse.close();
}
--
Gitblit v1.7.1