Go中责任链模式通过HandlerFunc函数类型或Handler接口定义统一契约,用Chain结构体切片动态管理处理器,支持Use/UseFront/Remove操作,Build方法返回闭包实现链式调用,节点如日志、校验、缓存、熔断各司其职。

在 Go 语言中实现责任链模式,核心是让请求沿一条处理器链依次传递,每个节点决定是否处理或继续转发;链的结构应支持运行时动态插入/移除节点,同时保持类型安全和低耦合。
定义统一的处理器接口
所有链节点需实现同一行为契约。推荐使用函数类型或接口,Go 中更倾向简洁的函数签名:
- 定义 HandlerFunc 类型:`type HandlerFunc func(ctx context.Context, req interface{}) (resp interface{}, err error)`
- 或定义接口(适合需附加状态的场景):
type Handler interface { Handle(ctx context.Context, req interface{}) (interface{}, error) } - 为接口提供默认的链式调用方法(如
Next字段或组合方式),但 Go 更常用组合而非继承,因此通常由链管理器统一调度
构建可动态扩展的链管理器
用切片维护处理器列表,暴露 Use、UseFront、Remove 等方法,支持运行时增删节点:
- 定义链结构:
type Chain struct { handlers []HandlerFunc } -
Use(h HandlerFunc)在末尾追加处理器 -
UseFront(h HandlerFunc)在开头插入,适用于前置校验类逻辑(如鉴权) -
Build()返回一个闭包处理器:遍历 handlers,逐个调用,任一返回非 nil error 或非 nil resp 即终止并返回
实现典型链节点示例
每个节点专注单一职责,不依赖后续节点存在:
立即学习“go语言免费学习笔记(深入)”;
- 日志节点:打印请求信息,调用 next 后再记录响应耗时
- 参数校验节点:检查 req 是否为 *User,字段是否非空,不符合则直接返回错误,不调用 next
- 缓存节点:先查 Redis,命中则直接返回,未命中才调用 next 并缓存结果
- 熔断节点:基于计数器或滑动窗口判断是否允许通行,拒绝时直接返回 fallback
实际调用与链装配
链的组装应在初始化阶段完成,但支持热更新(如监听配置变更后重建链):
- 初始化:
chain := NewChain().Use(AuthHandler).Use(ValidateHandler).Use(CacheHandler) - 生成最终处理器:
handler := chain.Build() - 使用:
resp, err := handler(context.Background(), userReq) - 若需动态添加(如灰度开关启用某节点):
chain.Use(NewMetricHandler()) // 无需重启服务










