Nginx mirror模块可无感复制生产高并发事件流至联调异步网关,需满足:版本≥1.13.4并启用mirror模块;location中配置mirror /mirror_async、mirror_request_body on;/mirror_async设为internal;proxy_pass保留$request_uri并加X-Traffic-Source头;异步网关需识别镜像流量并路由至影子库、测试Topic及带mirror标记缓存;通过超时控制、禁用缓冲与重试保障主链路稳定。

用 Nginx 的 mirror 模块把生产环境的真实高并发事件流无感复制到联调异步网关,核心在于“不扰主链路、不丢数据、能控节奏”。它不是把流量导过去就完事,而是让异步网关在完全不影响线上服务的前提下,拿到和线上一模一样的请求(含方法、URI、Header、Body),做联调验证或行为分析。
确认基础能力是否就位
先确保 Nginx 版本 ≥ 1.13.4,并已启用 ngx_http_mirror_module:
- 运行
nginx -V 2>&1 | grep -o with-http-mirror-module,有输出即支持 - 若为旧版本(如 1.12.x),需升级或重新编译时加
--with-http-mirror-module -
mirror 指令只能出现在
location块中,且必须配合proxy_pass使用
关键配置要写对
镜像不是简单转发,几个开关和路径必须配准:
- 在目标
location中启用mirror /mirror_async;,指向内部专用路径 - 务必开启
mirror_request_body on;—— 否则 POST/PUT 等带体事件(如 Webhook、MQTT over HTTP、JSON 事件推送)会丢失 body -
location = /mirror_async必须设为internal;,防止外部直接调用或探测 -
proxy_pass http://async_gateway$request_uri;中的$request_uri保留原始路径与 query,确保事件上下文完整 - 建议加标识头:
proxy_set_header X-Traffic-Source mirror;,方便异步网关识别并做隔离处理(如跳过幂等校验、写影子表)
适配联调异步网关的行为
镜像流量抵达后,异步网关不能当作普通请求处理,否则可能污染状态或触发真实动作:
- 通过
X-Traffic-Source: mirror或自定义 header 判断是否为镜像流 - 数据库操作自动路由到影子库(如
events_mirror),或加前缀(event_123_mirror) - 消息投递类操作改为本地日志落盘或发往测试 Topic,不触达下游真实系统
- 缓存 key 加标记(如
cache:event:id:123:mirror),避免击穿线上缓存 - 若异步网关本身有重试机制,建议关闭镜像流量的重试,防止重复压测
控制并发与稳定性
高并发事件流下,镜像不能拖慢主服务,也不能压垮异步网关:
- 给
/mirror_asynclocation 配置独立超时:proxy_connect_timeout 2s; proxy_send_timeout 2s; proxy_read_timeout 4s; - 关闭缓冲:
proxy_buffering off;,减少内存占用 - 禁用重试:
proxy_next_upstream off;,失败即丢弃,不干扰主流程 - 如需限流,可用
limit_req套在/mirror_async上,或借助 map + 变量实现条件镜像(如仅镜像POST /event)










