使用Java如何获取S3存储桶中指定文件的上一个版本ID

以下基于AWS SDK for Java 2.x实现，默认你已经为目标S3存储桶开启了版本控制功能。

1. 引入Maven依赖 #

<dependency>
    <groupId>software.amazon.awssdk</groupId>
    <artifactId>s3</artifactId>
    <version>2.20.0</version> <!-- 可替换为最新稳定版本 -->
</dependency>

2. 初始化S3客户端 #

import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.s3.S3Client;

// 初始化客户端，默认从环境变量、IAM角色等位置读取凭证
S3Client s3Client = S3Client.builder()
        .region(Region.of("你的桶所属区域，例如cn-north-1"))
        .credentialsProvider(DefaultCredentialsProvider.create())
        .build();

3. 查询紧邻最新版本的上一历史版本ID #

S3的listObjectVersions接口默认返回的版本列表按最后修改时间倒序排列，第一个元素为当前最新版本，第二个元素即为所需的紧邻历史版本：

import software.amazon.awssdk.services.s3.model.ListObjectVersionsRequest;
import software.amazon.awssdk.services.s3.model.ListObjectVersionsResponse;
import software.amazon.awssdk.services.s3.model.ObjectVersion;

String bucketName = "你的S3桶名称";
String targetFileName = "你的目标文件名称（即S3对象键）";

// 构造查询版本列表的请求
ListObjectVersionsRequest versionsRequest = ListObjectVersionsRequest.builder()
        .bucket(bucketName)
        .prefix(targetFileName)
        .build();

ListObjectVersionsResponse versionsResponse = s3Client.listObjectVersions(versionsRequest);
List<ObjectVersion> versionList = versionsResponse.versions();

String previousVersionId = null;
// 校验版本数量，至少有2个版本才存在上一历史版本
if (versionList.size() >= 2) {
    // 索引0为最新版本，索引1为紧邻的上一历史版本
    previousVersionId = versionList.get(1).versionId();
} else {
    throw new RuntimeException("目标文件没有历史版本");
}

4. 读取指定版本ID的文件内容 #

import software.amazon.awssdk.services.s3.model.GetObjectRequest;
import software.amazon.awssdk.core.ResponseBytes;
import software.amazon.awssdk.services.s3.model.GetObjectResponse;

GetObjectRequest getObjectRequest = GetObjectRequest.builder()
        .bucket(bucketName)
        .key(targetFileName)
        .versionId(previousVersionId) // 指定要读取的版本ID
        .build();

// 读取文件内容为字节数组，也可根据需求转换为输入流、本地文件等
ResponseBytes<GetObjectResponse> responseBytes = s3Client.getObjectAsBytes(getObjectRequest);
byte[] fileContent = responseBytes.asByteArray();

// 业务逻辑处理文件内容

注意事项 #

• 必须提前为目标S3存储桶开启版本控制，否则无法查询到历史版本
• 执行代码的IAM身份需要配置s3:ListBucketVersions（查询版本列表）、s3:GetObjectVersion（读取指定版本文件）的权限
• 如果文件存在删除标记，可根据业务需求判断是否需要跳过标记为删除的版本，调整版本列表的取值逻辑即可

内容的提问来源于stack exchange，提问作者kevin wang