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 隔离错误。