如何通过JMeter使用Azure SDK for Java上传文件至Azure Blob Storage

前提准备 #

• 安装好JMeter（建议使用最新稳定版）
• 拥有Azure存储账户，获取存储账户名称、账户密钥（或SAS令牌）、目标容器名称
• 下载Azure Blob Storage SDK for Java的相关依赖包（azure-storage-blob及配套依赖）

步骤1：编写上传逻辑的Java类 #

创建实现JMeter JavaSamplerClient接口的类，在runTest方法中实现Azure Blob上传逻辑：

import org.apache.jmeter.protocol.java.sampler.JavaSamplerClient;
import org.apache.jmeter.protocol.java.sampler.JavaSamplerContext;
import org.apache.jmeter.samplers.SampleResult;
import org.apache.jmeter.config.Arguments;
import com.azure.storage.blob.BlobClient;
import com.azure.storage.blob.BlobContainerClient;
import com.azure.storage.blob.BlobServiceClient;
import com.azure.storage.blob.BlobServiceClientBuilder;
import java.io.File;

public class AzureBlobUploader implements JavaSamplerClient {

    @Override
    public SampleResult runTest(JavaSamplerContext context) {
        SampleResult result = new SampleResult();
        result.sampleStart();

        // 从JMeter参数读取配置
        String storageAccountName = context.getParameter("storageAccountName");
        String accountKey = context.getParameter("accountKey");
        String containerName = context.getParameter("containerName");
        String localFilePath = context.getParameter("localFilePath");
        String blobName = context.getParameter("blobName");

        try {
            // 初始化Blob服务客户端
            BlobServiceClient blobServiceClient = new BlobServiceClientBuilder()
                    .connectionString(String.format("DefaultEndpointsProtocol=https;AccountName=%s;AccountKey=%s;EndpointSuffix=core.windows.net", storageAccountName, accountKey))
                    .buildClient();

            // 获取容器与Blob客户端
            BlobContainerClient containerClient = blobServiceClient.getBlobContainerClient(containerName);
            BlobClient blobClient = containerClient.getBlobClient(blobName);

            // 上传本地文件
            blobClient.uploadFromFile(localFilePath);

            result.setSuccessful(true);
            result.setResponseMessage("文件上传成功：" + blobName);
        } catch (Exception e) {
            result.setSuccessful(false);
            result.setResponseMessage("上传失败：" + e.getMessage());
            result.setResponseCode("500");
        } finally {
            result.sampleEnd();
        }

        return result;
    }

    @Override
    public void setupTest(JavaSamplerContext context) {}

    @Override
    public void teardownTest(JavaSamplerContext context) {}

    @Override
    public Arguments getDefaultParameters() {
        Arguments args = new Arguments();
        args.addArgument("storageAccountName", "你的存储账户名称");
        args.addArgument("accountKey", "你的账户密钥");
        args.addArgument("containerName", "目标容器名称");
        args.addArgument("localFilePath", "本地文件路径，如C:/test/upload.txt");
        args.addArgument("blobName", "Blob名称，如uploaded-file.txt");
        return args;
    }
}

步骤2：打包代码与依赖 #

• 编译上述Java类，将编译后的class文件连同Azure Blob SDK的所有依赖jar包，放入JMeter安装目录下的lib/ext文件夹
• 注意确保依赖包版本兼容，避免出现类冲突

步骤3：配置JMeter测试计划 #

1. 打开JMeter，新建测试计划
2. 添加线程组（按需配置线程数、循环次数）
3. 在线程组下添加Java请求采样器：
   • 在类名称下拉框选择你编写的AzureBlobUploader类
   • 填写参数：存储账户名称、账户密钥、容器名称、本地文件路径、Blob名称
4. 添加查看结果树、汇总报告等监听器，用于查看上传结果

步骤4：运行测试 #

点击JMeter运行按钮执行测试，通过查看结果树验证文件是否成功上传至Azure Blob Storage。

注意事项 #

• 确保JMeter运行环境的Java版本符合Azure SDK要求（建议Java 8及以上）
• 若使用SAS令牌替代账户密钥，修改BlobServiceClientBuilder配置，使用sasToken方法传入令牌
• 大文件上传可通过配置分块参数优化性能（uploadFromFile方法支持自动分块，也可手动指定分块大小）

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