feat: gzip response.

This commit is contained in:
2025-06-27 09:46:04 +08:00
parent 19148d7d35
commit 0852f4bc23

View File

@ -4,10 +4,12 @@ import (
"compress/gzip" "compress/gzip"
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
"net/http" "net/http"
"strings"
) )
func GzipMiddleware() gin.HandlerFunc { func GzipMiddleware() gin.HandlerFunc {
return func(c *gin.Context) { return func(c *gin.Context) {
// 1. 处理请求解压
if c.Request.Header.Get("Content-Encoding") == "gzip" { if c.Request.Header.Get("Content-Encoding") == "gzip" {
gzReader, err := gzip.NewReader(c.Request.Body) gzReader, err := gzip.NewReader(c.Request.Body)
if err != nil { if err != nil {
@ -17,6 +19,39 @@ func GzipMiddleware() gin.HandlerFunc {
defer gzReader.Close() defer gzReader.Close()
c.Request.Body = gzReader c.Request.Body = gzReader
} }
// 2. 设置响应压缩支持
if strings.Contains(c.Request.Header.Get("Accept-Encoding"), "gzip") {
// 创建gzip writer
gzWriter := gzip.NewWriter(c.Writer)
defer gzWriter.Close()
// 替换原始writer为压缩writer
originalWriter := c.Writer
c.Writer = &gzipResponseWriter{
ResponseWriter: originalWriter,
gzWriter: gzWriter,
}
// 设置响应头
c.Header("Content-Encoding", "gzip")
c.Header("Vary", "Accept-Encoding")
}
c.Next() c.Next()
} }
} }
// 自定义ResponseWriter实现gzip压缩
type gzipResponseWriter struct {
gin.ResponseWriter
gzWriter *gzip.Writer
}
func (w *gzipResponseWriter) Write(data []byte) (int, error) {
return w.gzWriter.Write(data)
}
func (w *gzipResponseWriter) WriteString(s string) (int, error) {
return w.gzWriter.Write([]byte(s))
}