答案：通过zap实现Go语言结构化日志中间件，记录请求方法、路径、IP、状态码、耗时等信息并以JSON格式输出，结合responseWriter包装捕获状态码，根据级别输出日志，支持客户端IP解析及可选优化如排除健康检查路径、链路追踪等，提升服务可观测性。
在Go语言开发中，记录访问日志是服务可观测性的基础。使用结构化日志（如JSON格式）能更好地对接日志收集系统（如ELK、Loki等），便于搜索和分析。通过编写一个结构化日志中间件，可以自动记录每次HTTP请求的关键信息。
结构化日志中间件设计目标
一个实用的访问日志中间件应记录以下信息：
请求方法（GET、POST等） 请求路径和查询参数 客户端IP地址 响应状态码 处理耗时 User-Agent等关键请求头
日志输出为JSON格式，便于后续处理。
使用 zap 实现结构化日志中间件
uber-go/zap 是高性能的结构化日志库，适合生产环境。以下是基于 zap 的中间件实现：
立即学习“go语言免费学习笔记（深入）”；
package mainimport ( "net" "net/http" "net/http/httputil" "strings" "time" "github.com/ulule/limiter/v3" "go.uber.org/zap")// Logger 中间件，记录结构化访问日志func Logger(logger *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() // 获取客户端IP ip := getRealIP(r) // 包装 ResponseWriter 以捕获状态码 rw := &responseWriter{ResponseWriter: w, statusCode: http.StatusOK} // 调用下一个处理器 next.ServeHTTP(rw, r) // 构建日志字段 fields := []zap.Field{ zap.String("method", r.Method), zap.String("path", r.URL.Path), zap.String("query", r.URL.RawQuery), zap.String("ip", ip), zap.String("user_agent", r.Header.Get("User-Agent")), zap.Int("status", rw.statusCode), zap.Duration("duration", time.Since(start)), } // 根据状态码选择日志级别 if rw.statusCode >= 500 { logger.Error("server error", fields...) } else if rw.statusCode >= 400 { logger.Warn("client error", fields...) } else { logger.Info("access", fields...) } }) }}// 获取真实客户端IPfunc getRealIP(r *http.Request) string { xff := r.Header.Get("X-Forwarded-For") if xff != "" { i := strings.Index(xff, ",") if i > 0 { return strings.TrimSpace(xff[:i]) } return xff } xrip := r.Header.Get("X-Real-IP") if xrip != "" { return xrip } ip, _, _ := net.SplitHostPort(r.RemoteAddr) return ip}// 包装 ResponseWriter 以捕获状态码type responseWriter struct { http.ResponseWriter statusCode int}func (rw *responseWriter) WriteHeader(code int) { rw.statusCode = code rw.ResponseWriter.WriteHeader(code)}
在项目中使用中间件
将日志中间件集成到HTTP服务中：
func main() { // 创建 zap 日志实例 logger, _ := zap.NewProduction() defer logger.Sync() mux := http.NewServeMux() mux.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) { w.Write([]byte("Hello, World!")) }) // 应用日志中间件 handler := Logger(logger)(mux) http.ListenAndServe(":8080", handler)}
运行后，访问服务会输出类似以下的JSON日志：
{ "level":"info", "ts":1712345678.123, "caller":"main.go:50", "msg":"access", "method":"GET", "path":"/", "query":"", "ip":"127.0.0.1", "user_agent":"curl/7.68.0", "status":200, "duration":0.000123}
可选优化
可根据实际需求扩展功能：
排除健康检查路径（如 /health）减少日志噪音 记录请求体或响应体（注意性能和隐私） 结合 context 记录 trace ID 实现链路追踪 按日志级别输出到不同文件
基本上就这些。一个简洁高效的结构化日志中间件能显著提升服务的可观测性，zap 提供了性能和功能的平衡，适合大多数Go项目使用。
以上就是怎样用Golang记录访问日志 结构化日志中间件实现的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1397330.html
微信扫一扫 
支付宝扫一扫 
