当前位置：首页 > 文章列表 > Golang > Go教程 > Golang观察者模式详解与应用

Golang观察者模式详解与应用

2026-02-09 15:30:40 0浏览收藏

今天golang学习网给大家带来了《Golang观察者模式实现与使用解析》，其中涉及到的知识点包括等等，无论你是小白还是老手，都适合看一看哦~有好的建议也欢迎大家在评论留言，若是看完有所收获，也希望大家能多多点赞支持呀！一起加油学习~

Go中不用interface{}做观察者事件参数，因其导致运行时panic频发、类型断言失败难定位，根本原因是丢失编译期类型约束；应为每类事件定义具体结构体并统一实现Event接口。

如何使用Golang实现观察者模式_Golang观察者设计模式解构与实现

为什么 Go 里不用 interface{} 做观察者事件参数

Go 没有泛型前，不少人用 interface{} 当事件数据载体，结果运行时 panic 频发，类型断言失败还难定位。根本问题在于丢失了编译期类型约束，一旦通知逻辑稍复杂（比如多个事件类型混发），消费者端很容易漏处理或误转型。

更稳妥的做法是为每类事件定义具体结构体，再通过接口统一通知入口。例如：

type Event interface {
    EventType() string
}
<p>type UserCreatedEvent struct {
UserID   int64
Username string
}</p><p>func (e UserCreatedEvent) EventType() string { return "user.created" }
</p>

所有事件实现 Event 接口，便于统一注册和分发
避免在 Notify() 方法里塞 interface{} 参数，改用具体类型接收
如果用 Go 1.18+，可配合泛型写一个类型安全的 Subject[T Event]，但多数业务场景中明确的事件结构已足够

如何避免观察者注册/注销时的竞态问题

多个 goroutine 同时调用 Register() 或 Unregister() 会导致切片操作 panic，或者漏掉某个观察者——这是最常被忽略的并发陷阱。

必须加锁，但别直接锁整个通知过程（否则 Notify 变成串行，失去并发意义）：

type Subject struct {
    mu        sync.RWMutex
    observers []Observer
}
<p>func (s *Subject) Register(o Observer) {
s.mu.Lock()
defer s.mu.Unlock()
s.observers = append(s.observers, o)
}</p><p>func (s *Subject) Notify(event Event) {
s.mu.RLock() // 只读锁，允许并发 Notify
defer s.mu.RUnlock()
for _, o := range s.observers {
o.OnEvent(event)
}
}
</p>

注册/注销走 Lock()，通知走 RLock()，性能和安全兼顾
切忌在 Notify() 中遍历时修改 s.observers（比如一边通知一边注销），应先拷贝一份快照：obs := append([]Observer(nil), s.observers...)
如果观察者可能长时间阻塞（如发 HTTP 请求），建议在 Notify 内启 goroutine 异步调用，但需自行管理生命周期，防止 goroutine 泄漏

什么时候该用 channel 替代切片存观察者

当观察者数量少、事件频率低、且需要强顺序保证时，切片 + 锁完全够用；但若出现以下任一情况，channel 更合适：

观察者处理速度差异大，部分慢观察者拖垮整体吞吐
需要支持背压（如限流、超时、丢弃旧事件）
事件源和观察者天然解耦（比如跨 goroutine、跨 package）

典型 channel 实现模式是“扇出”：

type Subject struct {
    eventCh chan Event
}
<p>func (s *Subject) Notify(event Event) {
select {
case s.eventCh <- event:
default:
// 可选：丢弃、打日志、触发告警
}
}</p><p>// 每个观察者单独起 goroutine 消费
func (s *Subject) AddObserver(handler func(Event)) {
go func() {
for event := range s.eventCh {
handler(event)
}
}()
}
</p>

注意：channel 方案要额外处理关闭、泄漏、缓冲区大小等细节，简单业务不推荐过早引入。