# k6 负载测试专家 k6 框架性能测试专家。 ## k6 核心原则 * **虚拟用户（VU）** ：每个VU独立并行运行测试脚本 * **迭代与持续时间**：在基于迭代或基于时间的测试执行之间进行选择 * **阶段**：逐渐增加/减少负载以模拟真实的流量模式 * **阈值**：定义自动性能验证的通过/失败标准 * **指标**：关注关键性能指标（响应时间、吞吐量、错误率） ## 基本测试脚本结构从'k6/http'导入http；从'k6'导入{检查，睡眠}；从'k6/metrics'导入{速率，趋势}； // 自定义指标 const errorRate = new Rate('错误'); const customTrend = new Trend('custom_duration'); // 测试配置导出常量选项= { 阶段：[ { period: '2m', target: 10 }, // 最多支持 10 个用户 { period: '5m', target: 10 }, // 保持在 10 个用户 { period: '2m', target: 20 }, // 最多支持 20 个用户 { period: '5m', target: 20 }, // 保持在 20 个用户 { period: '2m', target: 0 }, // 下降到 0 ], 阈值：{ http_req_duration: ['p(95)<500'], // 95% 的请求低于 500ms http_req_failed: ['rate<0.1'], // 错误率低于10% 错误：['率<0.1']， }, }; // 设置函数（测试前运行一次）导出函数 setup() { // 准备测试数据、验证等 const loginRes = http.post('https://api.example.com/auth/login', { 电子邮件：'test@example.com'，密码：'密码123', }); 返回 { 令牌：loginRes.json('token') }; } // 主要测试函数（针对每个 VU 运行）导出默认函数（数据）{ 常量参数 = { 标题：{ '授权': `承载${data.token}`, '内容类型'：'应用程序/json'， }, }; const 响应 = http.get('https://api.example.com/users', params); // 验证响应检查（响应，{ '状态为 200': (r) => r.status === 200, '响应时间 < 500ms': (r) => r.timings.duration < 500, '响应正文包含用户': (r) => r.body.includes('users'), }); // 跟踪自定义指标 errorRate.add(response.status !== 200); customTrend.add(response.timings.duration); // 考虑请求之间的时间睡眠（Math.random（）* 2 + 1）； // 1-3秒 } // Teardown 函数（测试后运行一次）导出函数拆卸（数据）{ // 清理操作 console.log('测试完成'); } ## 测试场景模式 ### 负载测试（正常流量）导出常量选项= { 阶段：[ { 持续时间: '5m', 目标: 50 }, // 加速 { period: '30m', target: 50 }, // 稳定状态 { 持续时间: '5m', 目标: 0 }, // 斜坡下降 ], 阈值：{ http_req_duration: ['p(95)<200', 'p(99)<500'], http_req_failed: ['速率<0.01'], }, }; ### 压力测试（超出正常容量）导出常量选项= { 阶段：[ { 持续时间：'2m'，目标：100 }, { 持续时间：'5m'，目标：100 }, { 持续时间：'2m'，目标：200 }, { 持续时间：'5m'，目标：200 }, { period: '2m', target: 300 }, // 超出正常容量 { 持续时间：'5m'，目标：300 }, { period: '10m', target: 400 }, // 断点 { 持续时间：'2m'，目标：0 }, ], }; ### 峰值测试（流量突然激增）导出常量选项= { 阶段：[ { period: '10s', target: 100 }, // 快速启动 { period: '1m', target: 100 }, // 保持峰值 { period: '10s', target: 0 }, // 快速减速 ], }; ### 浸泡测试（延长时间）导出常量选项= { 阶段：[ { 持续时间：'5m'，目标：50 }, {uration: '4h', target: 50 }, // 运行 4 小时 { 持续时间：'5m'，目标：0 }, ], }; ### 断点测试（寻找极限）导出常量选项= { 执行者：'斜坡到达率'，阶段：[ { 持续时间：'2m'，目标：100 }, { 持续时间：'2m'，目标：200 }, { 持续时间：'2m'，目标：300 }, { 持续时间：'2m'，目标：400 }, { 持续时间：'2m'，目标：500 }, // 继续直到系统崩溃 ], }; ## 高级模式 ### 数据驱动测试从'k6/data'导入{SharedArray}；从'https://jslib.k6.io/papaparse/5.1.1/index.js'导入papaparse； // 加载一次CSV数据，跨VU共享 const csvData = new SharedArray('用户', function() { return papaparse.parse(open('./users.csv'), { header: true }).data; }); 导出默认函数() { // 从数据集中随机用户 const user = csvData[Math.floor(Math.random() * csvData.length)]; const 负载 = JSON.stringify({ 用户名：用户.用户名，密码：用户.密码， }); const 响应 = http.post('https://api.example.com/login', 负载, { headers: { 'Content-Type': 'application/json' }, }); 检查（响应，{ '登录成功': (r) => r.status === 200, '存在令牌': (r) => r.json('token') !== '', }); } ### 基于会话的分组测试从'k6'导入{组，睡眠}；从'k6/http'导入http；导出默认函数() { 让 authToken；组（'身份验证'，函数（）{ const loginRes = http.post('https://api.example.com/auth/login', { 电子邮件：'user@example.com'，密码：'密码123', }); check(loginRes, { '登录成功': (r) => r.status === 200 }); authToken = loginRes.json('token'); }); const headers = { 授权：`Bearer ${authToken}` }; group('浏览产品', function() { const productsRes = http.get('https://api.example.com/products', { headers }); check(productsRes, { '产品已加载': (r) => r.status === 200 }); const ProductId = productsRes.json('产品')[0].id; constDetailRes = http.get(`https://api.example.com/products/${productId}`, { headers }); check(detailRes, { '产品详细信息已加载': (r) => r.status === 200 }); }); 组('添加到购物车', function() { const cartRes = http.post('https://api.example.com/cart', JSON.stringify({ 产品Id: 1, 数量: 2 }), { headers: { ...headers, 'Content-Type': 'application/json' } } ）； check(cartRes, { '已添加到购物车': (r) => r.status === 200 }); }); 组（'结帐'，函数（）{ const checkoutRes = http.post('https://api.example.com/checkout', JSON.stringify({ paymentMethod: '卡' }), { headers: { ...headers, 'Content-Type': 'application/json' } } ）； check(checkoutRes, { '结帐成功': (r) => r.status === 200 }); }); 睡眠（1）； } ### 批量请求从'k6/http'导入http；导出默认函数() { const 响应 = http.batch([ ['GET', 'https://api.example.com/users'], ['GET', 'https://api.example.com/products'], ['GET', 'https://api.example.com/orders'], ['POST', 'https://api.example.com/events', JSON.stringify({ event: 'page_view' }), { headers: { 'Content-Type': 'application/json' }, }], ]); check(responses[0], { '用户状态 200': (r) => r.status === 200 }); check(responses[1], { '产品状态 200': (r) => r.status === 200 }); check(responses[2], { '订单状态 200': (r) => r.status === 200 }); } ## 自定义指标从 'k6/metrics' 导入 { Counter, Gauge, Rate, Trend }; // 定义自定义指标 const pageViews = new Counter('page_views'); const activeUsers = new Gauge('active_users'); const errorRate = new Rate('error_rate'); const responseTrend = new Trend('response_trend'); 导出默认函数() { const 响应 = http.get('https://api.example.com/page'); // 记录指标 pageViews.add(1); activeUsers.add(__VU); // 当前 VU 计数 errorRate.add(response.status !== 200); responseTrend.add(response.timings.duration); // 用于分割的标签 pageViews.add(1, { 页面: 'home', 版本: 'v2' }); } ## 环境配置 ### 命令行选项 # 基本运行 k6 运行 script.js # 指定VU和持续时间 k6 运行 --vus 50 --duration 10m script.js # 环境变量 k6 run --env BASE_URL=https://staging.api.com --env API_KEY=xxx script.js # 输出到不同的后端 k6 run --out influxdb=http://localhost:8086/k6 script.js k6 run --out json=results.json script.js k6 run --out csv=results.csv script.js # 云执行 k6云脚本.js # 使用配置文件运行 k6 运行 --config config.json script.js ### 脚本中的环境变量 const BASE_URL = __ENV.BASE_URL || 'https://api.example.com'; const API_KEY = __ENV.API_KEY || '默认键'; 常量环境 = __ENV.ENV || '分期'；导出默认函数() { const 响应 = http.get(`${BASE_URL}/endpoint`, { 标头：{ 'X-API-Key': API_KEY }, }); } ## CI/CD 集成 ### GitHub 操作名称：负载测试于：推：分支：[主要] 时间表： - cron: '0 2 * * *' # 每天凌晨 2 点职位：负载测试：运行：ubuntu-latest 步骤： - 使用：actions/checkout@v4 - 名称：安装k6 运行：| 卷曲 -L https://github.com/grafana/k6/releases/download/v0.47.0/k6-v0.47.0-linux-amd64.tar.gz |焦油xvz sudo mv k6-v0.47.0-linux-amd64/k6 /usr/local/bin/ - 名称：运行负载测试运行：k6 run --env BASE_URL=${{secrets.API_URL}}tests/load-test.js - 名称：上传结果使用：actions/upload-artifact@v3 与：名称：k6-结果路径：结果.json ## 调试与分析从'https://jslib.k6.io/k6-summary/0.0.1/index.js'导入{textSummary}； // 自定义摘要处理程序导出函数handleSummary（数据）{ 返回{ 'stdout'：textSummary（数据，{缩进：''，enableColors：true}）， 'summary.json': JSON.stringify(数据), }; } 导出默认函数() { const 响应 = http.get('https://api.example.com/data'); // 失败时的详细调试 if (!check(response, { '状态为 200': (r) => r.status === 200 })) { console.error(`请求失败：${response.status}`); console.error(`响应正文: ${response.body.substring(0, 500)}`); console.error(`请求网址：${response.request.url}`); } // 记录慢速请求 if (response.timings.duration > 1000) { console.warn(`请求缓慢：${response.timings.duration}ms - ${response.request.url}`); } } ## 关键指标参考公制|描述 |典型阈值 ---|---|--- `http_req_duration` |响应时间| p(95)<500ms `http_req_failed` |请求失败率|率<0.01 `http_reqs` |每秒请求数 |不适用（仅供参考） `http_req_waiting` |到达第一个字节的时间 | p(95)<200ms `vus` |活跃虚拟用户|不适用 `迭代` |已完成迭代 |不适用 ## Лучшие практики 1. **现实的思考时间** — добавляйте `sleep()` между запросами 2. **逐步提升** — избегайте мгновенной нагрузки 3. **数据的SharedArray** — экономит память при больших датасетах 4. **有意义的阈值** — определяйте SLO заранее 5. **用于分段的标签** — группируйте метрики по 端点/功能 6. **监控负载生成器** — убедитесь, что k6 не 瓶颈

K6负载测试

包含技能