Go中观察者模式通过Subject管理Observer切片实现解耦，支持接口、函数类型、同步/异步通知及线程安全；可封装为OrderManager等业务结构，配合EmailNotifier等具体观察者响应状态变更。
用 Go 实现观察者模式管理订阅关系，核心是解耦“状态持有者”（Subject）和“监听者”（Observer），让状态变更时自动通知所有已注册的观察者。Go 没有内置接口继承或泛型约束（旧版本），但借助接口、切片、函数类型和 goroutine，可以写出简洁、线程安全、易扩展的实现。
定义 Observer 接口与 Subject 管理结构
观察者只需实现一个通知方法；Subject 则维护观察者列表，并提供注册、注销、通知能力：
（Go 1.18+ 推荐用泛型，但基础版更通用）
// 观察者接口：收到状态变更时被调用
type Observer interface {
Update(data interface{})
}
// 主题：持有状态并管理观察者
type Subject struct {
observers []Observer
mu sync.RWMutex
}
func (s *Subject) Register(obs Observer) {
s.mu.Lock()
defer s.mu.Unlock()
s.observers = append(s.observers, obs)
}
func (s *Subject) Unregister(obs Observer) {
s.mu.Lock()
defer s.mu.Unlock()
for i, o := range s.observers {
if o == obs {
s.observers = append(s.observers[:i], s.observers[i+1:]...)
break
}
}
}
func (s *Subject) Notify(data interface{}) {
s.mu.RLock()
// 复制一份避免遍历时被修改（如某 observer 内部调用 Unregister）
obsCopy := make([]Observer, len(s.observers))
copy(obsCopy, s.observers)
s.mu.RUnlock()
for _, obs := range obsCopy {
obs.Update(data)
}
}
用函数类型简化轻量级观察者
不必为每个观察逻辑都定义结构体，直接用函数实现 Observer 接口更灵活：
立即学习“go语言免费学习笔记（深入）”；
type FuncObserver func(data interface{})
func (f FuncObserver) Update(data interface{}) {
f(data)
}
// 使用示例
sub := &Subject{}
sub.Register(FuncObserver(func(data interface{}) {
fmt.Println("收到更新：", data)
}))
sub.Notify("订单已支付")
这种方式适合事件日志、指标上报、简单回调等场景，代码零冗余。
支持异步通知与错误隔离
避免某个观察者阻塞或 panic 影响其他观察者，可启动 goroutine 并 recover：
func (s *Subject) NotifyAsync(data interface{}) {
s.mu.RLock()
obsCopy := make([]Observer, len(s.observers))
copy(obsCopy, s.observers)
s.mu.RUnlock()
for _, obs := range obsCopy {
go func(o Observer) {
defer func() {
if r := recover(); r != nil {
log.Printf("observer panic: %v", r)
}
}()
o.Update(data)
}(obs)
}
}
注意：异步通知不保证执行顺序，也不适合依赖通知结果的业务逻辑（如事务后置校验），此时应同步调用 + 超时控制。
结合具体业务：订单状态管理示例
把 Subject 封装为 OrderManager，状态变更时触发不同行为：
type OrderManager struct {
Subject
status string
}
func (m *OrderManager) SetStatus(newStatus string) {
m.status = newStatus
m.Notify(map[string]string{
"event": "status_changed",
"order": "ORD-1001",
"from": m.status,
"to": newStatus,
})
}
// 注册邮件通知观察者
type EmailNotifier struct{ email string }
func (n EmailNotifier) Update(data interface{}) {
if d, ok := data.(map[string]string); ok && d["event"] == "status_changed" {
fmt.Printf("发送邮件到 %s：订单 %s 已变为 %s\n", n.email, d["order"], d["to"])
}
}
// 使用
mgr := &OrderManager{}
mgr.Register(EmailNotifier{email: "admin@example.com"})
mgr.Register(FuncObserver(func(d interface{}) {
log.Printf("审计日志：%v", d)
}))
mgr.SetStatus("shipped") // 自动触发两个观察者
不复杂但容易忽略：实际项目中建议给 Subject 增加 context 支持、通知限流、观察者超时取消机制，以及用 map[Observer]struct{} 替代切片提升注销效率（需额外锁保护）。核心在于让通知逻辑与业务逻辑真正分离，状态变更即“发布”，其余由观察者各自“订阅”响应。
