From 2d5e6b72fe1c74d909116bf62ac1d2897dfe841a Mon Sep 17 00:00:00 2001 From: zhangyuan Date: Thu, 8 Dec 2022 09:43:41 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8E=A8=E9=80=81=E6=96=B9=E6=B3=95=E8=BF=BD?= =?UTF-8?q?=E5=8A=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../esua/httpclient/HttpClientUtils.java | 116 ++++++++++++++++++ .../esua/httpclient/HttpDeleteWithBody.java | 27 ++++ 2 files changed, 143 insertions(+) create mode 100644 spring-boot-httpclient-starter/src/main/java/com/elink/esua/httpclient/HttpDeleteWithBody.java diff --git a/spring-boot-httpclient-starter/src/main/java/com/elink/esua/httpclient/HttpClientUtils.java b/spring-boot-httpclient-starter/src/main/java/com/elink/esua/httpclient/HttpClientUtils.java index be78b16..d22581d 100644 --- a/spring-boot-httpclient-starter/src/main/java/com/elink/esua/httpclient/HttpClientUtils.java +++ b/spring-boot-httpclient-starter/src/main/java/com/elink/esua/httpclient/HttpClientUtils.java @@ -6,10 +6,12 @@ import org.apache.http.HttpStatus; import org.apache.http.NameValuePair; import org.apache.http.ParseException; 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.HttpPut; import org.apache.http.client.utils.URLEncodedUtils; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; @@ -17,6 +19,7 @@ import org.apache.http.message.BasicNameValuePair; import org.apache.http.util.EntityUtils; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; +import org.springframework.util.StringUtils; import java.io.IOException; import java.net.URI; @@ -38,6 +41,17 @@ public class HttpClientUtils { private CloseableHttpClient client; + private static final int CONNECTION_TIMEOUT = 5000; + /** + * 读取数据超时时间，毫秒 + */ + private static final int SO_TIMEOUT = 45000; + private static final String HEADER_CONTENT_TYPE = "Content-Type"; + private static final String HEADER_APPLICATION_JSON = "application/json;charset=utf-8"; + private static final String UTF8 = "utf-8"; + private static final String HEADER_APPLICATION_FORM_URL_ENCODED = "application/x-www-form-urlencoded;charset=utf-8"; + + public HttpClientUtils(HttpClientManagerFactoryBen httpClientBean) { try { this.client = httpClientBean.getObject(); @@ -127,6 +141,96 @@ public class HttpClientUtils { return getResult(client.execute(httpPost)); } + /** + * post json + * + * @param url + * @param jsonStrParam + * @param headerMap + * @return com.elink.esua.httpclient.ResultDto + * @author zhy + * @date 2022/9/6 9:41 + */ + public ResultDto sendPostByJSONAndHeader(String url, String jsonStrParam, Map headerMap) { + + try { + HttpPost httppost = new HttpPost(url); + httppost.setConfig(REQUEST_CONFIG); + httppost.addHeader(HEADER_CONTENT_TYPE, HEADER_APPLICATION_JSON); + if (null != headerMap) { + headerMap.forEach(httppost::addHeader); + } + if (!StringUtils.isEmpty(jsonStrParam)) { + StringEntity se = new StringEntity(jsonStrParam, UTF8); + httppost.setEntity(se); + } + return getResult(client.execute(httppost)); + } catch (Exception e) { + return null; + } + + } + + /** + * put json + * + * @param url + * @param jsonStrParam + * @param headerMap + * @return com.elink.esua.httpclient.ResultDto + * @author zhy + * @date 2022/9/6 9:41 + */ + public ResultDto sendPutByJSONAndHeader(String url, String jsonStrParam, Map headerMap) { + + try { + HttpPut httpPut = new HttpPut(url); + httpPut.setConfig(REQUEST_CONFIG); + httpPut.addHeader(HEADER_CONTENT_TYPE, HEADER_APPLICATION_JSON); + if (null != headerMap) { + headerMap.forEach(httpPut::addHeader); + } + if (!StringUtils.isEmpty(jsonStrParam)) { + StringEntity se = new StringEntity(jsonStrParam, UTF8); + httpPut.setEntity(se); + } + return getResult(client.execute(httpPut)); + } catch (Exception e) { + return null; + } + + } + + /** + * delete json + * + * @param url + * @param jsonStrParam + * @param headerMap + * @return com.elink.esua.httpclient.ResultDto + * @author zhy + * @date 2022/9/6 9:41 + */ + public ResultDto sendDeleteByJSONAndHeader(String url, String jsonStrParam, Map headerMap) { + + try { + HttpDeleteWithBody httpDelete = new HttpDeleteWithBody(url); + httpDelete.setConfig(REQUEST_CONFIG); + httpDelete.addHeader(HEADER_CONTENT_TYPE, HEADER_APPLICATION_JSON); + if (null != headerMap) { + headerMap.forEach(httpDelete::addHeader); + } + if (!StringUtils.isEmpty(jsonStrParam)) { + StringEntity se = new StringEntity(jsonStrParam, UTF8); + httpDelete.setEntity(se); + } + return getResult(client.execute(httpDelete)); + } catch (Exception e) { + return null; + } + + } + /** * get 提交方式 * @@ -153,6 +257,11 @@ public class HttpClientUtils { return getResult(client.execute(httpGet)); } + public String getParamStr(Map paramMap) { + List formparams = setHttpParams(paramMap); + return URLEncodedUtils.format(formparams, "UTF-8"); + } + /** * 设置请求参数 * @@ -169,4 +278,11 @@ public class HttpClientUtils { } return formparams; } + + /*** 超时设置 ****/ + private static final RequestConfig REQUEST_CONFIG = RequestConfig.custom() + .setSocketTimeout(SO_TIMEOUT) + .setConnectTimeout(CONNECTION_TIMEOUT) + .setConnectionRequestTimeout(SO_TIMEOUT) + .build();//设置请求和传输超时时间 } diff --git a/spring-boot-httpclient-starter/src/main/java/com/elink/esua/httpclient/HttpDeleteWithBody.java b/spring-boot-httpclient-starter/src/main/java/com/elink/esua/httpclient/HttpDeleteWithBody.java new file mode 100644 index 0000000..a16a6cb --- /dev/null +++ b/spring-boot-httpclient-starter/src/main/java/com/elink/esua/httpclient/HttpDeleteWithBody.java @@ -0,0 +1,27 @@ +package com.elink.esua.httpclient; + +import org.apache.http.client.methods.HttpEntityEnclosingRequestBase; + +import java.net.URI; + +/** + * 带body的delete方法 + * + * @author zhy + * @date 2022/12/7 17:50 + */ +public class HttpDeleteWithBody extends HttpEntityEnclosingRequestBase { + public static final String METHOD_NAME = "DELETE"; + public String getMethod() { return METHOD_NAME; } + + public HttpDeleteWithBody(final String uri) { + super(); + setURI(URI.create(uri)); + } + public HttpDeleteWithBody(final URI uri) { + super(); + setURI(uri); + } + public HttpDeleteWithBody() { super(); } +} +