如何基于azure-storage-blob 12.5.0批量上传多字节数组至Azure Storage？

当然可以！用你当前的azure-storage-blob 12.5.0版本完全能实现字节数组集合的批量上传。结合你已有的单Blob上传代码，我整理了两种实用的实现方案：

方案1：串行循环上传（简单直接，适合小文件集合） #

这种方式复用你现有的store方法逻辑，遍历字节数组集合逐个上传，实现成本极低：

首先，你可以封装一个批量上传方法，同时定义一个简单的实体类来承载每个Blob的上传信息：

// 封装单个Blob的上传请求信息
static class BlobUploadTask {
    private final String blobPath;
    private final String originalFileName;
    private final byte[] bytes;

    public BlobUploadTask(String blobPath, String originalFileName, byte[] bytes) {
        this.blobPath = blobPath;
        this.originalFileName = originalFileName;
        this.bytes = bytes;
    }

    // Getter方法
    public String getBlobPath() { return blobPath; }
    public String getOriginalFileName() { return originalFileName; }
    public byte[] getBytes() { return bytes; }
}

// 批量上传方法
public void batchStoreBlobs(List<BlobUploadTask> uploadTasks) {
    for (BlobUploadTask task : uploadTasks) {
        try {
            // 直接调用你已实现的单Blob上传方法
            store(task.getBlobPath(), task.getOriginalFileName(), task.getBytes());
            System.out.printf("Successfully uploaded blob: %s%n", task.getBlobPath());
        } catch (StorageException exc) {
            // 单个上传失败时的处理：记录日志、标记失败任务等
            System.err.printf("Failed to upload blob %s: %s%n", task.getBlobPath(), exc.getMessage());
        }
    }
}

方案特点： #

• 优点：逻辑简单，完全复用现有代码，无需学习新API，调试和维护成本低；
• 缺点：串行执行，当集合数量大或字节数组体积大时，上传速度较慢。

方案2：并行上传（高效适合大集合） #

如果你的字节数组集合数量较多，可以用Java的线程池实现并行上传，充分利用网络带宽提升效率：

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public void parallelBatchStoreBlobs(List<BlobUploadTask> uploadTasks) {
    // 根据你的服务器性能和Azure的并发限制设置线程数，建议10-20个
    int threadPoolSize = 15;
    ExecutorService executor = Executors.newFixedThreadPool(threadPoolSize);
    List<CompletableFuture<Void>> uploadFutures = new ArrayList<>();

    for (BlobUploadTask task : uploadTasks) {
        // 将每个上传任务提交到线程池异步执行
        CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
            try {
                store(task.getBlobPath(), task.getOriginalFileName(), task.getBytes());
                System.out.printf("Parallel upload success: %s%n", task.getBlobPath());
            } catch (StorageException exc) {
                System.err.printf("Parallel upload failed for %s: %s%n", task.getBlobPath(), exc.getMessage());
            }
        }, executor);
        uploadFutures.add(future);
    }

    // 等待所有上传任务完成
    CompletableFuture.allOf(uploadFutures.toArray(new CompletableFuture[0])).join();
    // 关闭线程池
    executor.shutdown();
}

注意事项： #

• 线程数不要设置过大，避免触发Azure的请求频率限制；
• 每个Blob的blobPath必须唯一，否则会覆盖已存在的Blob；
• 如果字节数组体积超过100MB，建议改用分块上传API（stageBlock + commitBlockList），避免内存占用过高；
• 可以添加重试逻辑（比如自定义重试次数），应对临时的网络波动或服务端限流。

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