PHP 怎么流量录制回放

本文目录导读：

1. 黑盒方案：使用现成的开源工具（推荐首选）
2. 代码层方案：PHP 原生扩展或框架中间件
3. 高级场景：处理“幂等性”与“数据篡改”
4. 在 Swoole 常驻内存环境下的特殊处理
5. 选型总结
6. 重要注意事项（抄作业前必看）

流量录制回放（Traffic Recording & Replay）是保障系统在重构、升级、压测时行为一致性的重要手段，在 PHP 生态中，实现方式主要分为 “黑盒代理层” 和 “代码层埋点” 两类。

根据你的需求和环境（是否使用 Swoole/FPM、是否允许侵入代码），常用的方案如下：

黑盒方案：使用现成的开源工具（推荐首选）

这种方式对 PHP 代码零侵入，通过代理（Proxy）或网关捕获流量，不关心后端语言是 PHP 还是 Java。

方案 A：GoReplay（最流行，适合 HTTP 流量）

• 原理：在服务器上通过 --input-raw 监听网卡端口，捕获真实请求，通过 --output-http 批量发送到测试环境。

• 特点：支持流量放大（压测）、流量过滤（只录制特定接口）、中间件修改（JWT 脱敏）。

• 使用（假设线上端口 80，测试环境 staging.example.com）：

  # 录制（存到文件）
  sudo gor --input-raw :80 --output-file requests.gor
  # 回放（发送到测试环境）
  sudo gor --input-file requests.gor --output-http "http://staging.example.com"

方案 B：JVM 系工具（如 jvm-sandbox-repeater）的 HttpClient 适配

• 虽然主力是 Java，但配合 PHP 的 Guzzle/Curl，也可通过设置 HTTP 代理（如 proxy）拦截并录制。
• 适合：已有 Java 录制回放平台，希望 PHP 应用接入。

代码层方案：PHP 原生扩展或框架中间件

当需要录制函数参数、数据库 SQL 或内部复杂逻辑时，需要侵入代码。

方案 C：使用 PHP 中间件 + Redis/文件存储（半侵入）

利用 PHP-FPM 的 auto_prepend_file 或在框架（Laravel/Symfony）的中间件中实现：

// 1. 录制中间件（在线上环境开关）
public function handle($request, Closure $next)
{
    if (config('traffic.record.enabled')) {
        $data = [
            'uri' => $request->getRequestUri(),
            'method' => $request->getMethod(),
            'headers' => $request->headers->all(),
            'body' => $request->getContent(),
            'time' => microtime(true)
        ];
        Redis::rpush('traffic:queue', json_encode($data)); // 异步写入 Redis
    }
    return $next($request);
}
// 2. 回放脚本（在测试环境 CLI 运行）
$recorded = Redis::lrange('traffic:queue', 0, -1);
foreach ($recorded as $item) {
    $data = json_decode($item, true);
    $response = Http::withHeaders($data['headers'])
                  ->send($data['method'], $data['uri'], ['body' => $data['body']]);
    // 对比响应差异...
}

• 优点：能拿到 PHP 层已经解析好的参数（如 PHP 输入流）。
• 缺点：需要手动处理并发、ID 去重、外呼请求（第三方 API）屏蔽。

方案 D：使用 PHP 扩展（如 OpenTelemetry + Tideways 等 APM 工具）

• 原理：APM 工具本身会记录请求上下文（Trace ID、耗时、参数）。
• 局限：它们主要是为了监控，回放能力较弱，通常需配合前端录制插件（如阿里 ARMS）才能完成回放。

高级场景：处理“幂等性”与“数据篡改”

录制回放最大的坑是测试环境数据不一致，导致回放结果与线上不符。

• 方案：在回放脚本中加入 “动态数据 Mask（打码）” 逻辑。
  • 对 用户 ID、订单号 使用 Hash 映射（如 userId=123 → userId=abc123）。
  • 屏蔽 第三方支付回调、短信验证码 等外呼请求。
  • 在代码层,建议使用依赖注入（DI）容器，在回放时替换掉 HttpClient 为 Mock。

在 Swoole 常驻内存环境下的特殊处理

如果使用 Swoole 或 Hyperf，录制回放会更简单，因为请求对象生命周期可控：

• 直接在 Pipeline 中间件中协程化录制（性能开销极小）。
• 回放时,可以直接在内存中调用 Controller 方法，无需发起 HTTP 请求，效率更高。

// Hyperf 示例（伪代码）
$this->server->on('request', function ($request, $response) {
    if (TrafficStore::isReplayMode()) {
        // 直接调用内核处理，不走 TCP 端口回环
        return $this->core->handle($request->data);
    }
});

选型总结

重要注意事项（抄作业前必看）

1. 敏感数据脱敏：录制时不要保存 Cookie、Authorization 头（除非测试环境是可信任的）。
2. 时间戳与随机数：回放时建议全局冻结 time() 和随机数种子，否则结果不可复现。
3. 异步任务：如果代码里涉及 queue:push，回放时应重定向到测试队列，避免对线上资源造成污染。
4. 文件上传：录制时保存 tmp_name 下的文件内容，回放时需重新构造文件流。

最推荐的快速落地路径：如果是标准 HTTP 应用，直接上 GoReplay，它有完善的中间件生态（--middleware），可以通过编写简单 Python 脚本对录制流量做脱敏、IP 替换，且性能极高，不需要改任何 PHP 代码，成本最低，见效最快。