如何在Gatling中将URI中的{timestamp}替换为randomUUID().toString？

要把Feeder文件中URI里的{timestamp}替换为randomUUID().toString()，可以通过以下两种方式实现：

方式一：预处理Feeder记录（推荐） #

在过滤请求类型前，直接批量修改所有记录的URI字段，一次性替换占位符。修改后的完整代码如下：

val allRecommendationRequestRecords = jsonFile(scenarioAllRecommendationRequests).records

// 预处理所有记录，替换URI中的{timestamp}为随机UUID
val processedRecords = allRecommendationRequestRecords.map(record => {
  val originalUri = record("uri").toString
  val updatedUri = originalUri.replace("{timestamp}", java.util.UUID.randomUUID().toString)
  record + ("uri" -> updatedUri)
})

val allRecommendationPostRequest = processedRecords.filter(record => record("method").toString.toUpperCase == "POST")
val allRecommendationGetRequest = processedRecords.filter(record => record("method").toString.toUpperCase == "GET")

val totalPostRequestCount = allRecommendationPostRequest.length
val totalGetRequestCount = allRecommendationGetRequest.length

/**
 * Triggers
 */

val triggerForPostRequests = feed(allRecommendationPostRequest.circular)
  .exec(http(simulationTitle).post("${uri}").body(StringBody("${payload.jsonStringify()}".stripMargin)).check(status.is(200)))

val triggerForGetRequests = feed(allRecommendationGetRequest.circular)
  .exec(http(simulationTitle).get("${uri}").check(status.is(200)))

val scenarioForPostRequests = scenario(simulationTitle + " post requests").exec(triggerForPostRequests)
val scenarioForGetRequests = scenario(simulationTitle + " get requests").exec(triggerForGetRequests)
var httpProtocol = Recommendation.httpProtocol.shareConnections
/**
 * setup scenario using weight*
 */

方式二：请求前动态替换 #

如果需要在每个请求会话中实时生成UUID，可以在发送请求前通过会话处理逻辑替换占位符：

val triggerForPostRequests = feed(allRecommendationPostRequest.circular)
  .exec(session => {
    // 从会话中获取原始URI并替换占位符
    val originalUri = session("uri").as[String]
    val updatedUri = originalUri.replace("{timestamp}", java.util.UUID.randomUUID().toString)
    // 将更新后的URI存回会话
    session.set("uri", updatedUri)
  })
  .exec(http(simulationTitle).post("${uri}").body(StringBody("${payload.jsonStringify()}".stripMargin)).check(status.is(200)))

val triggerForGetRequests = feed(allRecommendationGetRequest.circular)
  .exec(session => {
    val originalUri = session("uri").as[String]
    val updatedUri = originalUri.replace("{timestamp}", java.util.UUID.randomUUID().toString)
    session.set("uri", updatedUri)
  })
  .exec(http(simulationTitle).get("${uri}").check(status.is(200)))

两种方式对比 #

• 方式一：提前完成所有URI的替换，避免请求阶段重复执行逻辑，性能更优。
• 方式二：每次请求都会生成新的UUID，适合需要每个请求使用不同UUID的场景。

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