Golang ChainOfResponsibility请求链处理模式实践-Golang-PHP中文网

Golang ChainOfResponsibility请求链处理模式实践

P粉602998670

发布： 2025-09-28 21:09:02

原创

613人浏览过

责任链模式通过将处理器串联实现请求的链式处理，Go中以接口与结构体组合构建日志、权限、校验等中间件流程，解耦发送者与接收者，提升灵活性，适用于多对象处理同一请求且需动态指定处理顺序的场景。

golang chainofresponsibility请求链处理模式实践

在Go语言开发中，当需要对一个请求进行多层判断或处理时，Chain of Responsibility（责任链）模式是一个非常实用的设计模式。它将多个处理器串联起来，让请求沿着链传递，直到被某个处理器处理为止。这种模式解耦了请求发送者和接收者，提升了系统的灵活性和可扩展性。

什么是责任链模式

责任链模式属于行为型设计模式，它的核心思想是：把多个处理器（Handler）像链条一样连接起来，每个处理器都拥有一个指向下一个处理器的引用。当请求到达时，第一个处理器尝试处理，如果无法处理则交给下一个，直到被处理或链结束。

适用场景包括：

有多个对象可以处理同一请求，但具体由谁处理运行时决定
希望动态地指定一组处理对象
需要解耦请求的发送方和接收方

Go中的责任链实现示例

下面通过一个HTTP中间件风格的日志、权限、参数校验流程来演示责任链的实现。

必应图像创建器

微软必应出品的AI绘图工具

593

查看详情

立即学习“go语言免费学习笔记（深入）”；

// 定义请求结构体
type Request struct {
  Path string
  User string
  Valid bool
}

// 处理器接口
type Handler interface {
  SetNext(handler Handler) Handler
  Handle(req *Request) bool
}

// 基础处理器结构
type BaseHandler struct {
  next Handler
}

func (h *BaseHandler) SetNext(handler Handler) Handler {
  h.next = handler
  return handler
}

func (h *BaseHandler) PassToNext(req *Request) bool {
  if h.next == nil {
    return true // 链条结束，继续
  }
  return h.next.Handle(req)
}

// 日志处理器
type LoggerHandler struct {
  BaseHandler
}

func (l *LoggerHandler) Handle(req *Request) bool {
  fmt.Printf("日志记录: 用户 %s 访问路径 %s\n", req.User, req.Path)
  return l.PassToNext(req)
}

// 权限校验处理器
type AuthHandler struct {
  BaseHandler
}

func (a *AuthHandler) Handle(req *Request) bool {
  if req.User == "" {
    fmt.Println("权限拒绝：未登录用户")
    return false
  }
  fmt.Println("权限校验通过")
  return a.PassToNext(req)
}

// 参数校验处理器
type ValidationHandler struct {
  BaseHandler
}

func (v *ValidationHandler) Handle(req *Request) bool {
  if !req.Valid {
    fmt.Println("参数校验失败")
    return false
  }
  fmt.Println("参数校验通过")
  return v.PassToNext(req)
}

// 使用示例
func main() {
  logger := &LoggerHandler{}
  auth := &AuthHandler{}
  validation := &ValidationHandler{}

  // 构建链
  logger.SetNext(auth).SetNext(validation)

  req := &Request{
    Path: "/api/user",
    User: "alice",
    Valid: true,
  }

  success := logger.Handle(req)
  if success {
    fmt.Println("请求处理完成")
  } else {
    fmt.Println("请求被拦截")
  }
}