如何批量上传文件至 AWS S3 并获取每个文件的公开访问 URL 路径与名称

import com.amazonaws.AmazonServiceException;

import com.amazonaws.SdkClientException;

import com.amazonaws.auth.profile.ProfileCredentialsProvider;

import com.amazonaws.services.s3.AmazonS3;

import com.amazonaws.services.s3.AmazonS3ClientBuilder;

import com.amazonaws.services.s3.model.URL;

import com.amazonaws.services.s3.transfer.*;

import com.amazonaws.services.s3.transfer.model.UploadResult;

import java.io.File;

import java.util.ArrayList;

import java.util.List;

import java.util.concurrent.CompletableFuture;

public class S3MultiFileUploader {

    public static class UploadInfo {

        public final String fileName;

        public final String objectKey;

        public final String s3Url;

        public UploadInfo(String fileName, String objectKey, String s3Url) {

            this.fileName = fileName;

            this.objectKey = objectKey;

            this.s3Url = s3Url;

        }

    }

    public static List<UploadInfo> uploadMultipleFiles(

            String region,

            String mediaBucket,

            List<File> files,

            String baseKeyPrefix) {

        AmazonS3 s3Client = AmazonS3ClientBuilder.standard()

                .withRegion(region)

                .withCredentials(new ProfileCredentialsProvider())

                .build();

        TransferManager tm = TransferManagerBuilder.standard()

                .withS3Client(s3Client)

                .build();

        List<CompletableFuture<UploadInfo>> futures = new ArrayList<>();

        for (int i = 0; i < files.size(); i++) {

            File file = files.get(i);

            // 推荐：为避免冲突，使用语义化 Key（如 prefix/filename-timestamp）

            String objectKey = String.format("%s/%s", baseKeyPrefix,

                System.currentTimeMillis() + "-" + file.getName());

            CompletableFuture<UploadInfo> future = CompletableFuture.supplyAsync(() -> {

                try {

                    Upload upload = tm.upload(mediaBucket, objectKey, file);

                    UploadResult result = upload.waitForUploadResult();

                    URL s3Url = s3Client.getUrl(result.getBucketName(), result.getKey());

                    return new UploadInfo(file.getName(), result.getKey(), s3Url.toString());

                } catch (Exception e) {

                    throw new RuntimeException("Failed to upload file: " + file.getName(), e);

                }

            });

            futures.add(future);

        }

        // 等待所有上传完成并聚合结果

        return futures.stream()

                .map(CompletableFuture::join)

                .toList();

    }

    // 使用示例

    public static void main(String[] args) {

        List<File> files = List.of(

            new File("/path/to/photo1.jpg"),

            new File("/path/to/document.pdf"),

            new File("/path/to/avatar.png")

        );

        List<UploadInfo> results = uploadMultipleFiles(

            "us-east-1",

            "my-media-bucket",

            files,

            "uploads/2024"

        );

        results.forEach(info ->

            System.out.printf("✅ %s → %s%n", info.fileName, info.s3Url)

        );

        // 记得关闭资源（生产环境务必调用）

        // tm.shutdownNow();

        // s3Client.shutdown();

    }

}