From 682b19cb3516c40f9a65b3f2336c06ef381e7b29 Mon Sep 17 00:00:00 2001 From: mediabot-pt <295750538+mediabot-pt@users.noreply.github.com> Date: Tue, 30 Jun 2026 16:59:09 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E7=A7=81=E6=9C=89=E7=A9=BA=E9=97=B4?= =?UTF-8?q?=E7=9B=B4=E6=8E=A5=E7=94=A8=E8=AE=A4=E8=AF=81=E6=BA=90=E7=AB=99?= =?UTF-8?q?=E4=B8=8B=E8=BD=BD=EF=BC=8C=E4=B8=8D=E8=B5=B0=20CDN?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../par/core/storage/QiniuStorageService.java | 20 +++++-------------- 1 file changed, 5 insertions(+), 15 deletions(-) diff --git a/par-core/src/main/java/com/par/core/storage/QiniuStorageService.java b/par-core/src/main/java/com/par/core/storage/QiniuStorageService.java index 084a0f5..0d13354 100644 --- a/par-core/src/main/java/com/par/core/storage/QiniuStorageService.java +++ b/par-core/src/main/java/com/par/core/storage/QiniuStorageService.java @@ -70,27 +70,17 @@ public class QiniuStorageService implements StorageService { @Override public String read(String path) { ensureInit(); - // 先走 CDN，404 则回退源站直读 - String content = readFromUrl(cdnDomain + "/" + path, path); - if (content != null) return content; - // CDN 缓存未命中，走 Qiniu 源站 + // 私有空间走认证源站下载 String sourceUrl = "https://" + bucket + ".qiniucdn.com/" + path; - String privateUrl = auth.privateDownloadUrl(sourceUrl, 3600); - content = readFromUrl(privateUrl, path); - if (content != null) return content; - log.warn("Qiniu 读取失败 {}: CDN+源站均不可用", path); - return null; - } - - private String readFromUrl(String url, String path) { + String signedUrl = auth.privateDownloadUrl(sourceUrl, 3600); try { - var req = HttpRequest.newBuilder().uri(URI.create(url)) + var req = HttpRequest.newBuilder().uri(URI.create(signedUrl)) .timeout(Duration.ofSeconds(10)).GET().build(); var resp = httpClient.send(req, HttpResponse.BodyHandlers.ofString()); if (resp.statusCode() == 200) return resp.body(); - log.debug("Qiniu CDN miss {}: HTTP {}", path, resp.statusCode()); + log.warn("Qiniu 读取失败 {}: HTTP {}", path, resp.statusCode()); } catch (Exception e) { - log.debug("Qiniu 读取异常 {}: {}", path, e.getMessage()); + log.warn("Qiniu 读取失败 {}: {}", path, e.getMessage()); } return null; }