Gatling用户行为建模：使用Scenario定义真实用户操作流程
一、Scenario基础概念
Scenario定义
Scenario是Gatling中的概念，用于模拟真实用户在系统中的完整操作流程。每个Scenario代表一类用户的行为模式。
scala
import io.gatling.core.Predef._
import io.gatling.http.Predef._
import scala.concurrent.duration._
class RealUserSimulation extends Simulation {
// HTTP配置
val httpProtocol = http
.baseUrl("https://api.example.com")
.acceptHeader("application/json")
.userAgentHeader("Gatling/3.9")
.disableCaching
// 定义用户操作流程
val userJourney = scenario("真实用户操作流")
.exec(http("首页访问")
.get("/home")
.check(status.is(200))
.check(jsonPath("$.userId").saveAs("userId")))
.pause(2, 5) // 随机思考时间2-5秒
.exec(http("登录操作")
.post("/login")
.formParam("username", "test_user")
.formParam("password", "password123")
.check(status.is(200))
.check(jsonPath("$.authToken").saveAs("authToken")))
.pause(1, 3)
}
二、复杂用户行为建模
多步骤业务流程
scala
val ecommerceUser = scenario("电商购物用户")
.exec(
// 第一阶段：浏览阶段
group("浏览阶段") {
exec(http("访问首页")
.get("/")
.check(status.is(200)))
.pause(3, 7)
.exec(http("浏览商品列表")
.get("/products?category=electronics")
.check(status.is(200))
.check(css(".product-item", "data-id").findAll.saveAs("productIds")))
.pause(2, 4)
.exec(http("查看商品详情")
.get("/products/${productIds.random()}")
.check(status.is(200)))
.pause(5, 10) // 仔细阅读商品详情
}
)
.exec(
// 第二阶段：购买阶段
group("购买阶段") {
exec(http("添加购物车")
.post("/cart/add")
.header("Authorization", "Bearer ${authToken}")
.body(StringBody("""{"productId": "${productId}", "quantity": 1}"""))
.asJson
.check(status.is(201)))
.pause(1, 2)
.exec(http("查看购物车")
.get("/cart")
.header("Authorization", "Bearer ${authToken}")
.check(status.is(200))
.check(jsonPath("$.totalPrice").saveAs("cartTotal")))
.pause(2, 3)
.exec(http("结算")
.post("/checkout")
.header("Authorization", "Bearer ${authToken}")
.body(StringBody("""{"paymentMethod": "credit_card"}"""))
.asJson
.check(status.is(200))
.check(jsonPath("$.orderId").saveAs("orderId")))
}
)
条件分支逻辑
scala
val conditionalUser = scenario("条件流程用户")
.exec(http("访问网站")
.get("/")
.check(status.is(200)))
.pause(2)
// 条件分支：检查用户是否登录
.doIf(session => !session("userId").asOption[String].isDefined) {
exec(http("新用户注册")
.post("/register")
.formParam("email", "user_${userId}@test.com")
.formParam("password", "Test123!")
.check(status.is(201))
.check(jsonPath("$.userId").saveAs("userId")))
.pause(1)
}
// 根据用户类型执行不同操作
.doIfEquals("${userType}", "premium") {
exec(http("访问VIP专区")
.get("/vip/content")
.check(status.is(200)))
.pause(5, 10)
}
.doIfEquals("${userType}", "regular") {
exec(http("浏览普通内容")
.get("/regular/content")
.check(status.is(200)))
.pause(2, 5)
}
// 循环浏览多个页面
.repeat(5, "pageNum") {
exec(http("浏览第${pageNum}页")
.get("/content?page=${pageNum}")
.check(status.is(200)))
.pause(1, 2)
}
三、高级用户行为模式
数据驱动测试
scala
// 使用Feeder提供测试数据
val userFeeder = csv("data/users.csv").circular
val productFeeder = jsonFile("data/products.json").random
val dataDrivenUser = scenario("数据驱动用户")
.feed(userFeeder)
.feed(productFeeder)
.exec(http("使用动态数据登录")
.post("/login")
.formParam("username", "${username}")
.formParam("password", "${password}")
.check(status.is(200))
.check(jsonPath("$.sessionId").saveAs("sessionId")))
.pause(2)
.exec(http("查看个性化推荐")
.get("/recommendations?userId=${userId}")
.header("Session-Id", "${sessionId}")
.check(status.is(200))
.check(jsonPath("$.recommendations[*].productId").findAll.saveAs("recommendedProducts")))
.pause(3)
.foreach("${recommendedProducts}", "product") {
exec(http("查看推荐产品${product}")
.get("/products/${product}")
.check(status.is(200)))
.pause(1)
}
复杂业务流程
scala
val businessWorkflowUser = scenario("复杂业务流程用户")
.tryMax(3) { // 重试机制
exec(
group("文档处理流程") {
exec(http("上传文档")
.post("/documents/upload")
.header("Authorization", "Bearer ${token}")
.bodyPart(RawFileBodyPart("file", "test.pdf"))
.check(status.is(202))
.check(jsonPath("$.documentId").saveAs("docId")))
.pause(1)
.asLongAs(session =>
session("processingStatus").asOption[String].exists(_ != "COMPLETED"),
"processingStep"
) {
exec(http("检查处理状态")
.get("/documents/${docId}/status")
.check(status.is(200))
.check(jsonPath("$.status").saveAs("processingStatus")))
.pause(2)
}
.exec(http("下载处理结果")
.get("/documents/${docId}/download")
.check(status.is(200)))
.pause(3)
}
)
}.exitHereIfFailed // 如果失败则退出场景
四、真实用户模拟配置
多用户类型混合
scala
// 定义不同用户类型的场景
val casualUser = scenario("轻度用户")
.exec(commonActions.randomPageVisits(1, 3))
.pause(30, 60)
val powerUser = scenario("重度用户")
.exec(commonActions.deepEngagementFlow)
.pause(10, 20)
.exec(commonActions.complexOperations)
.pause(5, 15)
val adminUser = scenario("管理员用户")
.exec(adminActions.dashboardAccess)
.pause(2, 5)
.exec(adminActions.userManagement)
.pause(1, 3)
.exec(adminActions.systemMonitoring)
.pause(5, 10)
// 混合用户注入策略
setUp(
casualUser.inject(
rampUsers(100).during(2.minutes), // 前2分钟逐步增加100个轻度用户
constantUsersPerSec(2).during(5.minutes) // 然后保持每秒2个用户
),
powerUser.inject(
rampUsers(20).during(1.minute), // 逐步增加20个重度用户
constantUsersPerSec(0.5).during(10.minutes)
),
adminUser.inject(
constantUsersPerSec(0.1).during(15.minutes) // 持续有管理员操作
)
).protocols(httpProtocol)
.maxDuration(15.minutes)
.assertions(
global.responseTime.max.lt(2000),
global.successfulRequests.percent.gt(95)
)
用户思考时间和行为随机化
scala
val realisticUser = scenario("带思考时间的真实用户")
.exec(api.login)
// 正态分布思考时间
.pause(normalPauses(5.seconds, 2.seconds))
.exec(api.browseProducts)
// 均匀分布思考时间
.pause(uniformPauses(3.seconds, 7.seconds))
.randomSwitch(
70.0 -> exec(api.addToCart), // 70%概率添加购物车
20.0 -> exec(api.saveForLater), // 20%概率收藏
10.0 -> exec(api.continueBrowsing) // 10%概率继续浏览
)
.pause(2, 5)
.randomSwitch(
60.0 -> exec(api.checkout), // 60%概率结账
40.0 -> exec(api.abandonCart) // 40%概率放弃购物车
)
// 使用会话变量控制流程
.doIf(session => session("cartValue").as[Double] > 100) {
exec(api.applyCoupon) // 购物车价值大于100时使用优惠券
.pause(1)
}
.uniformRandomSwitch(
exec(api.standardShipping), // 随机选择配送方式
exec(api.expressShipping),
exec(api.pickupInStore)
)
五、性能测试
模块化设计
scala
object UserActions {
val browseProducts = exec(
group("产品浏览") {
exec(http("获取产品列表")
.get("/api/products")
.queryParam("page", "${currentPage}")
.check(status.is(200))
.check(jsonPath("$[*].id").findAll.saveAs("productIds")))
.pause(1)
.foreach("${productIds}", "productId") {
exec(http("查看产品详情")
.get("/api/products/${productId}")
.check(status.is(200)))
.pause(0.5, 1.5)
}
}
)
val searchProducts = exec(
group("产品搜索") {
feed(searchKeywordsFeeder)
.exec(http("搜索产品")
.get("/api/search")
.queryParam("q", "${keyword}")
.queryParam("sort", "${sortBy}")
.check(status.is(200)))
.pause(2, 4)
}
)
val purchaseFlow = exec(
group("购买流程") {
exec(http("创建订单")
.post("/api/orders")
.body(StringBody(
"""{
| "items": ${cartItems},
| "shippingAddress": "${address}",
| "paymentMethod": "${paymentMethod}"
|}""".stripMargin))
.asJson
.check(status.is(201))
.check(jsonPath("$.orderId").saveAs("orderId")))
.pause(1)
.exec(http("确认订单")
.post("/api/orders/${orderId}/confirm")
.check(status.is(200)))
}
)
}
// 组合使用模块
val completeUserJourney = scenario("完整用户旅程")
.exec(UserActions.browseProducts)
.pause(3)
.exec(UserActions.searchProducts)
.pause(2)
.exec(UserActions.purchaseFlow)
错误处理和恢复
scala
val resilientUser = scenario("弹性用户")
.exec(http("访问首页")
.get("/")
.check(status.is(200))
.check(header("X-Request-ID").saveAs("requestId")))
.pause(2)
// 处理可能的错误
.tryMax(2, "登录重试") {
exec(http("用户登录")
.post("/login")
.body(StringBody("""{"username":"${user}", "password":"${pass}"}"""))
.asJson
.check(status.in(200, 201))
.check(jsonPath("$.token").saveAs("authToken")))
}.exitHereIfFailed
.doIf(session => session("authToken").asOption[String].isDefined) {
exec(http("获取用户资料")
.get("/profile")
.header("Authorization", "Bearer ${authToken}")
.check(status.is(200))
// 如果失败，回退到基础数据
.checkIf(status.is(200)) {
jsonPath("$.premiumFeatures").saveAs("features")
}.checkIf(status.is(404)) {
jsonPath("$.basicFeatures").saveAs("features")
})
}
// 记录错误但不中断测试
.exec(session => {
if (session.isFailed) {
println(s"请求失败但继续执行: ${session("requestId").asOption[String]}")
}
session
})
六、监控验证
验证和断言
scala
val validatedScenario = scenario("带验证的用户流程")
.exec(
http("创建资源")
.post("/api/resources")
.body(StringBody("""{"name": "test-resource", "type": "document"}"""))
.asJson
.check(status.is(201))
.check(jsonPath("$.id").saveAs("resourceId"))
.check(jsonPath("$.createdAt").transform(dateStr =>
java.time.Instant.parse(dateStr).toEpochMilli
).saveAs("creationTime"))
.check(header("Location").saveAs("resourceLocation"))
)
.pause(1)
.exec(
http("验证资源创建")
.get("${resourceLocation}")
.check(status.is(200))
.check(jsonPath("$.id").is("${resourceId}"))
.check(jsonPath("$.status").is("active"))
.check(jsonPath("$.name").is("test-resource"))
// 验证时间戳在合理范围内
.check(jsonPath("$.createdAt").transform(dateStr =>
val created = java.time.Instant.parse(dateStr).toEpochMilli
val now = System.currentTimeMillis()
(now - created) < 60000 // 创建时间应在1分钟内
).is(true))
)
.exec(
http("执行复杂操作")
.put("/api/resources/${resourceId}/process")
.check(status.is(202))
.check(header("X-Operation-Id").notNull)
.check(bodyString.saveAs("responseBody"))
// 自定义验证
.check(bodyString.transform(body => {
val json = io.circe.parser.parse(body).getOrElse(io.circe.Json.Null)
val status = json.hcursor.downField("status").as[String].getOrElse("")
status == "processing" || status == "queued"
}).is(true))
)
性能监控点
scala
val monitoredScenario = scenario("带监控的用户流程")
.exec(
group("关键业务事务") {
exec(
http("事务开始")
.get("/api/transaction/start")
.check(status.is(200))
).pause(1)
.exec(
http("处理步骤1")
.post("/api/transaction/step1")
.check(status.is(200))
.check(responseTimeInMillis.lt(1000)) // 响应时间断言
)
.exec(
http("处理步骤2")
.post("/api/transaction/step2")
.check(status.is(200))
.check(responseTimeInMillis.lt(2000))
)
.exec(
http("事务提交")
.post("/api/transaction/commit")
.check(status.is(200))
.check(jsonPath("$.transactionId").saveAs("txId"))
)
}.resources(
// 监控相关资源加载
http("加载CSS")
.get("/static/css/app.css"),
http("加载JS")
.get("/static/js/app.js")
)
)
七、电商平台用户模拟案例
scala
class ECommerceSimulation extends Simulation {
val httpProtocol = http
.baseUrl("https://ecommerce.example.com")
.acceptHeader("application/json")
.acceptEncodingHeader("gzip, deflate")
.userAgentHeader("Mozilla/5.0")
.disableCaching
// 数据供给
val userAccounts = csv("data/users.csv").circular
val products = jsonFile("data/products.json").random
val searchTerms = csv("data/search_terms.csv").random
// 用户行为对象
object Browse {
val homepage = exec(http("访问首页")
.get("/")
.check(status.is(200))
.check(css("meta[name='csrf-token']", "content").saveAs("csrfToken")))
.pause(2, 5)
val category = exec(
feed(products)
.exec(http("浏览分类")
.get("/category/${categoryId}")
.check(status.is(200))
.check(css(".product-card", "data-id").findRandom.saveAs("viewedProduct")))
.pause(3, 8)
)
val productDetail = exec(
exec(http("查看产品详情")
.get("/product/${viewedProduct}")
.check(status.is(200))
.check(css("#product-price").saveAs("productPrice")))
.pause(5, 15) // 仔细查看产品
)
}
object Search {
val performSearch = exec(
feed(searchTerms)
.exec(http("搜索产品")
.get("/search")
.queryParam("q", "${searchTerm}")
.check(status.is(200))
.check(css(".search-result-item").count.saveAs("resultCount")))
.pause(1, 3)
)
val filterResults = exec(
exec(http("筛选结果")
.get("/search/filter")
.queryParam("q", "${searchTerm}")
.queryParam("priceMin", "0")
.queryParam("priceMax", "100")
.check(status.is(200)))
.pause(2, 4)
)
}
object Cart {
val addToCart = exec(
exec(http("添加到购物车")
.post("/cart/add")
.header("X-CSRF-Token", "${csrfToken}")
.formParam("productId", "${viewedProduct}")
.formParam("quantity", "1")
.check(status.is(200))
.check(jsonPath("$.cartTotal").saveAs("cartTotal")))
.pause(1, 2)
)
val viewCart = exec(
exec(http("查看购物车")
.get("/cart")
.check(status.is(200))
.check(css(".cart-item").count.gt(0)))
.pause(2, 3)
)
}
object Checkout {
val startCheckout = exec(
exec(http("开始结账")
.post("/checkout/start")
.header("X-CSRF-Token", "${csrfToken}")
.check(status.is(200))
.check(jsonPath("$.checkoutId").saveAs("checkoutId")))
.pause(1, 2)
)
val submitOrder = exec(
exec(http("提交订单")
.post("/checkout/${checkoutId}/complete")
.header("X-CSRF-Token", "${csrfToken}")
.body(StringBody("""{
"shippingMethod": "standard",
"paymentMethod": "credit_card",
"billingAddress": ${addressJson}
}""")).asJson
.check(status.is(200))
.check(jsonPath("$.orderNumber").saveAs("orderNumber")))
.pause(2, 5)
)
}
// 定义完整用户流程
val standardUser = scenario("标准用户")
.feed(userAccounts)
.exec(Browse.homepage)
.randomSwitch(
60.0 -> exec(Browse.category),
40.0 -> exec(Search.performSearch)
)
.pause(2, 5)
.exec(Browse.productDetail)
.randomSwitch(
30.0 -> exec(Cart.addToCart), // 30%的用户添加购物车
70.0 -> exec(Search.performSearch) // 70%继续浏览
)
.doIf(session => session("cartTotal").asOption[String].isDefined) {
exec(Cart.viewCart)
.randomSwitch(
50.0 -> exec(Checkout.startCheckout), // 50%结账
50.0 -> exec(session => {
println(s"用户放弃购物车: ${session("userId").as[String]}")
session
})
)
}
// 设置负载模式
setUp(
standardUser.inject(
nothingFor(5.seconds), // 热身期
rampUsers(50).during(30.seconds), // 逐步增加
constantUsersPerSec(2).during(5.minutes), // 稳定负载
rampUsersPerSec(2).to(10).during(2.minutes), // 压力测试
constantUsersPerSec(10).during(3.minutes), // 峰值负载
rampUsersPerSec(10).to(2).during(1.minute) // 恢复期
)
).protocols(httpProtocol)
.maxDuration(15.minutes)
.assertions(
global.responseTime.percentile3.lt(800), // 99%请求<800ms
global.responseTime.max.lt(3000),
global.failedRequests.percent.lt(1.0),
forAll.responseTime.percentile4.lt(500) // 所有请求的95%<500ms
)
}
八、总结
设计原则
真实：模拟真实用户行为，包括思考时间、错误处理、随机选择
模块化：将常用操作封装为可重用组件
数据驱动：使用外部数据源模拟多样化用户
渐进加载：从低负载开始，逐步增加压力
监控验证：添加断言和监控点
调试技巧
scala
// 添加调试信息
val debugScenario = scenario("调试场景")
.exec(session => {
println(s"当前用户: ${session("userId").asOption[String]}")
println(s"会话属性: ${session.attributes}")
session
})
.exec(http("测试请求")
.get("/debug")
.check(bodyString.saveAs("response"))
.check(status.is(200)))
.exec(session => {
println(s"响应内容: ${session("response").as[String]}")
session
})
// 使用Gatling Recorder记录真实用户操作
// gatling-recorder --help
性能优化建议
连接池配置：优化HTTP连接重用
资源清理：及时关闭不用的连接
缓存策略：合理使用缓存减少重复请求
断言优化：避免过于复杂的断言影响性能
热门标签 换一换
CNAS软件测评报告 CMA软件测评报告 首版次软件认定 软件结题验收 软件测试报告书 软件质量检测 数据库测试 H5应用测试 软件质检机构 第三方质检机构 第三方权威质检机构 信创测评机构 信息技术应用创新测评机构 信创测试 软件信创测试 软件系统第三方测试 软件系统测试 软件测试标准 工业软件测试 软件应用性能测试 应用性能测试 可用性测试 软件可用性测试 软件可靠性测试 可靠性测试 系统应用测试 软件系统应用测试 软件应用测试 软件负载测试 API自动化测试 软件结题测试 软件结题测试报告 软件登记测试 软件登记测试报告 软件测试中心 第三方软件测试中心 应用测试 第三方应用测试 软件测试需求 软件检测报告定制 软件测试外包公司 第三方软件检测报告厂家 CMA资质 软件产品登记测试 软件产品登记 软件登记 CNAS资质 cma检测范围 cma检测报告 软件评审 软件项目评审 软件项目测试报告书 软件项目验收 软件质量测试报告书 软件项目验收测试 软件验收测试 软件测试机构 软件检验 软件检验检测 WEB应用测试 API接口测试 接口性能测试 第三方系统测试 第三方网站系统测试 数据库系统检测 第三方数据库检测 第三方数据库系统检测 第三方软件评估 课题认证 第三方课题认证 小程序测试 app测试 区块链业务逻辑 智能合约代码安全 区块链 区块链智能合约 软件数据库测试 第三方数据库测试 第三方软件数据库测试 软件第三方测试 软件第三方测试方案 软件测试报告内容 网站测试报告 网站测试总结报告 信息系统测试报告 信息系统评估报告 信息系统测评 语言模型安全 语言模型测试 软件报告书 软件测评报告书 第三方软件测评报告 检测报告厂家 软件检测报告厂家 第三方网站检测 第三方网站测评 第三方网站测试 检测报告 软件检测流程 软件检测报告 第三方软件检测 第三方软件检测机构 第三方检测机构 软件产品确认测试 软件功能性测试 功能性测试 软件崩溃 稳定性测试 API测试 API安全测试 网站测试测评 敏感数据泄露测试 敏感数据泄露 敏感数据泄露测试防护 课题软件交付 科研经费申请 软件网站系统竞赛 竞赛CMA资质补办通道 中学生软件网站系统CMA资质 大学生软件网站系统CMA资质 科研软件课题cma检测报告 科研软件课题cma检测 国家级科研软件CMA检测 科研软件课题 国家级科研软件 web测评 网站测试 网站测评 第三方软件验收公司 第三方软件验收 软件测试选题 软件测试课题是什么 软件测试课题研究报告 软件科研项目测评报告 软件科研项目测评内容 软件科研项目测评 长沙第三方软件测评中心 长沙第三方软件测评公司 长沙第三方软件测评机构 软件科研结项强制清单 软件课题验收 软件申报课题 数据脱敏 数据脱敏传输规范 远程测试实操指南 远程测试 易用性专业测试 软件易用性 政府企业软件采购验收 OA系统CMA软件测评 ERP系统CMA软件测评 CMA检测报告的法律价值 代码原创性 软件著作登记 软件著作权登记 教育APP备案 教育APP 信息化软件项目测评 信息化软件项目 校园软件项目验收标准 智慧软件项目 智慧校园软件项目 CSRF漏洞自动化测试 漏洞自动化测试 CSRF漏洞 反序列化漏洞测试 反序列化漏洞原理 反序列化漏洞 命令执行 命令注入 漏洞检测 文件上传漏洞 身份验证 出具CMA测试报告 cma资质认证 软件验收流程 软件招标文件 软件开发招标 卓码软件测评 WEB安全测试 漏洞挖掘 身份验证漏洞 测评网站并发压力 测评门户网站 Web软件测评 XSS跨站脚本 XSS跨站 C/S软件测评 B/S软件测评 渗透测试 网站安全 网络安全 WEB安全 并发压力测试 常见系统验收单 CRM系统验收 ERP系统验收 OA系统验收 软件项目招投 软件项目 软件投标 软件招标 软件验收 App兼容性测试 CNAS软件检测 CNAS软件检测资质 软件检测 软件检测排名 软件检测机构排名 Web安全测试 Web安全 Web兼容性测试 兼容性测试 web测试 黑盒测试 白盒测试 负载测试 软件易用性测试 软件测试用例 软件性能测试 科技项目验收测试 首版次软件 软件鉴定测试 软件渗透测试 软件安全测试 第三方软件测试报告 软件第三方测试报告 第三方软件测评机构 湖南软件测评公司 软件测评中心 软件第三方测试机构 软件安全测试报告 第三方软件测试公司 第三方软件测试机构 CMA软件测试 CNAS软件测试 第三方软件测试 移动app测试 软件确认测试 软件测评 第三方软件测评 软件测试公司 软件测试报告 跨浏览器测试 软件更新 行业资讯 软件测评机构 大数据测试 测试环境 网站优化 功能测试 APP测试 软件兼容测试 安全测评 第三方测试 测试工具 软件测试 验收测试 系统测试 测试外包 压力测试 测试平台 bug管理 性能测试 测试报告 测试框架 CNAS认可 CMA认证 自动化测试
400-607-0568