From 6eabd62cb0d35fb65b232d3bc1a99de61b9f0942 Mon Sep 17 00:00:00 2001
From: xiang <xiang@example.com>
Date: Tue, 29 Jul 2025 20:50:07 +0800
Subject: [PATCH] =?UTF-8?q?feat:=E9=99=90=E6=B5=81+=E9=87=8D=E8=AF=95+?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                       |  1 +
 xservice-http-starter/pom.xml                 | 30 ++++++++++
 .../xservice/http/config/HttpConfig.java      | 25 +++++++++
 .../http/helper/HttpRequestHelper.java        | 56 +++++++++++++++++++
 .../main/resources/META-INF/spring.factories  |  2 +
 5 files changed, 114 insertions(+)
 create mode 100644 xservice-http-starter/pom.xml
 create mode 100644 xservice-http-starter/src/main/java/com/xiang/xservice/http/config/HttpConfig.java
 create mode 100644 xservice-http-starter/src/main/java/com/xiang/xservice/http/helper/HttpRequestHelper.java
 create mode 100644 xservice-http-starter/src/main/resources/META-INF/spring.factories

diff --git a/pom.xml b/pom.xml
index a673ac4..1cffd89 100644
--- a/pom.xml
+++ b/pom.xml
@@ -14,6 +14,7 @@
         <module>xservice-third-part</module>
         <module>xservice-mysql-starter</module>
         <module>xservice-schedule-starter</module>
+        <module>xservice-http-starter</module>
     </modules>
 
     <properties>
diff --git a/xservice-http-starter/pom.xml b/xservice-http-starter/pom.xml
new file mode 100644
index 0000000..7fb0272
--- /dev/null
+++ b/xservice-http-starter/pom.xml
@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>com.xiang</groupId>
+        <artifactId>xservice-basic</artifactId>
+        <version>1.1-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>xservice-http-starter</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.github.rholder</groupId>
+            <artifactId>guava-retrying</artifactId>
+            <version>2.0.0</version>
+        </dependency>
+    </dependencies>
+
+
+</project>
\ No newline at end of file
diff --git a/xservice-http-starter/src/main/java/com/xiang/xservice/http/config/HttpConfig.java b/xservice-http-starter/src/main/java/com/xiang/xservice/http/config/HttpConfig.java
new file mode 100644
index 0000000..55e25b1
--- /dev/null
+++ b/xservice-http-starter/src/main/java/com/xiang/xservice/http/config/HttpConfig.java
@@ -0,0 +1,25 @@
+package com.xiang.xservice.http.config;
+
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@ConfigurationProperties(prefix = "http")
+public class HttpConfig {
+
+    /**
+     * 最大重试次数
+     */
+    private int maxAttempts;
+
+    /**
+     * 重试等待时间 ms
+     */
+    private long sleepMs;
+
+}
diff --git a/xservice-http-starter/src/main/java/com/xiang/xservice/http/helper/HttpRequestHelper.java b/xservice-http-starter/src/main/java/com/xiang/xservice/http/helper/HttpRequestHelper.java
new file mode 100644
index 0000000..7c701fd
--- /dev/null
+++ b/xservice-http-starter/src/main/java/com/xiang/xservice/http/helper/HttpRequestHelper.java
@@ -0,0 +1,56 @@
+package com.xiang.xservice.http.helper;
+
+import com.github.rholder.retry.Retryer;
+import com.github.rholder.retry.RetryerBuilder;
+import com.github.rholder.retry.StopStrategies;
+import com.github.rholder.retry.WaitStrategies;
+import com.xiang.xservice.http.config.HttpConfig;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.Objects;
+import java.util.concurrent.Callable;
+import java.util.concurrent.TimeUnit;
+import java.util.function.Supplier;
+
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class HttpRequestHelper {
+
+    private final HttpConfig httpConfig;
+
+    /**
+     * 封装带重试和延迟的请求调用
+     *
+     * @param supplier 实际请求的逻辑
+     * @param logTag   日志标识（便于排查）
+     * @param <T>      返回值类型
+     * @return 请求结果，如果失败则返回 null
+     */
+    public <T> T fetchWithRetry(Supplier<T> supplier, String logTag) {
+        Retryer<T> retryer = RetryerBuilder.<T>newBuilder()
+                .retryIfException()
+                .retryIfResult(Objects::isNull)
+                // 重试等待间隔
+                .withWaitStrategy(WaitStrategies.fixedWait(httpConfig.getSleepMs(), TimeUnit.MILLISECONDS))
+                // 最大重试次数
+                .withStopStrategy(StopStrategies.stopAfterAttempt(httpConfig.getMaxAttempts()))
+                .build();
+
+        Callable<T> callable = () -> {
+            T result = supplier.get();
+            // 每次请求后固定等待，用于限速
+            Thread.sleep(httpConfig.getSleepMs());
+            return result;
+        };
+        try {
+            return retryer.call(callable);
+        } catch (Exception e) {
+            log.warn("[{}] 请求失败，重试 {} 次后仍未成功，错误: {}", logTag, httpConfig.getMaxAttempts(), e.getMessage(), e);
+            return null;
+        }
+    }
+}
diff --git a/xservice-http-starter/src/main/resources/META-INF/spring.factories b/xservice-http-starter/src/main/resources/META-INF/spring.factories
new file mode 100644
index 0000000..3be09b5
--- /dev/null
+++ b/xservice-http-starter/src/main/resources/META-INF/spring.factories
@@ -0,0 +1,2 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+com.xiang.xservice.http.config.HttpConfig
\ No newline at end of file