当前位置：首页 > 文章列表 > Golang > Go教程 > Golang责任链模式请求处理详解

Golang责任链模式请求处理详解

2026-04-12 16:27:34 0浏览收藏

本文深入解析了Go语言中责任链模式的实战实现，展示了如何通过接口抽象、结构体组合与函数式编程三者结合，构建灵活、可动态组装的处理器链——从统一的Handler接口定义，到支持日志、限流、认证等中间件的模块化处理器，再到简洁优雅的函数型Handler和链式组装工具，完整呈现了Go风格责任链的核心思想与工程优势：无需继承、轻量高效、天然契合HTTP中间件与多级校验场景，让请求处理逻辑清晰解耦、易于扩展与复用。

如何在Golang中实现责任链模式处理请求_Golang责任链模式应用实例

在 Go 语言中实现责任链模式，核心是让多个处理器（Handler）按顺序尝试处理请求，每个处理器决定是否处理或把请求传递给下一个。Go 没有类继承，但通过接口 + 组合 + 函数式风格能简洁、高效地实现该模式，且天然契合其并发与中间件场景（如 HTTP 中间件、日志、鉴权等）。

定义统一的 Handler 接口

所有处理器都实现同一个接口，接收请求并返回是否已处理（或继续传递）：

// Request 可以是任意结构体，这里用简单字符串示意
// Handler 是责任链中的节点，返回 true 表示已处理，不再向后传递
type Handler interface {
Handle(request string) bool
}

构建可链式组装的处理器类型

用结构体封装具体逻辑，并支持设置“下一个处理器”，形成链式调用能力：

type AuthHandler struct {
  next Handler
}
func (h *AuthHandler) Handle(request string) bool {
  if strings.Contains(request, "token=valid") {
    fmt.Println("✅ 认证通过")
    return true // 终止链
  } else {
    fmt.Println("❌ 认证失败，交由下一环节")
    if h.next != nil {
      return h.next.Handle(request)
    }
  }
  return false
}
func (h *AuthHandler) SetNext(next Handler) { h.next = next }

支持函数式 Handler（更 Go 风格）

用函数类型替代结构体，提升灵活性和可读性：

type HandlerFunc func(string) bool
func (f HandlerFunc) Handle(request string) bool { return f(request) }

// 快速创建一个日志 Handler
logger := HandlerFunc(func(r string) bool {
  fmt.Printf("[LOG] 收到请求: %s\n", r)
  return false // 不终止，继续传递
})

// 创建限流 Handler
limiter := HandlerFunc(func(r string) bool {
  if len(r) > 100 {
    fmt.Println("⚠️ 请求超长，拒绝")
    return true
  }
  return false
})

组装与执行链（支持动态顺序）

把 Handler 串成链，然后调用首个节点即可：

// 按需组装：日志 → 限流 → 认证 → 业务处理
chain := logger
chain = Chain(chain, limiter)
chain = Chain(chain, &AuthHandler{})
chain = Chain(chain, HandlerFunc(func(r string) bool {
  fmt.Println("? 执行核心业务逻辑")
  return true
}))

// 工具函数：将 a 和 b 连接为 a → b
func Chain(a, b Handler) Handler {
  if h, ok := a.(interface{ SetNext(Handler) }); ok {
    h.SetNext(b)
    return a
  } else if f, ok := a.(HandlerFunc); ok {
    return HandlerFunc(func(r string) bool {
      if f(r) { return true }
      return b.Handle(r)
    })
  }
  return a
}

// 触发处理
chain.Handle("token=valid&user=admin")