From 3d8010f46010e3cc04fc741a090a8a534127cb4b Mon Sep 17 00:00:00 2001 From: xiang Date: Mon, 28 Jul 2025 22:32:15 +0800 Subject: [PATCH] =?UTF-8?q?feat:=E6=96=B0=E5=A2=9E=E9=87=8D=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../xiang/xservice/basic/utils/HttpUtils.java | 23 +++++++++++++++---- 1 file changed, 19 insertions(+), 4 deletions(-) diff --git a/xservice-common/src/main/java/com/xiang/xservice/basic/utils/HttpUtils.java b/xservice-common/src/main/java/com/xiang/xservice/basic/utils/HttpUtils.java index 3dfa0fc..3ce7c3a 100644 --- a/xservice-common/src/main/java/com/xiang/xservice/basic/utils/HttpUtils.java +++ b/xservice-common/src/main/java/com/xiang/xservice/basic/utils/HttpUtils.java @@ -1,5 +1,7 @@ package com.xiang.xservice.basic.utils; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.MapUtils; import org.apache.http.client.config.RequestConfig; @@ -56,7 +58,7 @@ public class HttpUtils { .build(); } - public static String doPost(String url, Map header, String jsonParams) { + public static String doPostV1(String url, Map header, String jsonParams) { RequestConfig requestConfig = RequestConfig.custom() // 设置连接超时时间 .setConnectTimeout(connectTimeout) @@ -82,7 +84,7 @@ public class HttpUtils { return result; } - public static String doPostV2(String url, Map header, String jsonParams) { + public static String doPost(String url, Map header, String jsonParams) { CloseableHttpResponse response = null; String result = ""; try { @@ -99,7 +101,20 @@ public class HttpUtils { return result; } - public static String doGetV2(String url, Map header, Map param) { + public static String doPostWithRetry(String url, Map header, String jsonParams, Integer successCode, int retryCounts) { + int i = 0; + while (i++ < retryCounts) { + String respStr = doPost(url, header, jsonParams); + JSONObject resp = JSON.parseObject(respStr); + Integer code = (Integer) resp.get("code"); + if (successCode.equals(code)) { + return respStr; + } + } + return null; + } + + public static String doGet(String url, Map header, Map param) { CloseableHttpResponse response = null; String result = ""; try { @@ -148,7 +163,7 @@ public class HttpUtils { return httpPost; } - public static String doGet(String url, Map header, Map param) { + public static String doGetV1(String url, Map header, Map param) { RequestConfig requestConfig = RequestConfig.custom() // 设置连接超时时间 .setConnectTimeout(connectTimeout)