Go实现观察者模式需定义Observer和Subject接口，用切片存储监听器、sync.RWMutex保障并发安全，支持动态注册/移除；Notify中应避免锁内耗时操作或panic，可异步处理并recover隔离错误。
用 Go 实现观察者模式，核心是定义事件源（Subject）和监听器（Observer），通过接口解耦、切片管理订阅者，并支持动态注册/移除。Go 没有内置的 event emitter，但靠简洁的接口和并发安全设计，能写出轻量、易维护的事件系统。
定义 Observer 和 Subject 接口
先抽象出监听器行为和事件源能力，避免强依赖具体类型：
-
Observer：定义一个
Update(event interface{})方法，所有监听器都实现它 -
Subject：提供
Register(o Observer)、Deregister(o Observer)和Notify(event interface{})方法
这样后续增删监听逻辑、更换事件类型都不用改核心结构。
用切片+互斥锁管理订阅者列表
Go 中常用 []Observer 存储监听器，配合 sync.RWMutex 保证并发安全：
立即学习“go语言免费学习笔记（深入）”；
- 读多写少场景下，
RWMutex比普通Mutex更高效 -
Register/Deregister用写锁，Notify用读锁遍历调用 - 注意在
Notify中避免锁内执行耗时操作（如网络请求），可启动 goroutine 异步处理
支持泛型事件类型（Go 1.18+）
如果事件结构统一，可用泛型提升类型安全：
type Eventer[T any] interface {
Register(obs Observer[T])
Notify(event T)
}
type Observer[T any] interface {
Update(event T)
}
这样编译期就能检查事件类型是否匹配，比如 Observer[UserLoginEvent] 不会误收 OrderPaidEvent。
简单可运行示例（无泛型版）
以下是一个最小可用实现：
type Observer interface {
Update(event string)
}
type Subject struct {
mu sync.RWMutex
observers []Observer
}
func (s *Subject) Register(o Observer) {
s.mu.Lock()
defer s.mu.Unlock()
s.observers = append(s.observers, o)
}
func (s *Subject) Notify(event string) {
s.mu.RLock()
defer s.mu.RUnlock()
for _, o := range s.observers {
o.Update(event)
}
}
// 使用示例：
type EmailNotifier struct{}
func (e EmailNotifier) Update(event string) { fmt.Println("Email:", event) }
type LogNotifier struct{}
func (l LogNotifier) Update(event string) { fmt.Println("Log:", event)
s := &Subject{}
s.Register(EmailNotifier{})
s.Register(LogNotifier{})
s.Notify("user logged in") // 输出两行日志
基本上就这些。不复杂但容易忽略的是并发安全和通知时机——别在锁里做阻塞操作，也别让某个 Observer panic 影响其他监听器，必要时加 recover 隔离错误。
