1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
|
@Service
public class AutoLinkService {
@Autowired
private OSS ossClient;
@Autowired
private OSSProperties ossProperties;
@Autowired
private FileMetadataService fileMetadataService;
public String generatePresignedUrl(String objectKey, int expiration) {
try {
Date expirationDate = new Date(System.currentTimeMillis() + expiration * 3600 * 1000);
GeneratePresignedUrlRequest request = new GeneratePresignedUrlRequest(
ossProperties.getBucketName(),
objectKey,
HttpMethod.GET
);
request.setExpiration(expirationDate);
URL presignedUrl = ossClient.generatePresignedUrl(request);
log.info("生成预签名URL成功: objectKey={}, expiration={}h", objectKey, expiration);
return presignedUrl.toString();
} catch (Exception e) {
log.error("生成预签名URL失败: objectKey={}", objectKey, e);
throw new RuntimeException("生成预签名URL失败", e);
}
}
public String generateCDNLink(String objectKey) {
try {
if (!StringUtils.hasText(ossProperties.getCdnDomain())) {
return generateDirectLink(objectKey);
}
String cdnUrl = ossProperties.getCdnDomain() + "/" + objectKey;
log.info("生成CDN链接成功: objectKey={}, cdnUrl={}", objectKey, cdnUrl);
return cdnUrl;
} catch (Exception e) {
log.error("生成CDN链接失败: objectKey={}", objectKey, e);
throw new RuntimeException("生成CDN链接失败", e);
}
}
public String generateDirectLink(String objectKey) {
try {
String directUrl = "https://" + ossProperties.getBucketName() + "." +
ossProperties.getEndpoint().replace("https://", "") + "/" + objectKey;
log.info("生成直链成功: objectKey={}, directUrl={}", objectKey, directUrl);
return directUrl;
} catch (Exception e) {
log.error("生成直链失败: objectKey={}", objectKey, e);
throw new RuntimeException("生成直链失败", e);
}
}
public Map<String, String> generateBatchLinks(List<String> objectKeys, String linkType) {
Map<String, String> linkMap = new HashMap<>();
for (String objectKey : objectKeys) {
try {
String link = generateLinkByType(objectKey, linkType);
linkMap.put(objectKey, link);
} catch (Exception e) {
log.error("生成链接失败: objectKey={}, linkType={}", objectKey, linkType, e);
}
}
return linkMap;
}
private String generateLinkByType(String objectKey, String linkType) {
switch (linkType) {
case "CDN":
return generateCDNLink(objectKey);
case "DIRECT":
return generateDirectLink(objectKey);
case "PRESIGNED":
return generatePresignedUrl(objectKey, 24);
default:
return generateCDNLink(objectKey);
}
}
public boolean updateFileLink(Long fileId, String linkType) {
try {
FileMetadata fileMetadata = fileMetadataService.getFileMetadata(fileId);
if (fileMetadata == null) {
log.warn("文件不存在: fileId={}", fileId);
return false;
}
String newLink = generateLinkByType(fileMetadata.getObjectKey(), linkType);
fileMetadata.setCdnUrl(newLink);
fileMetadataService.updateFileMetadata(fileMetadata);
log.info("更新文件链接成功: fileId={}, linkType={}", fileId, linkType);
return true;
} catch (Exception e) {
log.error("更新文件链接失败: fileId={}, linkType={}", fileId, linkType, e);
return false;
}
}
}
|
微信
