Golang如何实现观察者事件订阅_Golang 观察者事件订阅实践-Golang-PHP中文网

Golang如何实现观察者事件订阅_Golang 观察者事件订阅实践

P粉602998670

发布： 2025-11-23 16:23:04

原创

212人浏览过

答案：Go通过接口和切片实现观察者模式，支持事件驱动解耦。定义Observer与Subject接口，用EventBus管理订阅并通知，结合具体观察者如Logger、Notifier响应事件，可扩展异步、并发安全等优化机制。

golang如何实现观察者事件订阅_golang 观察者事件订阅实践

在 Golang 中实现观察者模式（Observer Pattern）是一种常见的解耦手段，适用于事件驱动系统、状态变更通知等场景。通过“订阅-发布”机制，可以让多个观察者监听某个主体的变化，而无需主体直接依赖这些观察者。

观察者模式的基本结构

观察者模式包含两个核心角色：

Subject（被观察者）：维护一组观察者，状态变化时通知它们。
Observer（观察者）：注册到 Subject，接收更新通知。

在 Go 中，我们可以利用接口和切片来实现这一模式，无需复杂的类继承。

使用接口定义观察者契约

先定义 Observer 和 Subject 接口，确保松耦合：

立即学习“go语言免费学习笔记（深入）”；

type Event string

type Observer interface {
  Update(Event)
}

type Subject interface {
  Register(Observer)
  Deregister(Observer)
  Notify(Event)
}

登录后复制

这里用 Event 表示触发的事件类型（如 "user.login"），Observer 只需实现 Update 方法即可响应事件。

实现一个具体的事件中心

我们可以构建一个简单的事件总线（EventBus），作为中心化的 Subject：

type EventBus struct {
  observers []Observer
}

func (bus *EventBus) Register(obs Observer) {
  bus.observers = append(bus.observers, obs)
}

func (bus *EventBus) Deregister(obs Observer) {
  for i, o := range bus.observers {
    if o == obs {
      bus.observers = append(bus.observers[:i], bus.observers[i+1:]...)
      break
    }
  }
}

func (bus *EventBus) Notify(event Event) {
  for _, obs := range bus.observers {
    obs.Update(event)
  }
}

登录后复制

这个 EventBus 支持动态注册与注销，并在事件发生时广播给所有订阅者。

Supercreator

AI视频创作编辑器，几分钟内从构思到创作。

查看详情

编写具体观察者处理逻辑

比如我们有两个业务需求：记录日志和发送通知：

type Logger struct{}

func (l *Logger) Update(event Event) {
  fmt.Printf("[LOG] 事件触发: %s\n", event)
}

type Notifier struct{}

func (n *Notifier) Update(event Event) {
  fmt.Printf("[NOTIFY] 正在处理事件: %s\n", event)
}

登录后复制

这两个结构体都实现了 Observer 接口，可以被注册进 EventBus。

实际使用示例

在 main 函数中组合使用：

func main() {
  bus := &EventBus{}
  
  logger := &Logger{}
  notifier := &Notifier{}

  bus.Register(logger)
  bus.Register(notifier)

  bus.Notify("user.login")  // 所有观察者都会收到通知

  bus.Deregister(notifier)
  bus.Notify("config.updated") // 只有 logger 会收到
}

登录后复制

输出结果：

[LOG] 事件触发: user.login [NOTIFY] 正在处理事件: user.login [LOG] 事件触发: config.updated