如何使用Golang实现中间件日志记录_Golang Web中间件日志管理实践-Golang-PHP中文网

如何使用Golang实现中间件日志记录_Golang Web中间件日志管理实践

P粉602998670

发布： 2025-11-14 08:41:03

原创

262人浏览过

答案：通过Golang中间件捕获请求信息并使用zap实现结构化日志。1. 设计基础中间件记录方法、路径、IP、状态码和耗时；2. 使用自定义ResponseWriter获取响应状态；3. 集成zap输出JSON格式日志；4. 在Gin等框架中注册中间件；5. 结合错误恢复与分级记录提升可观测性。

如何使用golang实现中间件日志记录_golang web中间件日志管理实践

在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等系统采集解析。

美间AI

美间AI：让设计更简单

查看详情

集成到主流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()
    }
}

登录后复制

将日志中间件、恢复中间件按顺序注册，就能形成完整的请求处理链。

基本上就这些。一个清晰的日志中间件不需要复杂逻辑，关键是捕获必要字段、结构化输出、合理分级。配合日志轮转和异步写入，可在生产环境稳定运行。

以上就是如何使用Golang实现中间件日志记录_Golang Web中间件日志管理实践的详细内容，更多请关注php中文网其它相关文章！