更新这个货源

2026-05-22 09:41:31 +08:00
parent 73d25fcbcb
commit 70e902e7ea
22 changed files with 1136 additions and 52 deletions
@@ -69,14 +69,24 @@ public class RustfsObjectStorageService {
        if (!isConfigured()) {
            throw new IllegalStateException("transient storage is not configured");
        }
-        try (var stream = buildClient().getObject(GetObjectArgs.builder()
-                .bucket(properties.getBucket())
-                .object(objectKey)
-                .build())) {
-            return new String(stream.readAllBytes(), StandardCharsets.UTF_8);
-        } catch (Exception ex) {
-            throw new IllegalStateException("failed to read payload from transient storage", ex);
+        Exception last = null;
+        int maxRetries = Math.max(1, properties.getReadMaxRetries());
+        for (int attempt = 1; attempt <= maxRetries; attempt++) {
+            try (var stream = buildClient().getObject(GetObjectArgs.builder()
+                    .bucket(properties.getBucket())
+                    .object(objectKey)
+                    .build())) {
+                return new String(stream.readAllBytes(), StandardCharsets.UTF_8);
+            } catch (Exception ex) {
+                last = ex;
+                if (attempt < maxRetries) {
+                    // 与 uploadText 对齐的线性退避，避免 rustfs 短暂抖动直接打成 read coze batch failed。
+                    log.warn("[rustfs] read failed, retrying objectKey={} attempt={}/{} err={}", objectKey, attempt, maxRetries, ex.getMessage());
+                    sleepQuietly(500L * attempt);
+                }
+            }
        }
+        throw new IllegalStateException("failed to read payload from transient storage", last);
    }

    public void deleteObject(String objectKey) {