Go中不用interface{}做事件参数,因会丢失类型信息导致运行时panic且IDE无法推导;应为每类事件定义具体结构体,编译期校验。

为什么 Go 里不用 interface{} 做事件参数
用 interface{} 接收事件数据看似灵活,实际会丢失类型信息,导致通知回调里必须做类型断言,一旦出错就 panic。更麻烦的是 IDE 和静态检查完全无法推导参数结构,协作和维护成本陡增。
推荐做法是为每类事件定义具体结构体,比如:
type UserCreatedEvent struct {
UserID int64
Email string
CreatedAt time.Time
}
观察者注册时明确声明自己关心哪种事件,发布方也只发对应类型——编译期就能校验,不靠运行时碰运气。
如何避免 Observer 注册后内存泄漏
Go 没有析构函数,Observer 如果持有外部对象引用(比如 HTTP handler、DB 连接),又没显式注销,就会让整个对象图无法被 GC 回收。
立即学习“go语言免费学习笔记(深入)”;
- 注册时返回一个
func()取消函数,调用即从内部 map/slice 中移除该 observer - Observer 实现
io.Closer接口,统一用defer obs.Close()管理生命周期 - 用
sync.Map存储 observer,key 用uintptr(unsafe.Pointer(&observer))需谨慎——更稳妥是用自增 ID 或 UUID 作 key
并发安全的 Notify 实现要注意什么
Notify() 被多个 goroutine 同时调用,而 observer 列表可能正在被增删,直接遍历 slice 会 panic。
- 读多写少场景:用
sync.RWMutex,Notify 用RLock(),注册/注销用Lock() - 写频繁场景:改用
sync.Map存 observer,但注意Range()不保证原子性,需配合 channel + goroutine 分发事件 - 关键点:不要在锁内执行 observer 回调——防止某个 observer 卡住阻塞全部通知
func (e *EventBus) Notify(event interface{}) {
e.mu.RLock()
obs := make([]Observer, 0, len(e.observers))
for _, o := range e.observers {
obs = append(obs, o)
}
e.mu.RUnlock()
for _, o := range obs {
go o.OnEvent(event) // 异步调用,不阻塞主流程
}
}
用泛型简化不同事件类型的注册与分发
Go 1.18+ 可以用泛型避免为每种事件写重复的 SubscribeUserCreated、SubscribeOrderPaid 方法。
核心是把事件类型作为类型参数,让编译器生成专用版本:
type EventHandler[T any] func(T)
type EventBus struct {
handlers sync.Map // key: reflect.Type, value: []EventHandler[T]
}
func (eb *EventBus) Subscribe[T any](handler EventHandler[T]) {
t := reflect.TypeOf((*T)(nil)).Elem()
if handlers, ok := eb.handlers.Load(t); ok {
eb.handlers.Store(t, append(handlers.([]EventHandler[T]), handler))
} else {
eb.handlers.Store(t, []EventHandler[T]{handler})
}
}
func (eb *EventBus) Publish[T any](event T) {
t := reflect.TypeOf((*T)(nil)).Elem()
if handlers, ok := eb.handlers.Load(t); ok {
for _, h := range handlers.([]EventHandler[T]) {
h(event)
}
}
}
调用时:bus.Subscribe[UserCreatedEvent](func(e UserCreatedEvent) { ... }),类型安全,无反射开销,IDE 自动补全也正常。
真正难的不是写完这个模式,而是想清楚哪些事件该同步通知、哪些必须异步、哪些需要重试或持久化——这些决策不会出现在代码模板里,但决定了系统是否可靠。










