Go语言中职责链模式通过函数式风格实现过滤器链，核心是将多个Filter函数串联处理请求。首先定义Filter类型为func(string) string，再通过Chain函数将多个过滤器组合，依次执行日志、验证、认证等逻辑。每个过滤器可修改或拦截请求，如AuthFilter检查权限，ValidateFilter校验输入。实际使用时，调用chain("request_with_auth")触发整条链执行，输出各阶段结果；若某环节失败则中断并返回错误。为支持中断，可扩展为InterruptibleFilter，返回(string, bool)控制是否继续。该模式适用于中间件、API网关等场景，逻辑解耦且易于扩展。
在Go语言中，职责链模式（Chain of Responsibility）非常适合用来实现过滤器处理流程，比如中间件、请求校验、日志记录等场景。它的核心思想是将多个处理对象串联成一条链，请求沿着链传递，每个节点决定是否处理或继续传递。
定义处理器接口
为了构建职责链，先定义一个统一的接口，表示每个过滤器的行为：
type Handler interface {
Handle(request string) string
}
或者更灵活的方式是使用函数类型来定义处理器，这样可以更方便地组合和扩展：
type Filter func(string) string
构建过滤器链
通过函数式方式将多个过滤器串联起来。每个过滤器完成自己的任务后，调用下一个过滤器：
立即学习“go语言免费学习笔记（深入）”；
func Chain(filters ...Filter) Filter {
return func(input string) string {
for _, f := range filters {
input = f(input)
}
return input
}
}
接下来定义几个具体的过滤器示例：
func LoggingFilter() Filter {
return func(input string) string {
fmt.Println("Logging:", input)
return input
}
}
func AuthFilter() Filter {
return func(input string) string {
if !strings.Contains(input, "auth") {
return "Unauthorized"
}
return input
}
}
func ValidateFilter() Filter {
return func(input string) string {
if len(input) == 0 {
return "Invalid request"
}
return input
}
}
实际使用示例
将多个过滤器组合成一条处理链，并传入请求数据：
func main() {
chain := Chain(
LoggingFilter(),
ValidateFilter(),
AuthFilter(),
)
result := chain("request_with_auth")
fmt.Println("Final result:", result)
}
输出会依次显示日志、验证通过、认证通过的结果。如果输入不符合条件，比如空字符串或缺少 auth 标记，链中的某个环节就会中断并返回错误信息。
支持中断的变体设计
有时需要在某个过滤器中终止后续处理，可以通过返回布尔值控制是否继续：
type InterruptibleFilter func(string) (string, bool)
func InterruptibleChain(filters ...InterruptibleFilter) InterruptibleFilter {
return func(input string) (string, bool) {
for _, f := range filters {
result, cont := f(input)
if !cont {
return result, false
}
input = result
}
return input, true
}
}
这种结构更适合权限拦截、异常提前返回等场景。
基本上就这些。用函数式风格写职责链，简洁又灵活，特别适合Go的中间件、API网关、请求预处理等过滤场景。关键是把每个过滤逻辑拆解独立，再按需组装成链。
