JMeter实现动态并行GraphQL请求的方法咨询

前置确认 #

确保你已通过JSR223后置处理器将获取到的账号列表存入JMeter变量，例如执行过类似代码：

// 假设accountList是你从首个GraphQL请求中解析出的账号集合
vars.putObject("accountList", accountList)

方案一：Parallel Controller + ForEach Controller（推荐，易维护） #

这是最直观的JMeter原生插件方案，无需手动处理线程：

1. 通过JMeter插件管理器安装Parallel Controller组件
2. 在首个GraphQL请求后，添加Parallel Controller，命名为「并行账号GraphQL调用」
3. 在Parallel Controller内部添加ForEach Controller：
   • 先在之前的JSR223后置处理器中补充代码，将列表拆分为单个变量：

     def accounts = vars.getObject("accountList")
     accounts.eachWithIndex { acc, idx -> vars.put("account_${idx}", acc) }
     

   • 配置ForEach Controller：
     • 输入变量前缀：account_
     • 输出变量名称：currentAccount
4. 在ForEach Controller内部添加HTTP请求（对应GraphQL调用）：
   • 填写GraphQL接口URL
   • 请求体中替换账号为${currentAccount}，示例请求体：

     {"query":"query { getUser(account: \"${currentAccount}\") { id name } }"}
     

5. 运行测试后，Parallel Controller会自动让所有账号对应的GraphQL请求并行执行

方案二：JSR223 Sampler动态生成并行请求（灵活可控） #

适合需要自定义请求逻辑、异常处理的场景，通过Groovy线程池实现：

1. 在首个GraphQL请求后添加JSR223 Sampler，执行以下代码：

// 获取账号列表
def accountList = vars.getObject("accountList")
if (!accountList || accountList.isEmpty()) {
    log.error("账号列表为空，终止并行请求生成")
    return
}

// 初始化线程池，大小与账号数量一致
def threadPool = java.util.concurrent.Executors.newFixedThreadPool(accountList.size())
def taskFutures = []

accountList.each { account ->
    taskFutures.add(threadPool.submit({
        try {
            // 构建请求参数
            def graphqlUrl = "你的GraphQL接口URL"
            def requestBody = """{"query":"query { getUser(account: \"${account}\") { id name } }"}"""
            
            // 发送POST请求
            def conn = new URL(graphqlUrl).openConnection()
            conn.setRequestMethod("POST")
            conn.setRequestProperty("Content-Type", "application/json")
            conn.setDoOutput(true)
            
            def outStream = new DataOutputStream(conn.getOutputStream())
            outStream.writeBytes(requestBody)
            outStream.flush()
            outStream.close()
            
            // 处理响应
            def respCode = conn.getResponseCode()
            def respContent = new BufferedReader(new InputStreamReader(conn.getInputStream())).text
            
            // 保存响应到变量，方便后续验证
            vars.put("resp_${account}", respContent)
            log.info("账号[${account}]请求完成，响应码：${respCode}")
        } catch (Exception e) {
            log.error("账号[${account}]请求失败：${e.message}")
        }
    }))
}

// 等待所有任务完成，关闭线程池
taskFutures.each { it.get() }
threadPool.shutdown()

2. 可根据需求修改请求头、查询语句、异常处理逻辑

注意事项 #

• 方案一中的Parallel Controller会自动管理并行线程数，无需手动配置
• 方案二中的线程池大小建议根据目标服务器性能调整，避免过度压测
• 可通过JMeter的「查看结果树」和「变量查看器」验证账号列表和请求结果

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