如何使用Java V2删除Amazon S3存储桶中带指定前缀的多对象

你的当前实现存在两个主要问题：一是逐个删除对象效率极低，二是while(true)的无限循环写法不够简洁易读，还容易因异常导致逻辑混乱。下面是两种更优的实现方式：

一、AWS SDK for Java 1.x 推荐实现（批量删除） #

利用S3的批量删除API（deleteObjects），每次最多批量删除1000个对象，结合分页查询大幅提升效率，同时优化循环逻辑：

String bucketName = "你的存储桶名称";
String prefix = "目标文件夹/"; // 注意末尾加斜杠，确保精准匹配前缀

ObjectListing objectListing = s3Client.listObjects(bucketName, prefix);

do {
    List<S3ObjectSummary> summaries = objectListing.getObjectSummaries();
    if (summaries.isEmpty()) {
        break;
    }

    // 构建批量删除请求
    DeleteObjectsRequest deleteRequest = new DeleteObjectsRequest(bucketName);
    List<DeleteObjectsRequest.KeyVersion> keysToDelete = new ArrayList<>();
    for (S3ObjectSummary summary : summaries) {
        keysToDelete.add(new DeleteObjectsRequest.KeyVersion(summary.getKey()));
    }
    deleteRequest.setKeys(keysToDelete);

    // 执行批量删除
    s3Client.deleteObjects(deleteRequest);

    // 处理分页
    if (objectListing.isTruncated()) {
        objectListing = s3Client.listNextBatchOfObjects(objectListing);
    } else {
        break;
    }
} while (true);

关键优化点： #

• 用do-while替代无限while(true)，逻辑更清晰
• 批量删除减少API调用次数，效率比逐个删除提升数十倍
• 增加空列表判断，避免不必要的无效请求

二、AWS SDK for Java 2.x 简洁实现（推荐使用新版本SDK） #

如果已经升级到SDK 2.x，官方提供了自动分页的工具类，代码结构更简洁：

String bucketName = "你的存储桶名称";
String prefix = "目标文件夹/";

// 初始化S3客户端（按需配置区域）
S3Client s3Client = S3Client.builder().region(Region.US_EAST_1).build();

// 构建分页查询请求
ListObjectsV2Request listRequest = ListObjectsV2Request.builder()
        .bucket(bucketName)
        .prefix(prefix)
        .build();

// 自动处理分页的查询结果
ListObjectsV2Iterable listResponse = s3Client.listObjectsV2Paginator(listRequest);

List<String> keysToDelete = new ArrayList<>();
for (ListObjectsV2Response page : listResponse) {
    for (S3Object object : page.contents()) {
        keysToDelete.add(object.key());
        // 达到批量删除上限（1000个）时执行删除
        if (keysToDelete.size() == 1000) {
            DeleteObjectsRequest deleteRequest = DeleteObjectsRequest.builder()
                    .bucket(bucketName)
                    .delete(Delete.builder().objects(keysToDelete.stream()
                            .map(key -> ObjectIdentifier.builder().key(key).build())
                            .collect(Collectors.toList()))
                            .build())
                    .build();
            s3Client.deleteObjects(deleteRequest);
            keysToDelete.clear();
        }
    }
}

// 删除剩余不足1000个的对象
if (!keysToDelete.isEmpty()) {
    DeleteObjectsRequest deleteRequest = DeleteObjectsRequest.builder()
            .bucket(bucketName)
            .delete(Delete.builder().objects(keysToDelete.stream()
                    .map(key -> ObjectIdentifier.builder().key(key).build())
                    .collect(Collectors.toList()))
                    .build())
            .build();
    s3Client.deleteObjects(deleteRequest);
}

额外建议： #

如果要删除的对象数量极大（百万级以上），直接用S3生命周期规则是更高效的方案——在控制台或通过API配置规则，让S3服务器自动删除指定前缀的对象，无需编写循环代码。

内容的提问来源于stack exchange，提问作者Inderjeet Chawla