go 应用事件通知应避免 observer 接口,改用 type eventhandler func(event) 类型,配合快照遍历、显式取消机制与具体 event struct,确保类型安全、并发安全及可维护性。

Go 语言里没有 Observer 接口,也不该硬套 Java 那套 register/unregister + Update() 的写法——那样写出来的代码,要么并发不安全,要么注销漏掉,要么通知时 panic,要么类型擦除后满屏 interface{} 断言。
用 func(Event) 替代 Observer 接口
观察者本质就是“收到事件后执行一段逻辑”,不是“实现某个接口的结构体”。用函数类型直接表达意图,更轻、更安全、更 Go:
-
Observer接口在 Go 里是冗余抽象:没人强制你实现它,编译器也检查不了,运行时才暴露nil pointer或静默忽略 - 统一用
type EventHandler func(Event),注册/注销都传这个类型,签名清晰,类型安全 - 避免为每个业务建新接口(比如
UserObserver、OrderObserver),后期改字段或加方法就得全量重构 - Event 类型必须是具体 struct(如
UserCreatedEvent),别用map[string]interface{}或json.RawMessage—— 否则字段改名、类型变更、JSON 解析失败全得 runtime 抓
切片存 handler 必须做快照遍历
用 []EventHandler 最简单,但直接 for _, h := range s.handlers 并发调用会 panic。常见错误是只加锁不拷贝,或边遍历边删元素。
- 注册/注销走
sync.RWMutex写锁,但Notify()中读操作不能长期持锁——否则阻塞写入 - 每次通知前做快照:
handlers := append(s.handlers[:0:0], s.handlers...),确保遍历的是稳定副本 - 别在
Notify()里同步调用耗时 handler(如 HTTP 请求、DB 写入);若需异步,由调用方决定是否go h(e),被观察者不封装 goroutine - 注销不要用值比较(
h == target),匿名函数地址不可靠;推荐返回取消函数,或用显式 token(struct{})标识生命周期
用 sync.Map 还是 sync.RWMutex + map?
sync.Map 不是万能药。它适合读多写少、key 动态增删频繁的场景;但高频注册/注销时,其内部分段锁和接口类型转换反而拖慢性能。
- 如果 handler 数量稳定(比如启动时注册完就不再变),用
sync.RWMutex + map[any]EventHandler更直观、易 debug - 若需按事件类型分发(如
"user.created"→ 多个 handler),用map[string][]EventHandler比嵌套sync.Map更可控 -
sync.Map.Load()返回interface{},必须断言;别存裸func(),统一包装为func(Event) error,方便错误传播和日志打点 - 别用
uintptr当 key 存函数地址——闭包、方法值每次调用地址可能不同,且无法区分同名函数多个实例
channel 方案防泄漏比防阻塞更重要
用 chan Event 实现异步解耦很自然,但多数人栽在生命周期管理上,不是缓冲区设多大,而是 goroutine 忘关。
- 每个订阅者必须启动独立 goroutine 消费 channel,主线程不能
range阻塞——否则一个慢 handler 卡死全部事件流 - 务必提供
Unsubscribe(),并在对象销毁时close(ch);goroutine 内部用select { case e := 响应退出信号 - 缓冲大小设 16~64 足够,别设
make(chan Event, 10000)—— OOM 比阻塞更难排查 - HTTP handler 等短生命周期上下文中,别直接
publish()后就返回;用带select的非阻塞发送,或先暂存再异步提交
真正难的不是让通知跑起来,而是想清楚:这个事件要不要保证顺序?失败了重不重试?下游是否可能 crash?这些决定了你该用切片快照、sync.Map 分发,还是直接上 Kafka。别在 init() 里全局订阅,也别把事件名散落在字符串里——集中定义、导出字段、统一错误处理,比选哪种数据结构重要得多。
golang免费学习笔记(深入):立即使用
在学习笔记中,你将探索golang的核心概念和高级技巧!











