当前位置：首页 > 文章列表 > Golang > Go教程 > Golang观察者模式：事件通知与订阅管理

Golang观察者模式：事件通知与订阅管理

2026-01-09 18:54:43 0浏览收藏

目前golang学习网上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《Golang实现观察者模式：事件通知与订阅者管理》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

Go中观察者模式通过接口定义Observer.Update(event interface{})实现解耦，Subject用切片维护观察者并加锁保障并发安全，支持函数类型简化订阅、goroutine异步通知及错误处理。

如何在Golang中实现观察者模式_事件触发通知订阅者

在 Go 语言中实现观察者模式，核心是解耦事件发布者（Subject）与订阅者（Observer），让发布者在状态变化时主动通知所有已注册的订阅者，而无需知道它们的具体类型或行为。Go 没有内置的 interface 继承或多态语法糖，但依靠接口（interface{}）、函数类型、切片和 goroutine，可以简洁高效地实现这一模式。

定义统一的观察者接口

观察者需实现一个通用的通知方法，比如 Update(event interface{})。用接口抽象，便于不同业务逻辑的结构体灵活实现：

  // Observer 定义接收通知的行为
type Observer interface {
    Update(event interface{})
}
  // 示例：日志观察者
type LogObserver struct {}
func (o LogObserver) Update(event interface{}) {
    fmt.Printf("[LOG] 接收到事件: %v\n", event)
}

构建可管理的事件发布者（Subject）

Subject 负责维护观察者列表、提供注册/移除接口，并在触发时遍历调用每个观察者的 Update 方法。为支持并发安全，建议加锁（如 sync.RWMutex）：

type Subject struct {
    observers []Observer
    mu sync.RWMutex
}
func (s *Subject) Register(o Observer) {
    s.mu.Lock()
    defer s.mu.Unlock()
    s.observers = append(s.observers, o)
}
func (s *Subject) Notify(event interface{}) {
    s.mu.RLock()
    defer s.mu.RUnlock()
    for _, o := range s.observers {
        o.Update(event)
    }
}

用函数类型简化轻量级订阅

若观察者逻辑简单（如仅打印或发 HTTP 请求），可跳过接口定义，直接用函数类型作为观察者：

type EventHandler func(event interface{})
type SimpleSubject struct {
    handlers []EventHandler
    mu sync.RWMutex
}
func (s *SimpleSubject) OnEvent(h EventHandler) {
    s.mu.Lock()
    defer s.mu.Unlock()
    s.handlers = append(s.handlers, h)
}
func (s *SimpleSubject) Fire(event interface{}) {
    s.mu.RLock()
    defer s.mu.RUnlock()
    for _, h := range s.handlers {
        h(event)
    }
}
  // 使用示例
subject := &SimpleSubject{}
subject.OnEvent(func(e interface{}) { fmt.Println("✅ 收到:", e) })
subject.Fire("用户登录成功")