Go中间件中需自定义ResponseWriter缓存响应体,并用ioutil.ReadAll+io.NopCloser复用r.Body,同时对敏感字段脱敏、限制日志长度、跳过健康检查路径并采样,以兼顾审计完整性与性能。

中间件里怎么拿到请求和响应的完整内容
Go 的 http.Handler 中间件默认只能访问 *http.Request 和 http.ResponseWriter,但后者是接口,不支持直接读取响应体。想审计 API 的入参和出参,必须包装响应写入过程。
常见错误是直接用 response.Body —— 它根本不存在;或者试图在 WriteHeader 后再读响应,此时已发送给客户端,无法捕获。
- 用
httptest.ResponseRecorder仅适合测试,生产环境会吃内存、拖慢吞吐,别用 - 正确做法:自定义一个
ResponseWriter实现,把Write和WriteHeader的数据缓存到字节切片或bytes.Buffer - 注意响应可能分多次
Write,要确保缓存完整;如果响应体很大(比如文件下载),需设上限并标记截断,避免 OOM
示例关键结构:
type auditResponseWriter struct {
http.ResponseWriter
statusCode int
body *bytes.Buffer
}
如何在不侵入业务逻辑的前提下记录请求参数
GET 请求参数从 r.URL.Query() 拿,POST/PUT 的 JSON 或表单则得解析 r.Body。但问题在于:r.Body 只能读一次,读完业务 handler 就拿不到原始数据了。
解决方案不是“复制一遍 body”,而是用 io.TeeReader 或重置 Body 的底层 io.ReadCloser:
- 对 JSON 请求,建议用
io.NopCloser(bytes.NewReader(buf))把缓存的字节重新赋给r.Body,前提是提前ioutil.ReadAll(r.Body)并保存 - 注意
r.ParseForm()会自动读Body,若审计中间件在它之前执行,必须手动调用r.ParseMultipartForm或r.ParseForm并恢复r.PostForm等字段 - 敏感字段(如
password、token)应在审计前就脱敏,别等日志落地再处理
审计日志该写到哪里、写什么字段才实用
写本地文件容易丢日志、难聚合;直连 Elasticsearch 或 Kafka 又增加部署复杂度。折中方案是走结构化日志管道,比如用 zerolog + stdout,由容器平台统一收集。
一条可用的审计日志至少包含:
-
timestamp:用time.Now().UTC().Format(time.RFC3339),避免时区混乱 -
method、path、status_code、duration_ms:基础指标,便于监控告警 -
req_id:从X-Request-ID头提取,或用uuid.NewString()补充,用于链路追踪 -
client_ip:别只取r.RemoteAddr,要检查X-Forwarded-For并做可信代理白名单校验 -
req_body和resp_body:必须限制长度(如 2KB),超长加"[TRUNCATED]"标记
别记录 Authorization 头原始值 —— 即使是 Bearer Token,也应只记前 8 位 + "..."。
并发高时审计中间件引发的性能抖动怎么压
审计动作本身不是纯内存操作:JSON 序列化、字符串拼接、日志写入都涉及内存分配和锁。QPS 上千后,容易成为瓶颈。
- 避免在审计中间件里做
json.Marshal:先用bytes.Buffer缓存原始字节,序列化推迟到日志采集端 - 日志写入不要同步刷盘,用带缓冲的
zerolog.ConsoleWriter或异步 channel + worker 模式 - 对健康检查路径(如
/healthz)、静态资源(/static/)做路径白名单跳过审计,用strings.HasPrefix(r.URL.Path, "/healthz")判断比正则快得多 - 启用采样:比如
rand.Intn(100) == 0只记录 1% 请求,调试期开全量,上线后降级
最易被忽略的是:审计中间件一定要放在所有其他中间件之后(比如 JWT 验证、限流之后),否则记录的 status_code 是 401/429,而不是业务真实返回码。
大量免费API接口:立即使用
涵盖生活服务API、金融科技API、企业工商API、等相关的API接口服务。免费API接口可安全、合规地连接上下游,为数据API应用能力赋能!











