Golang责任链模式在中间件中的应用

Go中间件天然适合责任链模式,因其函数签名func(https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler) https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler直接体现“接收并返回https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler”的链式调用结构,无需额外抽象,通过函数组合即可实现干净的链式组装。

Go 中间件为什么天然适合责任链模式//www./link/d3d92bc35d062c83f89b7ea87d99dca93>

因为 Go 的 https://www./link/d3d92bc35d062c83f89b7ea87d99dca9TTP 中间件函数签名统一为 func(https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler) https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler,本质就是接收一个 https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler、返回一个新 https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler,这和责任链里“上一节点调用下一节点”的结构完全吻合——每个中间件只关心自己该做的事,再把请求交给 next 处理。

不需要额外封装接口或抽象基类,也不用维护显式的 next 指针。链的组装靠函数组合完成,干净又符合 Go 的惯用法。

如何手动串联多个中间件而不依赖框架//www./link/d3d92bc35d062c83f89b7ea87d99dca93>

核心是把中间件看作高阶函数,用闭包捕获 next,再通过嵌套调用形成链。顺序决定执行先后:最外层中间件最先被调用,最内层(原始 https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler)最后执行。

  • loggerauthttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9rateLimithttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler 表示日志总在最前,鉴权其次,限流再后,业务逻辑最后
  • 错误提前中断时,不要调用 next.Servehttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9TTP,但要注意是否需清理资源或写响应头
  • 避免在中间件里直接 return 后忘记写状态码和 body,导致客户端卡住(常见于忘记调用 w.Writehttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9eader()w.Write()
func logger(next https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler) https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler {
    return https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andlerFunc(func(w https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.ResponseWriter, r *https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.Request) {
        log.Printf("START %s %s", r.Methttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9od, r.URL.Pathttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9)
        next.Servehttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9TTP(w, r)
        log.Printf("END %s %s", r.Methttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9od, r.URL.Pathttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9)
    })
}

func authttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9(next https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler) https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler { return https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andlerFunc(func(w https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.ResponseWriter, r *https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.Request) { token := r.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9eader.Get("Authttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9orization") if token == "" { https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.Error(w, "Unauthttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9orized", https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.StatusUnauthttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9orized) return // 中断链,不调用 next } next.Servehttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9TTP(w, r) }) }

// 使用:https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler = logger(authttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9(rateLimit(myhttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler)))

立即学习“go语言免费学习笔记(深入)”;

使用 net/https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp 原生方式实现可插拔的责任链//www./link/d3d92bc35d062c83f89b7ea87d99dca93>

Go 标准库没提供链式注册 API,但可以自己定义一个 Mux 类型来聚合中间件,让路由注册更清晰。关键不是“自动链”,而是控制中间件注入时机和作用范围。

  • 全局中间件:包装 https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.DefaultServeMux 或自定义 https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.ServeMux
  • 路由级中间件:对某个路径前缀单独套一层链,比如 /api/ 下全走鉴权,而 /public/ 不走
  • 注意 https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.ServeMux 本身不支持中间件,必须在 https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andle 之前手动 wrap
type Chttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9ain struct {
    middlewares []func(https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler) https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler
}

func (c *Chttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9ain) Use(mw func(https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler) https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler) { c.middlewares = append(c.middlewares, mw) }

func (c *Chttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9ain) Thttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9en(https://www./link/d3d92bc35d062c83f89b7ea87d99dca9 https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler) https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler { for i := len(c.middlewares) - 1; i >= 0; i-- { https://www./link/d3d92bc35d062c83f89b7ea87d99dca9 = c.middlewaresi } return https://www./link/d3d92bc35d062c83f89b7ea87d99dca9 }

// 用法: chttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9ain := &Chttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9ain{} chttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9ain.Use(logger) chttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9ain.Use(authttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9) https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andle("/api/", chttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9ain.Thttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9en(https://www./link/d3d92bc35d062c83f89b7ea87d99dca9ttp.https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andlerFunc(apihttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler)))

容易被忽略的上下文传递与性能隐患//www./link/d3d92bc35d062c83f89b7ea87d99dca93>

责任链中跨中间件传参不能靠全局变量或闭包捕获请求数据(并发不安全),必须用 context.Context;但频繁创建子 context、反复调用 Withttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9Value 会有分配开销,尤其在高频接口中。

  • 只存必要字段,如 userIDrequestID,别塞整个 struct 或 map
  • context.Withttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9Value 前先定义 key 类型(避免字符串冲突),例如 type ctxKey string; const userIDKey ctxKey = "user_id"
  • 中间件里修改 response writer(如加 https://www./link/d3d92bc35d062c83f89b7ea87d99dca9eader)要小心:一旦 Writehttps://www./link/d3d92bc35d062c83f89b7ea87d99dca9eader 被调用,后续写操作可能被静默丢弃

链越长,函数调用栈越深,虽不影响正确性,但在 pprof 中会看到明显嵌套。如果某中间件耗时突增,排查时得从链尾往前逆推,而不是只盯最后一个 https://www./link/d3d92bc35d062c83f89b7ea87d99dca9andler。