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 请求），可跳过接口定义，直接用函数类型作为观察者：
立即学习“go语言免费学习笔记（深入）”；
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，发布者检查返回值并记录 - 对关键业务观察者（如扣款回调），建议增加重试机制与超时控制
