k6峰值流量回放与瓶颈定位 - 第1节

1.1 为什么需要峰值流量回放？

在微服务与云原生架构下，系统瓶颈往往在流量峰值瞬间暴露：秒杀、大促、热点事件引发的流量洪峰，可能导致服务雪崩、数据库连接池耗尽、CPU 毛刺甚至全站宕机。传统的压测方式使用固定并发数或阶梯递增模型，难以还原真实流量在时间维度上的“尖刺”特征。

k6 峰值流量回放的核心价值在于：

• 真实还原：基于生产环境流量录制（如 HAR、Prometheus 指标、网关日志），在测试环境按时间轴精确回放请求序列与并发模式。
• 精准定位：通过 k6 内置的 HTTP 指标、Trend 与自定义检查，快速识别响应时间突变、错误率飙升、资源饱和点。
• 低成本验证：无需搭建庞大的流量模拟集群，单机 k6 即可驱动数万 VU，配合 k6-operator 可弹性扩展。

1.2 课程大纲概览

本课程共 30 章，分为四大模块，覆盖从流量录制到瓶颈定位的完整链路：

每章均包含：概念讲解 + 可运行代码 + 内联架构图 + 避坑提示。

1.3 学习目标

完成本课程后，你将能够：

1. 独立搭建基于 k6 的峰值流量回放环境，支持 HAR、CSV、gRPC 等多种数据源。
2. 编写可复用的回放脚本，包含动态关联、参数化、阈值断言与自定义指标。
3. 执行单机与分布式回放，利用 k6-operator 在 Kubernetes 上弹性调度。
4. 定位常见的性能瓶颈：慢 SQL、连接池耗尽、CPU 调度延迟、内存泄漏、IO 等待。
5. 输出专业的性能报告，包含火焰图、响应时间分布、资源饱和度曲线。

1.4 前置知识

为了获得最佳学习体验，建议你具备以下基础：

1.5 峰值流量回放核心流程

下图展示了从生产流量采集到瓶颈定位的完整数据流与工具链：

1.6 课程使用的工具链

本课程将围绕以下工具链展开，所有工具均为开源或免费使用：

• k6：核心回放引擎，支持 JavaScript 脚本、自定义指标、阈值与分布式执行。
• k6-operator：Kubernetes 原生 operator，用于在 K8s 集群中编排大规模回放任务。
• HAR 录制器：浏览器 DevTools 或 mitmproxy 导出 HAR 文件，作为流量数据源。
• Prometheus + Grafana：采集 k6 运行时指标并可视化，辅助瓶颈定位。
• 火焰图工具：用于分析 CPU 热点与调用栈。

1.7 一个简单的回放脚本示例

以下脚本演示了如何基于 HAR 文件进行峰值流量回放。该脚本将在第 6 章详细讲解。

import http from 'k6/http';
import { check, sleep } from 'k6';
import { SharedArray } from 'k6/data';

// 从 HAR 文件加载请求序列
const requests = new SharedArray('requests', function () {
  return JSON.parse(open('./peak.har')).log.entries.map(e => ({
    method: e.request.method,
    url: e.request.url,
    headers: e.request.headers,
    body: e.request.postData ? e.request.postData.text : null,
  }));
});

export const options = {
  scenarios: {
    peak_replay: {
      executor: 'ramping-arrival-rate',
      startRate: 10,
      timeUnit: '1s',
      preAllocatedVUs: 50,
      maxVUs: 200,
      stages: [
        { target: 100, duration: '30s' },
        { target: 500, duration: '30s' },
        { target: 1000, duration: '60s' },
      ],
    },
  },
  thresholds: {
    http_req_duration: ['p(95)<2000'],
    http_req_failed: ['rate<0.01'],
  },
};

export default function () {
  const idx = Math.floor(Math.random() * requests.length);
  const req = requests[idx];
  const res = http.request(req.method, req.url, req.body, { headers: req.headers });
  check(res, {
    'status is 2xx': (r) => r.status >= 200 && r.status < 300,
    'response time < 2s': (r) => r.timings.duration < 2000,
  });
  sleep(0.1);
}