Golang实现简单的请求日志中间件

Go HTTP日志中间件需包装ResponseWriter捕获状态码，用time.Now和defer统计耗时，通过X-Forwarded-For等头获取真实IP并校验，日志异步化防阻塞，避免序列化大body。

Go HTTP 中间件怎么记录请求基础信息

直接用 http.Handler 包一层就能实现日志中间件，不需要第三方库。核心是拦截 http.ResponseWriter，在写入响应前记录状态码、耗时、路径等。

注意：不能直接读取原始 ResponseWriter 的状态码，得用自定义结构体包装它，重写 WriteHeader 方法来捕获实际返回的状态码。

• 必须包装 ResponseWriter，否则拿不到真实 StatusCode
• 用 time.Now() 记开始时间，defer 算耗时，避免漏统计
• 日志建议用 log.Printf 或结构化日志库（如 zerolog），别用 fmt.Println

如何获取客户端真实 IP（尤其 Nginx 反向代理后）

直接读 r.RemoteAddr 在有反向代理时会得到 127.0.0.1:xxxx，不可用。应优先检查 X-Forwarded-For 头，但要注意该头可被伪造，生产环境需配合 X-Real-IP 或信任的代理 IP 段做校验。

• r.Header.Get("X-Forwarded-For") 返回逗号分隔的 IP 列表，取第一个（最左）通常是客户端真实 IP
• 若使用 Nginx，确保配置了 proxy_set_header X-Forwarded-For $remote_addr;
• 更安全的做法：只信任内网 IP 发来的 X-Forwarded-For，其他情况回落到 r.RemoteAddr 解析出 IP

中间件里怎么避免阻塞主处理逻辑

日志本身是 I/O 操作，但同步写文件或网络日志服务可能拖慢请求。简单场景下同步写 os.Stderr 或 log.Logger 是可接受的；高并发时建议异步提交日志（例如发到 channel 由 goroutine 消费）。

• 不要在中间件里调用 time.Sleep、http.Get 等阻塞操作
• 避免在日志中序列化大体积请求体（r.Body）或响应体——默认不读、不复制
• 如果真要记录 body，需用 io.TeeReader / io.MultiWriter 做透传，且限制最大长度（防 OOM）

func loggingMiddleware(next http.Handler) http.Handler {
	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		start := time.Now()
		lw := &responseWriter{ResponseWriter: w, statusCode: http.StatusOK}
		
		next.ServeHTTP(lw, r)
		
		ip := getClientIP(r)
		duration := time.Since(start).Microseconds()
		
		log.Printf(
			"[%s] %s %s %d %dµs %s",
			time.Now().Format("2006-01-02T15:04:05Z"),
			r.Method,
			r.URL.Path,
			lw.statusCode,
			duration,
			ip,
		)
	})
}

type responseWriter struct {
	http.ResponseWriter
	statusCode int
}

func (rw *responseWriter) WriteHeader(code int) {
	rw.statusCode = code
	rw.ResponseWriter.WriteHeader(code)
}

func getClientIP(r *http.Request) string {
	if ip := r.Header.Get("X-Forwarded-For"); ip != "" {
		return strings.TrimSpace(strings.Split(ip, ",")[0])
	}
	if ip := r.Header.Get("X-Real-IP"); ip != "" {
		return ip
	}
	return strings.Split(r.RemoteAddr, ":")[0]
}

注意 responseWriter 没有实现 Flush、Hijack 等方法，如果下游 handler 用到了流式响应（比如 SSE），需要补全这些接口，否则 panic。