如何在使用Taurus运行Gatling测试时为每个并发用户生成独立ID

数据老陈

2026-10-1

方案实现说明

你当前使用Feeder实现独立用户ID的思路是正确的，仅需要做少量优化即可保证效果：

1. 优化Feeder逻辑，避免ID重复

你现有的随机数生成逻辑有小概率出现ID重复，可替换为多线程安全的原子递增计数器，保证所有并发用户的ID绝对唯一：

import java.util.concurrent.atomic.AtomicInteger
import io.gatling.core.Predef._
import io.gatling.http.Predef._

// 全局原子计数器，并发场景下也能生成不重复的递增ID
val userIdCounter = new AtomicInteger(1)
val feeder = Iterator.continually(Map("userId" -> userIdCounter.getAndIncrement().toString))

val TestPlan: ChainBuilder = {
    feed(feeder)
      .exec(
          // 注意原代码漏了http请求定义前缀，补充后可正常运行
          http("测试接口请求")
          .put(baseURL)
          .header("UserId", "testuser_${userId}")
          .body(StringBody("Hello World!"))
          .check(status.is(200))
      )
}

额外说明：如果需要每个虚拟用户全程复用同一个ID（不管执行多少次请求迭代），可以把feed(feeder)操作移到scenario定义的最开头，每个用户初始化时仅取一次ID即可：

val TestPlanSimulation = scenario("TestPlanSimulation")
  .feed(feeder) // 每个用户仅取一次ID，后续所有请求都复用该值
  .exec(TestPlan)

2. 验证ID配置生效

可在请求前增加会话日志打印，测试阶段确认ID生成符合预期，正式压测时注释即可避免性能损耗：

val TestPlan: ChainBuilder = {
    feed(feeder)
      .exec { session =>
        println(s"生成的用户ID为：${session("userId").as[String]}")
        session
      }
      .exec(
          http("测试接口请求")
          .put(baseURL)
          .header("UserId", "testuser_${userId}")
          .body(StringBody("Hello World!"))
          .check(status.is(200))
      )
}