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

Golang ChainOfResponsibility责任链模式请求处理实践

P粉602998670

发布： 2025-10-03 17:16:02

原创

649人浏览过

责任链模式通过将请求沿处理链传递实现解耦，Go中可用接口与结构体组合实现，如认证、权限、校验流程；每个处理器决定是否处理或转发请求，支持动态扩展与灵活组装，适用于中间件、审批流等场景。

golang chainofresponsibility责任链模式请求处理实践

在 Go 语言中，责任链模式（Chain of Responsibility Pattern）是一种行为设计模式，它允许你将请求沿着处理者对象组成的链传递，直到某个对象处理它为止。这种模式常用于构建灵活、可扩展的请求处理流程，比如中间件系统、审批流、日志处理等场景。

责任链模式的核心思想

责任链模式的关键在于解耦请求发送者和接收者。每个处理节点都持有对下一个处理者的引用，当一个节点无法处理请求时，会将其转发给下一个节点。这样可以在不修改原有代码的前提下动态添加或调整处理逻辑。

在 Golang 中，我们可以通过接口和结构体组合来实现这一模式，结合函数式编程的思想还能让代码更简洁。

定义处理器接口与基础结构

首先定义一个通用的处理器接口：

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

type Handler interface {
    SetNext(handler Handler) Handler
    Handle(request string) string
}

登录后复制

每个处理器需要能设置下一个处理器，并决定是否处理当前请求。为了简化链式调用，SetNext 返回 Handler 类型便于链式写法。

接下来实现一个基础抽象结构，避免每个处理器重复写 SetNext 的逻辑：

type BaseHandler struct {
    next Handler
}

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

func (b *BaseHandler) Handle(request string) string {
    if b.next != nil {
        return b.next.Handle(request)
    }
    return ""
}

登录后复制

具体处理器实现

现在可以基于 BaseHandler 实现具体的业务处理器。例如，构建一个模拟 API 请求处理流程：身份验证 → 权限检查 → 数据校验。

ListenLeap

AI辅助通过播客学英语

101

查看详情

// 认证处理器
type AuthHandler struct {
    BaseHandler
}

func (a *AuthHandler) Handle(request string) string {
    if containsToken(request) {
        return "认证通过 -> " + a.BaseHandler.Handle(request)
    }
    return "拒绝：缺少有效令牌"
}

// 权限处理器
type PermissionHandler struct {
    BaseHandler
}

func (p *PermissionHandler) Handle(request string) string {
    if hasPermission(request) {
        return "权限检查通过 -> " + p.BaseHandler.Handle(request)
    }
    return "拒绝：权限不足"
}

// 数据校验处理器
type ValidationHandler struct {
    BaseHandler
}
 
func (v *ValidationHandler) Handle(request string) string {
    if isValidData(request) {
        return "数据校验通过 -> 请求已处理"
    }
    return "拒绝：数据无效"
}

登录后复制

辅助函数示例：

func containsToken(req string) bool {
    return strings.Contains(req, "token")
}

func hasPermission(req string) bool {
    return strings.Contains(req, "admin")
}

func isValidData(req string) bool {
    return len(strings.TrimSpace(req)) > 5
}

登录后复制

使用责任链组装处理流程

在 main 函数或其他调用处，按顺序组装处理器链：

func main() {
    auth := &AuthHandler{}
    perm := &PermissionHandler{}
    valid := &ValidationHandler{}

    // 组装责任链
    auth.SetNext(perm).SetNext(valid)

    // 发起请求
    req := "token=admin&action=create"
    result := auth.Handle(req)
    fmt.Println(result) // 输出：认证通过 -> 权限检查通过 -> 数据校验通过 -> 请求已处理

    // 测试中断情况
    badReq := "action=delete"
    result2 := auth.Handle(badReq)
    fmt.Println(result2) // 输出：拒绝：缺少有效令牌
}

登录后复制

这个例子展示了如何通过责任链控制请求流程。任何一个环节失败都会终止后续处理，而成功则继续传递。

实际应用场景建议

责任链非常适合以下场景：

Web 框架中间件：如 Gin 或 Echo 中的 middleware 链，每个中间件可做日志、鉴权、限流等。
审批流程：请假申请依次经过主管、HR、财务审批。
事件处理器：GUI 事件冒泡机制，或消息路由系统。
日志级别处理：DEBUG、INFO、ERROR 各自对应不同处理器。

在 Go 中还可以用函数类型实现更轻量的责任链：

type HandlerFunc func(string, func(string) string) string

func Chain(handlers ...HandlerFunc) HandlerFunc {
    return func(req string, next func(string) string) string {
        if len(handlers) == 0 {
            if next != nil {
                return next(req)
            }
            return "处理完成"
        }
        head := handlers[0]
        tail := handlers[1:]
        return head(req, func(r string) string {
            nh := Chain(tail...)
            return nh(r, next)
        })
    }
}

登录后复制

这种方式更加灵活，适合中间件风格的编程。

基本上就这些。Golang 实现责任链模式简单高效，关键是明确职责划分和链的构建方式。根据项目复杂度选择结构体还是函数式实现，都能达到良好的解耦效果。

以上就是Golang ChainOfResponsibility责任链模式请求处理实践的详细内容，更多请关注php中文网其它相关文章！