sxyanzhu
/
jhprjv2
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

提交代码

dev_xds
姜玉琦 2024-01-14 17:14:15 +08:00
parent d49091a697
commit 567fd3f237
4 changed files with 741 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

221
ruoyi-admin/src/main/java/com/ruoyi/api/labour/controller/LabourApiController.java
View File

@ -1,6 +1,7 @@
package com.ruoyi.api.labour.controller;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.api.base.TokenReqVo;
import com.ruoyi.api.labour.domain.LabourSignetVo;
@ -17,8 +18,11 @@ import com.ruoyi.common.enums.LimitType;
import com.ruoyi.common.enums.ShiFouEnum;
import com.ruoyi.common.enums.UserTypeEnum;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.AuthRsaUtils;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.http.HttpClientUtil;
import com.ruoyi.common.utils.sign.Md5Utils;
import com.ruoyi.framework.web.service.SysLoginService;
import com.ruoyi.system.domain.SysApplyConfig;
import com.ruoyi.system.service.ISysUserService;
@ -38,9 +42,7 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.*;
/**
* 劳务人员APIController
@ -442,4 +444,217 @@ public class LabourApiController extends BaseController {
return success(failServiceIdList);
}
private static final String publicKey = "";
private static final String baseUrl = "http://localhost:8090/jhapi";
private static final String token = "eyJhbGciOiJIUzUxMiJ9.eyJsb2dpbl91c2VyX2tleSI6Ijk1OWIwODAzLTU3NjEtNDBlOS1iYWUxLWJhNzQ0NjkyNmNkMCJ9.BKEaL5vGknNX6aVwYqG1xlJqv9haByoCD4Qo5alXXPWY3PkQsyKuLCN-Iw2ZHM3B4MX9XahrS2sT9Y3RjmuWXA";
/**
* 推送,修改班组信息【示例代码】
*/
public static String getToken(){
String timestamp = String.valueOf(System.currentTimeMillis());
String appId = "jhcf170515993052073qrDFKJmk001";
try {
// 明文信息->公钥加密
String encryptByPublicKeyStr = AuthRsaUtils.encryptByPublicKey(publicKey, appId+timestamp);
log.info("公钥加密...{}" , encryptByPublicKeyStr);
// redis中查询->未查询到则重新获取
String url = baseUrl + "/api/labour/v1/getToken";
Map<String, Object> body = new HashMap<>();
body.put("appId",appId);
body.put("sign",encryptByPublicKeyStr);
body.put("timestamp",timestamp);
String result = HttpClientUtil.doPost(url, null, com.alibaba.fastjson2.JSON.toJSONString(body));
JSONObject jsonObject = JSONObject.parseObject(result);
if(jsonObject.getInteger("code")==200){
// 获取到存入redis，设置30分钟有效期
String token = jsonObject.getString("Authorization");
log.info("Authorization...{}" , token);
return token;
}
}catch (Exception e){
e.printStackTrace();
}
return null;
}
/**
* 推送,修改班组信息【示例代码】
*/
public static void pushLabourGroup(){
Map<String,Object> map = new HashMap<>();
map.put("serverid","1");
String jsonString = JSONObject.toJSONString(map);
String timestamp = String.valueOf(System.currentTimeMillis());
try {
// 明文信息->公钥加密
String encryptByPublicKeyStr = AuthRsaUtils.encryptByPublicKey(publicKey, Md5Utils.hash(jsonString)+timestamp);
log.info("公钥加密...{}" , encryptByPublicKeyStr);
String url = baseUrl + "/api/labour/v1/pushLabourGroup";
Map<String, Object> body = new HashMap<>();
body.put("sign",encryptByPublicKeyStr);
body.put("data",jsonString);
body.put("timestamp",timestamp);
// redis中查询->未查询到则重新获取
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", token);
String result = HttpClientUtil.doPost(url, headers, com.alibaba.fastjson2.JSON.toJSONString(body));
JSONObject jsonObject = JSONObject.parseObject(result);
if(jsonObject.getInteger("code")==200){
log.info("success...{}");
}
}catch (Exception e){
e.printStackTrace();
}
}
/**
* 批量推送班组信息【示例代码】
*/
public static void pushLabourGroupList(List<Map<String,Object>> datas){
String jsonString = JSONObject.toJSONString(datas);
String timestamp = String.valueOf(System.currentTimeMillis());
try {
// 明文信息->公钥加密
String encryptByPublicKeyStr = AuthRsaUtils.encryptByPublicKey(publicKey, Md5Utils.hash(jsonString)+timestamp);
log.info("公钥加密...{}" , encryptByPublicKeyStr);
String url = baseUrl + "/api/labour/v1/pushLabourGroup";
Map<String, Object> body = new HashMap<>();
body.put("sign",encryptByPublicKeyStr);
body.put("data",jsonString);
body.put("timestamp",timestamp);
// redis中查询->未查询到则重新获取
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", token);
String result = HttpClientUtil.doPost(url, headers, com.alibaba.fastjson2.JSON.toJSONString(body));
JSONObject jsonObject = JSONObject.parseObject(result);
if(jsonObject.getInteger("code")==200){
JSONArray jsonArray = jsonObject.getJSONArray("data");
log.info("推送失败下标...{}",jsonArray);
}
}catch (Exception e){
e.printStackTrace();
}
}
/**
* 推送,修改人员信息【示例代码】
*/
public static void pushLabourUser(){
Map<String,Object> map = new HashMap<>();
map.put("workerId","1");
map.put("name","张三");
String jsonString = JSONObject.toJSONString(map);
String timestamp = String.valueOf(System.currentTimeMillis());
try {
// 明文信息->公钥加密
String encryptByPublicKeyStr = AuthRsaUtils.encryptByPublicKey(publicKey, Md5Utils.hash(jsonString)+timestamp);
log.info("公钥加密...{}" , encryptByPublicKeyStr);
String url = baseUrl + "/api/labour/v1/pushLabourUser";
Map<String, Object> body = new HashMap<>();
body.put("sign",encryptByPublicKeyStr);
body.put("data",jsonString);
body.put("timestamp",timestamp);
// redis中查询->未查询到则重新获取
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", token);
String result = HttpClientUtil.doPost(url, headers, com.alibaba.fastjson2.JSON.toJSONString(body));
JSONObject jsonObject = JSONObject.parseObject(result);
if(jsonObject.getInteger("code")==200){
log.info("success...{}");
}
}catch (Exception e){
e.printStackTrace();
}
}
/**
* 批量推送人员信息【示例代码】
*/
public static void pushLabourUserList(List<Map<String,Object>> datas){
String jsonString = JSONObject.toJSONString(datas);
String timestamp = String.valueOf(System.currentTimeMillis());
try {
// 明文信息->公钥加密
String encryptByPublicKeyStr = AuthRsaUtils.encryptByPublicKey(publicKey, Md5Utils.hash(jsonString)+timestamp);
log.info("公钥加密...{}" , encryptByPublicKeyStr);
String url = baseUrl + "/api/labour/v1/pushLabourUserList";
Map<String, Object> body = new HashMap<>();
body.put("sign",encryptByPublicKeyStr);
body.put("data",jsonString);
body.put("timestamp",timestamp);
// redis中查询->未查询到则重新获取
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", token);
String result = HttpClientUtil.doPost(url, headers, com.alibaba.fastjson2.JSON.toJSONString(body));
JSONObject jsonObject = JSONObject.parseObject(result);
if(jsonObject.getInteger("code")==200){
JSONArray jsonArray = jsonObject.getJSONArray("data");
log.info("推送失败下标...{}",jsonArray);
}
}catch (Exception e){
e.printStackTrace();
}
}
/**
* 推送,修改班组人员出勤信息【示例代码】
*/
public static void pushLabourData(){
Map<String,Object> map = new HashMap<>();
map.put("serverid","1");
map.put("workerId","1");
String jsonString = JSONObject.toJSONString(map);
String timestamp = String.valueOf(System.currentTimeMillis());
try {
// 明文信息->公钥加密
String encryptByPublicKeyStr = AuthRsaUtils.encryptByPublicKey(publicKey, Md5Utils.hash(jsonString)+timestamp);
log.info("公钥加密...{}" , encryptByPublicKeyStr);
String url = baseUrl + "/api/labour/v1/pushLabourData";
Map<String, Object> body = new HashMap<>();
body.put("sign",encryptByPublicKeyStr);
body.put("data",jsonString);
body.put("timestamp",timestamp);
// redis中查询->未查询到则重新获取
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", token);
String result = HttpClientUtil.doPost(url, headers, com.alibaba.fastjson2.JSON.toJSONString(body));
JSONObject jsonObject = JSONObject.parseObject(result);
if(jsonObject.getInteger("code")==200){
log.info("success...{}");
}
}catch (Exception e){
e.printStackTrace();
}
}
/**
* 批量推送班组人员出勤信息【示例代码】
*/
public static void pushLabourDataList(List<Map<String,Object>> datas){
String jsonString = JSONObject.toJSONString(datas);
String timestamp = String.valueOf(System.currentTimeMillis());
try {
// 明文信息->公钥加密
String encryptByPublicKeyStr = AuthRsaUtils.encryptByPublicKey(publicKey, Md5Utils.hash(jsonString)+timestamp);
log.info("公钥加密...{}" , encryptByPublicKeyStr);
String url = baseUrl + "/api/labour/v1/pushLabourDataList";
Map<String, Object> body = new HashMap<>();
body.put("sign",encryptByPublicKeyStr);
body.put("data",jsonString);
body.put("timestamp",timestamp);
// redis中查询->未查询到则重新获取
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", token);
String result = HttpClientUtil.doPost(url, headers, com.alibaba.fastjson2.JSON.toJSONString(body));
JSONObject jsonObject = JSONObject.parseObject(result);
if(jsonObject.getInteger("code")==200){
JSONArray jsonArray = jsonObject.getJSONArray("data");
log.info("推送失败下标...{}",jsonArray);
}
}catch (Exception e){
e.printStackTrace();
}
}
}

