Golang观察者模式实现事件通知

本篇文章给大家分享《Golang观察者模式实现事件通知》，覆盖了Golang的常见基础知识，其实一个语言的全部知识点一篇文章是不可能说完的，但希望通过这些问题，让读者对自己的掌握程度有一定的认识(B 数)，从而弥补自己的不足，更好的掌握它。

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 回收。

• 注册时返回一个 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 自动补全也正常。

真正难的不是写完这个模式，而是想清楚哪些事件该同步通知、哪些必须异步、哪些需要重试或持久化——这些决策不会出现在代码模板里，但决定了系统是否可靠。

终于介绍完啦！小伙伴们，这篇关于《Golang观察者模式实现事件通知》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！