extends AbstractBaseFileService
{
-
+
protected AmazonS3 s3Client;
-
+
public static final InputStream EMPTY_INPUT_STREAM = new ByteArrayInputStream(new byte[0]);
-
+
@Resource
private SystemConfigService systemConfigService;
-
+
@Override
public List extends A
public String getDownloadUrl(String pathAndName) {
String bucketName = param.getBucketName();
String domain = param.getDomain();
-
+
String fullPath = StringUtils.concatTrimStartSlashes(param.getBasePath() + pathAndName);
-
+
// 如果不是私有空间, 且指定了加速域名, 则直接返回下载地址.
if (BooleanUtil.isFalse(param.isPrivate()) && StrUtil.isNotEmpty(domain)) {
return StringUtils.concat(domain, StringUtils.encodeAllIgnoreSlashes(fullPath));
}
-
+
Integer tokenTime = param.getTokenTime();
if (param.getTokenTime() == null || param.getTokenTime() < 1) {
tokenTime = 1800;
}
-
+
Date expirationDate = new Date(System.currentTimeMillis() + tokenTime * 1000);
-
+
GeneratePresignedUrlRequest generatePresignedUrlRequest = new GeneratePresignedUrlRequest(bucketName, fullPath, HttpMethod.GET);
generatePresignedUrlRequest.setExpiration(expirationDate);
URL url = s3Client.generatePresignedUrl(generatePresignedUrlRequest);
-
+
String defaultUrl = url.toExternalForm();
if (StrUtil.isNotEmpty(domain)) {
defaultUrl = StringUtils.concat(domain, url.getFile());
}
return defaultUrl;
}
-
-
+
+
/**
* 获取 S3 指定目录下的对象列表
* @param path 路径
@@ -97,23 +84,23 @@ public abstract class AbstractS3BaseFileService extends A
String bucketName = param.getBucketName();
path = StringUtils.trimStartSlashes(path);
String fullPath = StringUtils.trimStartSlashes(StringUtils.concat(param.getBasePath(), path, ZFileConstant.PATH_SEPARATOR));
-
+
List extends A
fileItemResult.setTime(s.getLastModified());
fileItemResult.setType(FileTypeEnum.FILE);
fileItemResult.setPath(path);
-
+
String fullPathAndName = StringUtils.concat(path, fileItemResult.getName());
fileItemResult.setUrl(getDownloadUrl(fullPathAndName));
-
+
fileItemList.add(fileItemResult);
}
-
+
for (String commonPrefix : objectListing.getCommonPrefixes()) {
FileItemResult fileItemResult = new FileItemResult();
fileItemResult.setName(commonPrefix.substring(fullPath.length(), commonPrefix.length() - 1));
@@ -138,25 +125,25 @@ public abstract class AbstractS3BaseFileService extends A
if (StrUtil.isEmpty(name) || StrUtil.equals(name, StringUtils.DELIMITER_STR)) {
continue;
}
-
+
fileItemResult.setType(FileTypeEnum.FOLDER);
fileItemResult.setPath(path);
fileItemList.add(fileItemResult);
}
isFirstWhile = false;
} while (objectListing.isTruncated());
-
+
return fileItemList;
}
-
+
@Override
public FileItemResult getFileItem(String pathAndName) {
String fileName = FileUtil.getName(pathAndName);
String parentPath = StringUtils.getParentPath(pathAndName);
-
+
String trimStartPath = StringUtils.concatTrimStartSlashes(param.getBasePath(), pathAndName);
ObjectMetadata objectMetadata = s3Client.getObjectMetadata(param.getBucketName(), trimStartPath);
-
+
FileItemResult fileItemResult = new FileItemResult();
fileItemResult.setName(fileName);
fileItemResult.setSize(objectMetadata.getInstanceLength());
@@ -166,7 +153,7 @@ public abstract class AbstractS3BaseFileService extends A
fileItemResult.setUrl(getDownloadUrl(pathAndName));
return fileItemResult;
}
-
+
@Override
public boolean newFolder(String path, String name) {
name = StringUtils.trimSlashes(name);
@@ -176,7 +163,7 @@ public abstract class AbstractS3BaseFileService extends A
PutObjectResult putObjectResult = s3Client.putObject(putObjectRequest);
return putObjectResult != null;
}
-
+
@Override
public boolean deleteFile(String path, String name) {
String fullPath = StringUtils.concat(param.getBasePath(), path, name);
@@ -184,7 +171,7 @@ public abstract class AbstractS3BaseFileService extends A
s3Client.deleteObject(param.getBucketName(), fullPath);
return true;
}
-
+
@Override
public boolean deleteFolder(String path, String name) {
String fullPath = StringUtils.concat(param.getBasePath(), path, name);
@@ -192,36 +179,36 @@ public abstract class AbstractS3BaseFileService extends A
s3Client.deleteObject(param.getBucketName(), fullPath + '/');
return true;
}
-
+
@Override
public boolean renameFile(String path, String name, String newName) {
String srcPath = StringUtils.concatTrimStartSlashes(param.getBasePath(), path, name);
String distPath = StringUtils.concatTrimStartSlashes(param.getBasePath(), path, newName);
-
+
String bucketName = param.getBucketName();
s3Client.copyObject(bucketName, srcPath, bucketName, distPath);
deleteFile(path, name);
return true;
}
-
+
@Override
public boolean renameFolder(String path, String name, String newName) {
throw new UnsupportedOperationException("该存储类型不支持此操作");
}
-
+
@Override
public String getUploadUrl(String path, String name, Long size) {
String bucketName = param.getBucketName();
String uploadToPath = StringUtils.concat(param.getBasePath(), path, name);
uploadToPath = StringUtils.trimStartSlashes(uploadToPath);
-
+
GeneratePresignedUrlRequest req =
new GeneratePresignedUrlRequest(bucketName, uploadToPath, HttpMethod.PUT);
URL url = s3Client.generatePresignedUrl(req);
-
+
return url.toExternalForm();
}
-
+
protected void setUploadCors() {
if (param.isAutoConfigCors()) {
try {
@@ -234,35 +221,46 @@ public abstract class AbstractS3BaseFileService extends A
if (corsRules == null) {
corsRules = new ArrayList<>();
}
-
-
+
+
// 当前要添加的规则
- List