6
ruoyi-common/pom.xml
View File

@ -163,6 +163,12 @@
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.13</version>
</dependency>
</dependencies>
</project>

2
ruoyi-common/src/main/java/com/ruoyi/common/enums/HttpStatusEnum.java
View File

@ -7,7 +7,7 @@ package com.ruoyi.common.enums;
*/
public enum HttpStatusEnum {
ERROR(11110, "AppId不存在或已被停用"),
ERROR(11110, "AppId不存在或已被删除"),
DISABLE(11112, "AppId已被停用"),
SINGET_ERROR(11113, "签名值不正确"),
SINGET_TIMEOUT(11114, "签名数据已过期"),

516
ruoyi-common/src/main/java/com/ruoyi/common/utils/http/HttpClientUtil.java 100644
View File

@ -0,0 +1,516 @@
package com.ruoyi.common.utils.http;
import com.ruoyi.common.utils.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.Header;
import org.apache.http.NameValuePair;
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.HttpDelete;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;
import org.springframework.http.MediaType;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
/**
* HttpClient工具类
*
* @author: xingxixingzhe
* @date: 2023/9/25 14:18
*/
@Slf4j
public class HttpClientUtil {
public static final String HTTP_CHARSET = "utf-8";
private static final String CONTENTTYPE = "Content-Type";
/**
* get请求
*
* @param url 请求地址
* @param headers 请求头，可以为null
* @return String
*/
public static String doGet(String url, Map<String, String> headers) {
// 创建HttpClient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
// 创建HttpResponse对象
CloseableHttpResponse response = null;
log.info("request param info : {}", url);
log.info("request header info : {}", headers);
try {
try {
// 创建HttpPost对象
HttpGet get = new HttpGet(url);
// 封装请求头
if (null != headers) {
headers.keySet().forEach(key -> {
get.addHeader(key, headers.get(key));
});
}
response = httpClient.execute(get);
String result = EntityUtils.toString(response.getEntity(), Charset.forName(HTTP_CHARSET));
log.info("response info : {}", result);
return result;
} catch (IOException e) {
log.error("get链接失败：" + e.getMessage());
} finally {
// 释放连接
if (response != null) {
response.close();
}
}
} catch (IOException e) {
log.error("get关闭response失败：" + e.getMessage());
}
return null;
}
/**
* get请求
*
* @param url 请求地址
* @param headers 请求头，可以为null
* @param paramMap 请求参数
* @return String
*/
public static String doGetQueryParams(String url, Map<String, String> headers, Map<String, Object> paramMap) {
// 创建HttpClient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
// 创建HttpResponse对象
CloseableHttpResponse response = null;
StringBuilder urlTemp = new StringBuilder(url);
if (null != paramMap && paramMap.size() > 0) {
int index = 0;
for (Map.Entry<String, Object> entry : paramMap.entrySet()) {
if (index == 0) {
urlTemp.append("?").append(entry.getKey()).append("=").append(entry.getValue());
} else {
urlTemp.append("&").append(entry.getKey()).append("=").append(entry.getValue());
}
index++;
}
}
url = urlTemp.toString();
log.info("request param info : {}", url);
log.info("request header info : {}", headers);
try {
try {
// 创建HttpPost对象
HttpGet get = new HttpGet(url);
// 封装请求头
if (null != headers) {
headers.keySet().forEach(key -> {
get.addHeader(key, headers.get(key));
});
}
response = httpClient.execute(get);
String result = EntityUtils.toString(response.getEntity(), Charset.forName(HTTP_CHARSET));
log.info("response info : {}", result);
return result;
} catch (IOException e) {
log.error("get链接失败：" + e.getMessage());
} finally {
// 释放连接
if (response != null) {
response.close();
}
}
} catch (IOException e) {
log.error("get关闭response失败：" + e.getMessage());
}
return null;
}
/**
* get请求 下载文件保存在本地
*
* @param url 请求地址
* @param headers 请求头，可以为null
* @param downloadPath 下载地址
* @return String
*/
public static String doGetDownloadSaveLocal(String url, Map<String, String> headers, String downloadPath) {
// 创建HttpClient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
// 创建HttpResponse对象
CloseableHttpResponse response = null;
log.info("request param info : {}", url);
log.info("request header info : {}", headers);
try {
try {
// 创建HttpPost对象
HttpGet get = new HttpGet(url);
// 封装请求头
if (null != headers) {
headers.keySet().forEach(key -> {
get.addHeader(key, headers.get(key));
});
}
response = httpClient.execute(get);
// 获取下载文件流
InputStream inputStream = response.getEntity().getContent();
// 获取下载文件的文件名，此处的 File-Name 头信息，需要在服务端进行自定义
Header header = response.getFirstHeader("Content-Disposition");
String fileName = header.getValue();
fileName = StringUtils.substringAfter(fileName, "=");
fileName = System.currentTimeMillis() + fileName;
log.info("下载的文件名称:" + fileName);
File file = new File(downloadPath + fileName);
file.getParentFile().mkdirs();
FileOutputStream fileOut = new FileOutputStream(file);
byte[] buffer = new byte[2048];
int ch = 0;
while ((ch = inputStream.read(buffer)) != -1) {
fileOut.write(buffer, 0, ch);
}
inputStream.close();
fileOut.flush();
fileOut.close();
return file.getPath();
} catch (IOException e) {
log.error("get链接失败：" + e.getMessage());
} finally {
// 释放连接
if (response != null) {
response.close();
}
}
} catch (IOException e) {
log.error("get关闭response失败：" + e.getMessage());
}
return null;
}
/**
* get请求 带时间配置请求
*
* @param url 请求地址
* @param headers 请求头，可以为null
* @param connectTimeout 连接超时时间
* @param connectionRequestTimeout 建立连接超时时间，
* @param socketTimeout 读取数据超时时间
* @return String
*/
public static String doGet(String url, Map<String, String> headers,
int connectTimeout, int connectionRequestTimeout, int socketTimeout) {
// 创建HttpClient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
// 创建HttpResponse对象
CloseableHttpResponse response = null;
log.info("request param info : {}", url);
log.info("request header info : {}", headers);
try {
try {
// 创建HttpPost对象
HttpGet get = new HttpGet(url);
get.setConfig(RequestConfig.custom()
.setConnectTimeout(connectTimeout)
.setConnectionRequestTimeout(connectionRequestTimeout)
.setSocketTimeout(socketTimeout).build());
// 封装请求头
if (null != headers) {
headers.keySet().forEach(key -> {
get.addHeader(key, headers.get(key));
});
}
response = httpClient.execute(get);
String result = EntityUtils.toString(response.getEntity(), Charset.forName(HTTP_CHARSET));
log.info("response info : {}", result);
return result;
} catch (IOException e) {
log.error("get链接失败：" + e.getMessage());
} finally {
// 释放连接
if (response != null) {
response.close();
}
}
} catch (IOException e) {
log.error("get关闭response失败：" + e.getMessage());
}
return null;
}
/**
* post请求 body为json 带时间配置请求
*
* @param url 请求地址
* @param headers 请求头，可以为null
* @param body json请求体
* @param connectTimeout 连接超时时间
* @param connectionRequestTimeout 建立连接超时时间，
* @param socketTimeout 读取数据超时时间
* @return String
* @author: lll
* @date: 2022年11月21日 14:11:49
*/
public static String doPost(String url, Map<String, String> headers, String body,
int connectTimeout, int connectionRequestTimeout, int socketTimeout) {
// 创建HttpClient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
// 创建HttpResponse对象
CloseableHttpResponse response = null;
log.info("request param info : {}", body);
log.info("request header info : {}", headers);
try {
try {
// 创建HttpPost对象
HttpPost post = new HttpPost(url);
post.setConfig(RequestConfig.custom()
.setConnectTimeout(connectTimeout)
.setConnectionRequestTimeout(connectionRequestTimeout)
.setSocketTimeout(socketTimeout)
.build());
// 封装请求头
if (null != headers) {
headers.keySet().forEach(key -> {
post.addHeader(key, headers.get(key));
});
}
post.addHeader(HTTP.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
// 封装请求体
if (StringUtils.isNotBlank(body)) {
// 请求体主要封装在HttpEntity中
post.setEntity(new StringEntity(body, Charset.forName(HTTP_CHARSET)));
}
response = httpClient.execute(post);
// 处理响应
String result = EntityUtils.toString(response.getEntity(), Charset.forName(HTTP_CHARSET));
log.info("response info : {}", result);
return result;
} catch (IOException e) {
log.error("post链接失败：" + e.getMessage());
} finally {
// 释放连接
if (response != null) {
response.close();
}
}
} catch (IOException e) {
log.error("post关闭response失败：" + e.getMessage());
}
return null;
}
/**
* post请求 body为json
*
* @param url 请求地址
* @param headers 请求头，可以为null
* @param body json请求体
* @return String
*/
public static String doPost(String url, Map<String, String> headers, String body) {
// 创建HttpClient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
// 创建HttpResponse对象
CloseableHttpResponse response = null;
log.info("request header url : {}", url);
log.info("request param body : {}", body);
log.info("request header headers : {}", headers);
try {
try {
// 创建HttpPost对象
HttpPost post = new HttpPost(url);
// 封装请求头
if (null != headers) {
headers.keySet().forEach(key -> {
post.addHeader(key, headers.get(key));
});
}
post.addHeader(HTTP.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
// 封装请求体
if (StringUtils.isNotBlank(body)) {
// 请求体主要封装在HttpEntity中
post.setEntity(new StringEntity(body, Charset.forName(HTTP_CHARSET)));
}
response = httpClient.execute(post);
// 处理响应
String result = EntityUtils.toString(response.getEntity(), Charset.forName(HTTP_CHARSET));
log.info("response result : {}", result);
return result;
} catch (IOException e) {
log.error("post链接失败：" + e.getMessage());
} finally {
// 释放连接
if (response != null) {
response.close();
}
}
} catch (IOException e) {
log.error("post关闭response失败：" + e.getMessage());
}
return null;
}
/**
* post请求 body为form
* <p>
* post请求 body为json 带时间配置请求
*
* @param url 请求地址
* @param headers 请求头，可以为null
* @param body form请求体
* @return String
*/
public static String doPost(String url, Map<String, String> headers, Map<String, Object> body,
int connectTimeout, int connectionRequestTimeout, int socketTimeout) {
// 创建HttpClient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
// 创建HttpResponse对象
CloseableHttpResponse response = null;
log.info("request param info : {}", body);
log.info("request header info : {}", headers);
try {
try {
// 创建HttpPost对象
HttpPost post = new HttpPost(url);
post.setConfig(RequestConfig.custom().setConnectTimeout(connectTimeout).setConnectionRequestTimeout(connectionRequestTimeout).setSocketTimeout(socketTimeout).build());
// 封装请求头
if (null != headers) {
headers.keySet().forEach(key -> {
post.addHeader(key, headers.get(key));
});
}
// 封装请求体
List<NameValuePair> nvpList = new ArrayList<>();
for (String name : body.keySet()) {
String value = String.valueOf(body.get(name));
nvpList.add(new BasicNameValuePair(name, value));
}
post.setEntity(new UrlEncodedFormEntity(nvpList));
response = httpClient.execute(post);
// 处理响应
String result = EntityUtils.toString(response.getEntity(), Charset.forName(HTTP_CHARSET));
log.info("response info : {}", result);
return result;
} catch (IOException e) {
log.error("post链接失败：" + e.getMessage());
} finally {
// 释放连接
if (response != null) {
response.close();
}
}
} catch (IOException e) {
log.error("post关闭response失败：" + e.getMessage());
}
return null;
}
/**
* post请求 body为form
* <p>
*
* @param url 请求地址
* @param headers 请求头，可以为null
* @param body json请求体
* @return String
*/
public static String doPost(String url, Map<String, String> headers, Map<String, Object> body) {
// 创建HttpClient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
// 创建HttpResponse对象
CloseableHttpResponse response = null;
log.info("request param info : {}", body);
log.info("request header info : {}", headers);
try {
try {
// 创建HttpPost对象
HttpPost post = new HttpPost(url);
// 封装请求头
if (null != headers) {
headers.keySet().forEach(key -> {
post.addHeader(key, headers.get(key));
});
}
// 封装请求体
List<NameValuePair> nvpList = new ArrayList<>();
for (String name : body.keySet()) {
String value = String.valueOf(body.get(name));
nvpList.add(new BasicNameValuePair(name, value));
}
post.setEntity(new UrlEncodedFormEntity(nvpList,HTTP_CHARSET));
response = httpClient.execute(post);
// 处理响应
String result = EntityUtils.toString(response.getEntity(), Charset.forName(HTTP_CHARSET));
log.info("response info : {}", result);
return result;
} catch (IOException e) {
log.error("post链接失败：" + e.getMessage());
} finally {
// 释放连接
if (response != null) {
response.close();
}
}
} catch (IOException e) {
log.error("post关闭response失败：" + e.getMessage());
}
return null;
}
/**
* delete请求
*
* @param url 请求地址
* @param headers 请求头，可以为null
* @return String
*/
public static String doDelete(String url, Map<String, String> headers) {
// 创建HttpClient对象
CloseableHttpClient httpClient = HttpClients.createDefault();
// 创建HttpResponse对象
CloseableHttpResponse response = null;
log.info("request param info : {}", url);
log.info("request header info : {}", headers);
try {
try {
// 创建HttpPost对象
HttpDelete delete = new HttpDelete(url);
// 封装请求头
if (null != headers) {
headers.keySet().forEach(key -> {
delete.addHeader(key, headers.get(key));
});
}
response = httpClient.execute(delete);
String result = EntityUtils.toString(response.getEntity(), Charset.forName(HTTP_CHARSET));
log.info("response info : {}", result);
return result;
} catch (IOException e) {
log.error("delete链接失败：" + e.getMessage());
} finally {
// 释放连接
if (response != null) {
response.close();
}
}
} catch (IOException e) {
log.error("delete关闭response失败：" + e.getMessage());
}
return null;
}
}