Golang中介者与观察者模式实现教程

本文深入讲解了如何在Go语言中巧妙结合中介者与观察者模式，构建高内聚、低耦合的事件驱动系统：中介者作为中央调度员统一管理注册、请求处理与事件分发，观察者仅通过简洁的Update方法响应感兴趣的通知；借助sync.RWMutex保障并发安全，配合goroutine异步通知和可选的谓词过滤机制，既轻量高效又易于扩展——新增组件只需实现Observer并注册事件，修改交互逻辑仅需调整中介者，彻底解耦业务对象，显著提升系统可维护性与伸缩性。

用 Go 实现中介者 + 观察者组合模式，核心是让中介者（Mediator）作为“中央调度员”，既协调各组件间的交互，又充当观察者模式中的事件分发中心——组件只与中介者通信，不互相依赖；同时中介者在状态变化时主动通知所有订阅者。

中介者接口设计：统一收发与注册

中介者需提供注册观察者、触发事件、转发请求三类能力。Go 中用接口定义契约，避免强耦合：

• 定义 Mediator 接口，含 RegisterObserver、Notify、HandleRequest 方法
• 观察者实现 Observer 接口，仅声明 Update(event string, data interface{})
• 中介者内部用 map[string][]Observer 按事件类型分类存储订阅者，支持多事件多播

具体组件解耦：通过中介者通信

各业务组件（如 User、ChatRoom、NotificationService）不再直接调用彼此，而是：

• 初始化时向中介者注册自身为某类事件的观察者（例如 User 注册接收 “message_sent”）
• 执行动作时调用中介者的 HandleRequest，传入操作类型和参数（如 mediator.HandleRequest("send_message", msg)）
• 中介者根据请求类型执行逻辑（如校验、持久化），再调用 Notify("message_sent", msg) 广播

事件通知机制：轻量且线程安全

Go 原生支持并发，但观察者列表读写需保护。推荐方式：

• 用 sync.RWMutex 保护观察者映射，注册/注销用写锁，通知遍历时用读锁
• 通知时启动 goroutine 异步分发（避免某个观察者阻塞整体），但注意控制并发数或使用带缓冲 channel 限流
• 可扩展支持事件过滤：观察者注册时传入 predicate 函数，中介者通知前做条件匹配

完整示例关键片段

一个简化的聊天场景：

• User 结构体实现 Observer，收到 "user_joined" 时刷新联系人列表
• ChatMediator 实现 Mediator，HandleRequest("join", user) 会保存用户并 Notify("user_joined", user)
• 所有 User 实例已在初始化时调用 mediator.RegisterObserver("user_joined", u)
• 新增 NotificationService 同样监听 "message_sent"，自动推送手机通知——无需修改 User 或 ChatMediator 代码

这种组合让系统扩展性强：加新组件只需实现 Observer 并注册事件；改交互逻辑只动中介者，不碰业务对象。不复杂但容易忽略的是事件命名规范和生命周期管理——比如观察者退出时要反注册，否则引发 panic 或内存泄漏。

以上就是《Golang中介者与观察者模式实现教程》的详细内容，更多关于的资料请关注golang学习网公众号！