如何使用Golang实现观察者模式管理订阅关系_状态变更自动通知

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 已变为 %sn", 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{} 替代切片提升注销效率（需额外锁保护）。核心在于让通知逻辑与业务逻辑真正分离，状态变更即“发布”，其余由观察者各自“订阅”响应。