4、回放技术原理：请求回放（HTTP/gRPC）、数据库回放（SQL replay）、消息队列回放（Kafka replay）
回放技术是审计基线的核心执行引擎。它通过录制生产环境的真实流量或数据变更，在测试或预发环境中重新执行，从而验证系统行为、数据一致性与性能基线。本章从三种主流回放维度展开：请求回放（HTTP/gRPC）、数据库回放（SQL replay）和消息队列回放（Kafka replay）。
4.1 请求回放（HTTP/gRPC）
请求回放是最常见的回放模式，适用于微服务网关、API 网关、BFF 层等无状态或弱状态服务的审计。其核心思路是：录制生产环境的请求报文（包括 Header、Body、Query 参数），在目标环境按原时序或并发度重新发送，并比对响应状态码、响应体、响应延迟。
4.1.1 HTTP 回放流程
- 录制层：通过 Sidecar 代理或 SDK 拦截器捕获 HTTP 请求/响应对，写入本地文件或消息队列。
- 存储层：将录制的请求按时间戳、TraceID、接口路径索引，支持去重与过滤。
- 调度层：按原始时间间隔或加速比（如 2x、5x）重新发送请求，支持并发控制与超时重试。
- 比对层：对比回放响应与录制响应的状态码、关键字段、响应时间，输出差异报告。
关键指标：回放覆盖率（录制请求数 / 回放成功数）、响应差异率、平均延迟偏差（ms）。
4.1.2 gRPC 回放差异
| 维度 | HTTP 回放 | gRPC 回放 |
|---|---|---|
| 协议格式 | 文本/JSON 明文 | Protobuf 二进制序列化 |
| 录制方式 | HTTP 拦截器 / 反向代理 | gRPC 拦截器（Unary/Stream） |
| 回放难点 | Header 顺序、Cookie 过期 | Stream 时序、Metadata 完整性 |
| 比对策略 | JSON 路径比对 + 模糊匹配 | Protobuf 字段级比对 + 忽略时间戳 |
实践建议：gRPC 回放时务必保留原始 Metadata（如 token、trace_id），否则服务端认证或链路追踪会失败。
4.2 数据库回放（SQL replay）
数据库回放用于审计数据访问层（DAL）的变更行为。它录制生产数据库的 SQL 执行日志（包括 SELECT、INSERT、UPDATE、DELETE），在测试库按相同顺序和参数重新执行，并比对影响行数、执行耗时、返回结果集。
4.2.1 录制与回放策略
- 录制源：MySQL general log、PostgreSQL pg_stat_statements、阿里云 RDS 审计日志、自研 ORM 拦截器。
- 回放约束：必须隔离写操作（INSERT/UPDATE/DELETE）到影子表或事务回滚，避免污染测试库。
- 比对维度：影响行数、执行计划（EXPLAIN）、返回行数、最大/平均延迟。
注意：数据库回放不能直接在生产库执行写操作。必须使用影子表（shadow table）或事务回滚（ROLLBACK）机制，否则会造成数据污染。
4.2.2 SQL 回放与请求回放对比
| 对比项 | 请求回放 | 数据库回放 |
|---|---|---|
| 录制粒度 | HTTP/gRPC 请求 | 单条 SQL 或事务 |
| 回放副作用 | 低（幂等设计可消除） | 高（写操作必须隔离） |
| 比对复杂度 | JSON 字段级 | 结果集 + 执行计划 |
| 典型工具 | GoReplay、gRPCurl | SQLReplay、pt-query-digest |
4.3 消息队列回放（Kafka replay）
消息队列回放适用于异步事件驱动的系统审计。它录制 Kafka Topic 中的消息（包括 Key、Value、Headers、Partition、Offset），在测试集群按原始分区顺序重新生产，并比对消费端处理结果与延迟。
4.3.1 回放关键步骤
- 录制：通过 Kafka MirrorMaker 或自研 Consumer 将指定 Topic 的消息持久化到文件或对象存储。
- 清洗：过滤无效消息、脱敏敏感字段、修正时间戳（避免 TTL 过期）。
- 回放：使用 Kafka Producer 按原始 Partition 和 Offset 顺序发送，支持消息速率控制（如 100 msg/s）。
- 验证：消费端记录处理结果，比对消息丢失率、重复率、端到端延迟。
审计要点：消息队列回放必须保留原始 Partition 顺序，否则会破坏业务状态机（如订单状态流转）。
4.3.2 三种回放技术对比总表
| 维度 | 请求回放 | 数据库回放 | 消息队列回放 |
|---|---|---|---|
| 录制对象 | HTTP/gRPC 请求 | SQL 语句 | Kafka 消息 |
| 回放目标 | API 服务 | 数据库实例 | Kafka Topic |
| 顺序敏感度 | 低（可并发） | 中（事务内有序） | 高（分区内有序） |
| 副作用风险 | 低（幂等设计） | 高（写污染） | 中（消费幂等） |
| 比对维度 | 响应状态 / 体 / 延迟 | 影响行数 / 执行计划 | 消费结果 / 延迟 / 丢失率 |
选型建议：审计无状态 API 优先用请求回放；审计数据层变更必须用数据库回放 + 影子表；审计异步链路完整性必须用消息队列回放 + 分区保序。