From c804490e2cac13bcb1bb5628a6a28633cd6e7026 Mon Sep 17 00:00:00 2001 From: JiyangTang <18010816106@163.com> Date: Wed, 5 Jul 2023 15:16:33 +0800 Subject: [PATCH] =?UTF-8?q?=E5=85=AC=E5=91=8A=E7=9B=91=E5=90=AC=E4=BF=AE?= =?UTF-8?q?=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../admin/schedule/NoticeSchedule.java | 7 +- .../top/baogutang/common/utils/HttpUtils.java | 161 ------------------ .../baogutang/common/utils/OkHttpUtil.java | 127 ++++++++++++++ 3 files changed, 131 insertions(+), 164 deletions(-) delete mode 100644 baogutang-common/src/main/java/top/baogutang/common/utils/HttpUtils.java create mode 100644 baogutang-common/src/main/java/top/baogutang/common/utils/OkHttpUtil.java diff --git a/baogutang-admin/src/main/java/top/baogutang/admin/schedule/NoticeSchedule.java b/baogutang-admin/src/main/java/top/baogutang/admin/schedule/NoticeSchedule.java index e2f2e54..4bfe1f0 100644 --- a/baogutang-admin/src/main/java/top/baogutang/admin/schedule/NoticeSchedule.java +++ b/baogutang-admin/src/main/java/top/baogutang/admin/schedule/NoticeSchedule.java @@ -15,7 +15,7 @@ import top.baogutang.admin.utils.DingTalkMsgPushUtils; import top.baogutang.common.domain.Page; import top.baogutang.common.domain.Results; import top.baogutang.common.properties.WxMsgPushProperties; -import top.baogutang.common.utils.HttpUtils; +import top.baogutang.common.utils.OkHttpUtil; import javax.annotation.Resource; import java.util.Objects; @@ -56,7 +56,7 @@ public class NoticeSchedule { */ @Scheduled(cron = "0 0/1 * * * ? ") public void edgeXNotice() { - Results> results = HttpUtils.get(EDGE_X_REQUEST_URL, new TypeReference>>() { + Results> results = OkHttpUtil.get(EDGE_X_REQUEST_URL, null, null, new TypeReference>>() { }); log.info(">>>>>>>>>>请求获取edgeX公告返回数据：{}<<<<<<<<<<", JSON.toJSONString(results)); if (Objects.isNull(results)) { @@ -84,8 +84,9 @@ public class NoticeSchedule { */ @Scheduled(cron = "0 0/1 * * * ? ") public void edgeNotice() { - Results> results = HttpUtils.get(EDGE_REQUEST_URL, new TypeReference>>() { + Results> results = OkHttpUtil.get(EDGE_REQUEST_URL, null, null, new TypeReference>>() { }); + log.info(">>>>>>>>>>请求获取edge公告返回数据：{}<<<<<<<<<<", JSON.toJSONString(results)); if (Objects.isNull(results)) { return; diff --git a/baogutang-common/src/main/java/top/baogutang/common/utils/HttpUtils.java b/baogutang-common/src/main/java/top/baogutang/common/utils/HttpUtils.java deleted file mode 100644 index be5c4ff..0000000 --- a/baogutang-common/src/main/java/top/baogutang/common/utils/HttpUtils.java +++ /dev/null @@ -1,161 +0,0 @@ -package top.baogutang.common.utils; - -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.TypeReference; -import lombok.extern.slf4j.Slf4j; -import top.baogutang.common.constants.ErrorCodeEnum; -import top.baogutang.common.exceptions.BusinessException; - -import java.io.ByteArrayOutputStream; -import java.io.IOException; -import java.io.InputStream; -import java.io.OutputStream; -import java.net.HttpURLConnection; -import java.net.URL; -import java.nio.charset.StandardCharsets; -import java.util.Map; -import java.util.Set; - -/** - * 说明：网络请求工具 - * - * @author nikooh - */ -@Slf4j -public final class HttpUtils { - private static final String CHARSET_NAME = "UTF-8"; - - private HttpUtils() { - - } - - /** - * 发送post请求 - * - * @param data 发送的数据 - * @param url 请求后台的url - * @return 发送的result结果 - */ - public static T post(Object data, String url, TypeReference type) { - try { - if (data == null) { - return null; - } - String dataStr = JSON.toJSONString(data); - - URL cUrl = new URL(url); - HttpURLConnection urlConnection = (HttpURLConnection) cUrl.openConnection(); - urlConnection.setConnectTimeout(60000); - urlConnection.setReadTimeout(60000); - urlConnection.setUseCaches(false); - urlConnection.setRequestMethod("POST"); - //设置请求属性 - urlConnection.setRequestProperty("Content-Type", "application/json"); - urlConnection.setRequestProperty("Charset", CHARSET_NAME); - urlConnection.setDoOutput(true); - urlConnection.connect(); - OutputStream outputStream = urlConnection.getOutputStream(); - outputStream.write(dataStr.getBytes(StandardCharsets.UTF_8)); - outputStream.flush(); - return dealConnect(urlConnection, type); - } catch (Exception e) { - log.error(">>>>>>>>>>请求异常：{}<<<<<<<<<<", e.getMessage(), e); - throw new BusinessException(ErrorCodeEnum.E_BIZ_ERROR); - } - } - - public static T get(String path, TypeReference type) { - return get(null, path, type); - } - - /** - * 发送get请求 - */ - public static T get(Map data, String url, TypeReference type) { - try { - String query = parseMap2Query(data); - if (!query.isEmpty()) { - url = url + "?" + query; - } - URL cUrl = new URL(url); - HttpURLConnection urlConnection = (HttpURLConnection) cUrl.openConnection(); - urlConnection.setConnectTimeout(60000); - urlConnection.setReadTimeout(60000); - urlConnection.setUseCaches(false); - urlConnection.setRequestMethod("GET"); - //设置请求属性 - urlConnection.setRequestProperty("Charset", CHARSET_NAME); - urlConnection.setDoOutput(true); - urlConnection.connect(); - return dealConnect(urlConnection, type); - } catch (Exception e) { - log.error(">>>>>>>>>>请求异常：{}<<<<<<<<<<", e.getMessage(), e); - throw new BusinessException(ErrorCodeEnum.E_BIZ_ERROR); - } - } - - /** - * 把map转成query查询字符串 - */ - private static String parseMap2Query(Map data) { - if (data == null || data.size() <= 0) { - return ""; - } - Set> entries = data.entrySet(); - StringBuilder stringBuilder = new StringBuilder(); - for (Map.Entry entry : entries) { - if (stringBuilder.length() > 0) { - stringBuilder.append("&"); - } - stringBuilder.append(entry.getKey()).append("=").append(entry.getValue()); - } - return stringBuilder.toString(); - } - - - /** - * 处理连接以后的状态信息 - * - * @param urlConnection 打开的连接 - * @return 返回发送结果 - */ - private static T dealConnect(HttpURLConnection urlConnection, TypeReference type) { - try { - int responseCode = urlConnection.getResponseCode(); - if (responseCode != 200) { - throw new BusinessException(ErrorCodeEnum.E_BIZ_ERROR); - } - InputStream inputStream = urlConnection.getInputStream(); - String res = inputStream2String(inputStream); - if (res == null || res.isEmpty()) { - return null; - } - return JSON.parseObject(res, type); - - } catch (Exception e) { - log.error(">>>>>>>>>>请求异常：{}<<<<<<<<<<", e.getMessage(), e); - throw new BusinessException(ErrorCodeEnum.E_BIZ_ERROR); - } - } - - /** - * 从输入流中读取内容到字符串 - * - * @param inputStream 输入路 - * @return 返回字符串 - */ - private static String inputStream2String(InputStream inputStream) { - ByteArrayOutputStream outputStream = new ByteArrayOutputStream(); - int len = 0; - byte[] bytes = new byte[4096]; - try { - while ((len = inputStream.read(bytes)) != -1) { - outputStream.write(bytes, 0, len); - } - return new String(outputStream.toByteArray(), StandardCharsets.UTF_8); - } catch (IOException e) { - log.error(">>>>>>>>>>请求异常：{}<<<<<<<<<<", e.getMessage(), e); - throw new BusinessException(ErrorCodeEnum.E_BIZ_ERROR); - } - } -} diff --git a/baogutang-common/src/main/java/top/baogutang/common/utils/OkHttpUtil.java b/baogutang-common/src/main/java/top/baogutang/common/utils/OkHttpUtil.java new file mode 100644 index 0000000..761f1b2 --- /dev/null +++ b/baogutang-common/src/main/java/top/baogutang/common/utils/OkHttpUtil.java @@ -0,0 +1,127 @@ +package top.baogutang.common.utils; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.TypeReference; +import lombok.extern.slf4j.Slf4j; +import okhttp3.*; +import org.apache.commons.lang.StringUtils; + +import java.util.Map; +import java.util.Objects; +import java.util.concurrent.TimeUnit; + +/** + * okhttp连接池单例 + * + * @author developer + **/ +@Slf4j +public class OkHttpUtil { + private OkHttpUtil() { + } + + public static OkHttpClient getInstance() { + return Singleton.INSTANCE.getInstance(); + } + + private enum Singleton { + /** + * + */ + INSTANCE; + private final OkHttpClient singleton; + + Singleton() { + OkHttpClient.Builder builder = new OkHttpClient.Builder(); + builder.connectTimeout(10L, TimeUnit.SECONDS); + builder.readTimeout(60L, TimeUnit.SECONDS); + builder.writeTimeout(60L, TimeUnit.SECONDS); + ConnectionPool connectionPool = new ConnectionPool(50, 60, TimeUnit.SECONDS); + builder.connectionPool(connectionPool); + singleton = builder.build(); + } + + public OkHttpClient getInstance() { + return singleton; + } + } + + + public static T post(String url, Map params, TypeReference type) { + try { + FormBody.Builder builder = new FormBody.Builder(); + params.forEach(builder::add); + RequestBody body = builder.build(); + Request request = new Request.Builder().post(body).url(url).build(); + Response response = OkHttpUtil.getInstance().newCall(request).execute(); + if (response.isSuccessful()) { + String content = Objects.requireNonNull(response.body()).string(); + if (StringUtils.isNotBlank(content)) { + return JSON.parseObject(content, type); + } + } else { + log.error("postRequest fail ,url:{}, params:{}, res:{}", url, params, response); + } + } catch (Exception e) { + log.error(">>>>>>>>>>request error:{}<<<<<<<<<<", e.getMessage(), e); + } + return null; + } + + public static T post(String url, Map headerMap, Map params, TypeReference type) { + try { + Headers.Builder headerBuilder = new Headers.Builder(); + if (Objects.nonNull(headerMap) && !headerMap.isEmpty()) { + headerMap.forEach(headerBuilder::add); + } + RequestBody body = RequestBody.create(JSON.toJSONString(params), MediaType.parse("application/json; charset=utf-8")); + Request request = new Request.Builder().post(body).headers(headerBuilder.build()).url(url).build(); + Response response = OkHttpUtil.getInstance().newCall(request).execute(); + log.info("postJSONRequestReq:{},Res:{}, ", JSON.toJSONString(params), JSON.toJSONString(response)); + if (response.isSuccessful()) { + String content = Objects.requireNonNull(response.body()).string(); + if (StringUtils.isNotBlank(content)) { + return JSON.parseObject(content, type); + } + } else { + log.error("postJSONRequest fail ,url:{}, params:{}, res:{}", url, params, response); + } + } catch (Exception e) { + log.error(">>>>>>>>>>request error:{}<<<<<<<<<<", e.getMessage(), e); + } + return null; + } + + + public static T get(String url, Map headerMap, Map params, TypeReference type) { + try { + StringBuilder urlBuilder = new StringBuilder(); + urlBuilder.append(url); + if (Objects.nonNull(params) && !params.isEmpty()) { + urlBuilder.append("?"); + for (Map.Entry m : params.entrySet()) { + urlBuilder.append(m.getKey()).append("="); + urlBuilder.append(m.getValue()).append("&"); + } + } + Headers.Builder headerBuilder = new Headers.Builder(); + if (Objects.nonNull(headerMap) && !headerMap.isEmpty()) { + headerMap.forEach(headerBuilder::add); + } + Request request = new Request.Builder().get().url(urlBuilder.toString()).headers(headerBuilder.build()).build(); + Response response = OkHttpUtil.getInstance().newCall(request).execute(); + if (response.isSuccessful()) { + String content = Objects.requireNonNull(response.body()).string(); + if (StringUtils.isNotBlank(content)) { + return JSON.parseObject(content, type); + } + } else { + log.error("getRequest fail ,url:{}, params:{}, res:{}", url, params, response); + } + } catch (Exception e) { + log.error(">>>>>>>>>>request error:{}<<<<<<<<<<", e.getMessage(), e); + } + return null; + } + +} \ No newline at end of file