yescent/par
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: Qiniu 读取使用 SDK Client + Region ioHost 域名

Browse Source
This commit is contained in:
mediabot-pt
2026-06-30 17:29:35 +08:00
parent 2ac5084566
commit a3f13d689d
1 changed files with 18 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
par-core/src/main/java/com/par/core/storage/QiniuStorageService.java
View File

@@ -1,6 +1,8 @@
package com.par.core.storage;
import com.qiniu.common.QiniuException;
import com.qiniu.http.Client;
import com.qiniu.http.Response;
import com.qiniu.storage.BucketManager;
import com.qiniu.storage.Configuration;
import com.qiniu.storage.Region;
@@ -9,12 +11,6 @@ import com.qiniu.util.Auth;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.time.Duration;
/**
* 七牛云存储。
* 每次调用时从环境变量读取配置，支持热更新无需重启。
@@ -23,36 +19,34 @@ import java.time.Duration;
@Service
public class QiniuStorageService implements StorageService {
private final HttpClient httpClient = HttpClient.newBuilder()
.connectTimeout(Duration.ofSeconds(5))
.followRedirects(HttpClient.Redirect.NORMAL)
.build();
private UploadManager uploadManager;
private BucketManager bucketManager;
private Client qiniuClient;
private Auth auth;
private String bucket;
private String downloadDomain;
private String ioHost;
private synchronized void ensureInit() {
if (bucket != null) return;
String ak = env("QINIU_AK");
String sk = env("QINIU_SK");
String region = env("QINIU_REGION", "z2");
String regionStr = env("QINIU_REGION", "z2");
this.bucket = env("QINIU_BUCKET", "par-configs");
this.downloadDomain = env("QINIU_DOWNLOAD_DOMAIN", "http://" + bucket + ".qiniudn.com");
this.auth = Auth.create(ak, sk);
Configuration cfg = new Configuration(switch (region) {
Region region = switch (regionStr) {
case "z0" -> Region.region0();
case "z1" -> Region.region1();
case "z2" -> Region.region2();
case "na0" -> Region.regionNa0();
case "as0" -> Region.regionAs0();
default -> Region.autoRegion();
});
};
Configuration cfg = new Configuration(region);
this.ioHost = region.getIovipHost(ak);
this.uploadManager = new UploadManager(cfg);
this.bucketManager = new BucketManager(auth, cfg);
log.info("Qiniu 存储就绪: bucket={}", bucket);
this.qiniuClient = new Client(cfg);
log.info("Qiniu 存储就绪: bucket={}, ioHost={}", bucket, ioHost);
}
@Override
@@ -70,17 +64,15 @@ public class QiniuStorageService implements StorageService {
@Override
public String read(String path) {
ensureInit();
// 使用配置的下载域名生成私密下载链接
String baseUrl = downloadDomain.endsWith("/") ? downloadDomain + path : downloadDomain + "/" + path;
// 通过 SDK Client + 区域 ioHost 私密下载
String baseUrl = "http://" + ioHost + "/" + path;
String signedUrl = auth.privateDownloadUrl(baseUrl, 3600);
try {
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.warn("Qiniu 读取失败 {}: HTTP {} (domain={})", path, resp.statusCode(), downloadDomain);
} catch (Exception e) {
log.warn("Qiniu 读取失败 {}: {}", path, e.getMessage());
Response resp = qiniuClient.get(signedUrl);
if (resp.isOK()) return resp.bodyString();
log.warn("Qiniu 读取失败 {}: HTTP {}", path, resp.statusCode);
} catch (QiniuException e) {
log.warn("Qiniu 读取失败 {}: {}", path, e.response != null ? e.response.error : e.getMessage());
}
return null;
}