当前位置：首页 > 文章列表 > Golang > Go教程 > 责任链与中介者模式在Go中的应用

责任链与中介者模式在Go中的应用

2025-12-29 12:10:35 0浏览收藏

“纵有疾风来，人生不言弃”，这句话送给正在学习Golang的朋友们，也希望在阅读本文《责任链与中介者模式在Go中的链式请求实现》后，能够真的帮助到大家。我也会在后续的文章中，陆续更新Golang相关的技术文章，有好的建议欢迎大家在评论留言，非常感谢！

责任链与中介者模式协同使用：责任链负责请求逐级处理与传递，中介者解耦节点、统一协调流程与状态，支持动态注册、顺序调整、上下文共享及条件分支。

如何在Golang中实现责任链+中介者模式_链式请求与中心协调

在 Go 语言中，责任链（Chain of Responsibility）和中介者（Mediator）模式可以协同使用：责任链负责请求的**逐级处理与传递**，中介者则负责**解耦各处理节点、统一协调流程与状态**。这种组合特别适合需要灵活扩展处理步骤、又要求节点间低耦合、流程可控的场景（如 API 请求预处理、工作流引擎、消息路由等）。

核心设计思路：分离“流转逻辑”与“协调逻辑”

责任链本身是线性的、静态的调用链；而中介者引入后，可动态注册/移除处理器、修改执行顺序、注入共享上下文、甚至根据运行时状态跳过或分支处理——链不再硬编码，而是由中介者驱动。

关键点：

每个处理器（Handler）不直接引用下一个 Handler，而是通过中介者获取后续动作
中介者持有所有已注册的处理器，并管理它们的执行顺序与依赖关系
请求对象（Request）需携带可变上下文（如 Context、Map、或自定义 Payload），供各 Handler 读写

基础结构定义：Handler 接口与 Mediator 核心

定义统一的处理器接口，接收请求并返回是否继续流转：

// Handler 处理器接口，返回 true 表示继续传递，false 表示终止
type Handler interface {
  Handle(req *Request) bool
}

// Request 是可扩展的请求载体，支持键值上下文
type Request struct {
  Data map[string]interface{}
  ctx context.Context
}
func NewRequest() *Request {
  return &Request{Data: make(map[string]interface{})}
}

// Mediator 中介者，集中管理 Handler 生命周期与执行逻辑
type Mediator struct {
  handlers []Handler
  order map[string]int // 可选：支持按名称排序或条件跳转
}
func NewMediator() *Mediator {
  return &Mediator{handlers: make([]Handler, 0), order: make(map[string]int)}
}
func (m *Mediator) Register(h Handler) {
  m.handlers = append(m.handlers, h)
}
func (m *Mediator) Handle(req *Request) {
  for _, h := range m.handlers {
    if !h.Handle(req) {
      break
    }
  }
}

实战示例：API 请求的链式校验 + 中心日志/熔断协调

假设一个 HTTP 请求需依次做：鉴权 → 限流 → 参数校验 → 缓存检查。其中限流和缓存需共享 Redis 客户端，熔断状态需全局感知——这些共享资源与策略不应由 Handler 自行管理，而交由 Mediator 统一注入。

实现方式：

Mediator 初始化时注入 Redis 客户端、熔断器、Logger 等共享依赖
每个 Handler 通过构造函数接收 Mediator 实例（或只接收所需依赖），避免强耦合
Handler 内部可调用 mediator.GetCache() 或 mediator.IsCircuitOpen() 等协调方法
中介者还可提供 Before/After 钩子，在整条链前后执行审计或指标上报

例如限流 Handler：

// RateLimitHandler 使用中介者提供的限流器
type RateLimitHandler struct {
  mediator *Mediator
}
func NewRateLimitHandler(m *Mediator) *RateLimitHandler {
  return &RateLimitHandler{mediator: m}
}
func (h *RateLimitHandler) Handle(req *Request) bool {
  if !h.mediator.RateLimiter.Allow(req.Data["client_id"].(string)) {
    req.Data["error"] = "rate limited"
    return false
  }
  return true
}