caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: minio 无法删除磁盘文件问题处理

Browse Source
This commit is contained in:
Chopper711 2023-08-18 15:20:48 +08:00
parent a62db61221
commit 5af1238e02
1 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
framework/src/main/java/cn/lili/modules/file/plugin/impl/MinioFilePlugin.java
View File

@ -7,6 +7,7 @@ import cn.lili.modules.file.plugin.FilePlugin;
import cn.lili.modules.system.entity.dto.OssSetting;
import io.minio.*;
import io.minio.errors.ErrorResponseException;
import io.minio.messages.DeleteError;
import io.minio.messages.DeleteObject;
import lombok.extern.slf4j.Slf4j;
@ -96,8 +97,20 @@ public class MinioFilePlugin implements FilePlugin {
return;
}
MinioClient ossClient = getOssClient();
List<DeleteObject> objectList = key.stream().map(DeleteObject::new).collect(Collectors.toList());
ossClient.removeObjects(RemoveObjectsArgs.builder().objects(objectList).bucket(ossSetting.getM_bucketName()).build());
List<DeleteObject> objectList = key.stream().map(DeleteObject::new).collect(Collectors.toList()); Iterable<Result<DeleteError>> results =
ossClient.removeObjects(RemoveObjectsArgs.builder().objects(objectList).bucket(ossSetting.getM_bucketName()).build());
for (Result<DeleteError> result : results) {
DeleteError error = null;
try {
error = result.get();
log.error(
"Error in deleting object " + error.objectName() + "; " + error.message());
} catch (Exception e) {
log.error(
"Error in deleting object " + e.getMessage());
}
}
}