答案：通过Golang中间件捕获请求信息并使用zap实现结构化日志。1. 设计基础中间件记录方法、路径、IP、状态码和耗时；2. 使用自定义ResponseWriter获取响应状态；3. 集成zap输出JSON格式日志；4. 在Gin等框架中注册中间件；5. 结合错误恢复与分级记录提升可观测性。
在Golang开发Web服务时，中间件是处理请求前后逻辑的核心组件。日志记录作为可观测性的重要部分，通过中间件实现可以统一管理所有请求的出入信息。下面介绍如何使用Go标准库和第三方工具来实现一个高效、结构化的日志中间件。
基础日志中间件设计
一个典型的日志中间件需要捕获请求的基本信息：方法、路径、客户端IP、响应状态码、耗时等。我们可以基于net/http的HandlerFunc模式构建中间件函数。
中间件本质上是一个包装函数，接收http.Handler并返回新的http.Handler，在请求前后插入日志逻辑。
func LoggingMiddleware(next http.Handler) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
start := time.Now()
// 记录请求开始
log.Printf(
"Started %s %s from %s",
r.Method,
r.URL.Path,
r.RemoteAddr,
)
// 包装ResponseWriter以捕获状态码
rw := &responseWriter{ResponseWriter: w, statusCode: 200}
next.ServeHTTP(rw, r)
// 请求结束日志
log.Printf(
"Completed %s %s in %v | Status: %d",
r.Method,
r.URL.Path,
time.Since(start),
rw.statusCode,
)
})
}
// 自定义ResponseWriter以获取状态码
type responseWriter struct {
http.ResponseWriter
statusCode int
}
func (rw *responseWriter) WriteHeader(code int) {
rw.statusCode = code
rw.ResponseWriter.WriteHeader(code)
}
使用结构化日志提升可读性
标准log包输出的是纯文本，不利于后期分析。推荐使用uber-go/zap或rs/zerolog这类高性能结构化日志库。
立即学习“go语言免费学习笔记（深入）”；
以zap为例，改造上述中间件：
func StructuredLoggingMiddleware(log *zap.Logger) func(http.Handler) http.Handler {
return func(next http.Handler) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
start := time.Now()
rw := &responseWriter{ResponseWriter: w, statusCode: 200}
next.ServeHTTP(rw, r)
latency := time.Since(start).Milliseconds() / float64(time.Millisecond)
clientIP := r.Header.Get("X-Forwarded-For")
if clientIP == "" {
clientIP = r.RemoteAddr
}
log.Info("http request",
zap.String("method", r.Method),
zap.String("path", r.URL.Path),
zap.String("client_ip", clientIP),
zap.Int("status_code", rw.statusCode),
zap.Float64("latency_ms", latency),
)
})
}
}
这样输出的日志是JSON格式，便于ELK或Loki等系统采集解析。
集成到主流Web框架
无论使用Gin、Echo还是原生net/http，中间件模式都适用。
Gin框架示例：
r := gin.New()
logger, _ := zap.NewProduction()
r.Use(StructuredGinMiddleware(logger))
func StructuredGinMiddleware(log *zap.Logger) gin.HandlerFunc {
return func(c *gin.Context) {
start := time.Now()
c.Next()
latency := time.Since(start).Seconds()
log.Info("http request",
zap.String("method", c.Request.Method),
zap.String("path", c.Request.URL.Path),
zap.Int("status", c.Writer.Status()),
zap.Float64("latency", latency),
zap.String("client_ip", c.ClientIP()),
)
}
}
日志分级与错误捕获
可结合中间件做错误恢复，并根据状态码决定日志级别。例如4xx用Warn，5xx用Error。
添加defer recover块防止panic中断服务，同时记录错误堆栈。
func RecoveryMiddleware(log *zap.Logger) gin.HandlerFunc {
return func(c *gin.Context) {
defer func() {
if err := recover(); err != nil {
log.Error("request panic",
zap.Any("error", err),
zap.String("stack", string(debug.Stack())),
)
c.AbortWithStatus(http.StatusInternalServerError)
}
}()
c.Next()
}
}
将日志中间件、恢复中间件按顺序注册，就能形成完整的请求处理链。
基本上就这些。一个清晰的日志中间件不需要复杂逻辑，关键是捕获必要字段、结构化输出、合理分级。配合日志轮转和异步写入，可在生产环境稳定运行。
