Golang观察者模式：事件通知与订阅管理

目前golang学习网上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《Golang实现观察者模式：事件通知与订阅者管理》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

Go中观察者模式通过接口定义Observer.Update(event interface{})实现解耦，Subject用切片维护观察者并加锁保障并发安全，支持函数类型简化订阅、goroutine异步通知及错误处理。

在 Go 语言中实现观察者模式，核心是解耦事件发布者（Subject）与订阅者（Observer），让发布者在状态变化时主动通知所有已注册的订阅者，而无需知道它们的具体类型或行为。Go 没有内置的 interface 继承或多态语法糖，但依靠接口（interface{}）、函数类型、切片和 goroutine，可以简洁高效地实现这一模式。

定义统一的观察者接口

观察者需实现一个通用的通知方法，比如 Update(event interface{})。用接口抽象，便于不同业务逻辑的结构体灵活实现：

  // Observer 定义接收通知的行为
type Observer interface {
    Update(event interface{})
}
  // 示例：日志观察者
type LogObserver struct {}
func (o LogObserver) Update(event interface{}) {
    fmt.Printf("[LOG] 接收到事件: %v\n", event)
}

构建可管理的事件发布者（Subject）

Subject 负责维护观察者列表、提供注册/移除接口，并在触发时遍历调用每个观察者的 Update 方法。为支持并发安全，建议加锁（如 sync.RWMutex）：

type Subject struct {
    observers []Observer
    mu sync.RWMutex
}
func (s *Subject) Register(o Observer) {
    s.mu.Lock()
    defer s.mu.Unlock()
    s.observers = append(s.observers, o)
}
func (s *Subject) Notify(event interface{}) {
    s.mu.RLock()
    defer s.mu.RUnlock()
    for _, o := range s.observers {
        o.Update(event)
    }
}

用函数类型简化轻量级订阅

若观察者逻辑简单（如仅打印或发 HTTP 请求），可跳过接口定义，直接用函数类型作为观察者：

type EventHandler func(event interface{})
type SimpleSubject struct {
    handlers []EventHandler
    mu sync.RWMutex
}
func (s *SimpleSubject) OnEvent(h EventHandler) {
    s.mu.Lock()
    defer s.mu.Unlock()
    s.handlers = append(s.handlers, h)
}
func (s *SimpleSubject) Fire(event interface{}) {
    s.mu.RLock()
    defer s.mu.RUnlock()
    for _, h := range s.handlers {
        h(event)
    }
}
  // 使用示例
subject := &SimpleSubject{}
subject.OnEvent(func(e interface{}) { fmt.Println("✅ 收到:", e) })
subject.Fire("用户登录成功")

支持异步通知与错误处理

避免某个观察者阻塞整个通知流程，可将 Notify 改为异步执行；同时允许观察者返回错误，供发布者按需记录或重试：

• 用 go o.Update(event) 启动 goroutine，注意防止闭包变量误捕获（推荐传参而非引用循环变量）
• 若需等待全部完成，可用 sync.WaitGroup + channel 收集结果
• 观察者接口可扩展为 Update(event interface{}) error，发布者检查返回值并记录
• 对关键业务观察者（如扣款回调），建议增加重试机制与超时控制

好了，本文到此结束，带大家了解了《Golang观察者模式：事件通知与订阅管理》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！