如何使用Golang实现观察者模式与事件通知_动态响应对象状态变化

观察者模式是“一对多”依赖关系，被观察者状态改变时自动通知所有观察者；Go通过接口、切片和函数类型简洁实现，需定义Observer接口和Subject结构体，支持并发安全注册与通知。

观察者模式的核心思路

观察者模式本质是“一对多”的依赖关系：当一个对象（被观察者）状态改变，所有依赖它的对象（观察者）自动收到通知并响应。Golang 没有内置接口或语法糖支持，但靠接口、切片和函数类型就能简洁实现，无需第三方库。

定义统一的事件通知接口

先定义一个通用的 Observer 接口，让所有观察者都实现 Update(event interface{}) 方法：

  // Observer 定义观察者行为
  type Observer interface {
    Update(event interface{})
  }

这样设计灵活：事件可以是字符串、结构体、自定义事件类型，甚至 map[string]interface{}，由业务决定。

构建可观察的对象（Subject）

被观察者需维护观察者列表，并提供注册、注销、通知能力。用结构体封装状态和行为：

  // Subject 管理观察者并触发通知
  type Subject struct {
    observers []Observer
    mu sync.RWMutex
  }

  func (s *Subject) Register(o Observer) {
    s.mu.Lock()
    s.observers = append(s.observers, o)
    s.mu.Unlock()
  }

  func (s *Subject) Notify(event interface{}) {
    s.mu.RLock()
    defer s.mu.RUnlock()
    for _, o := range s.observers {
      o.Update(event)
    }
  }

注意加锁保护并发安全——尤其在 Web 服务或定时任务中，多个 goroutine 可能同时注册或通知。

具体使用：状态变化触发事件

以用户登录状态为例，封装一个 UserSession 结构体嵌入 Subject，并在关键方法中调用 Notify：

  type UserSession struct {
    *Subject
    ID string
    IsLoggedIn bool
  }

  func (u *UserSession) Login() {
    u.IsLoggedIn = true
    u.Notify(map[string]string{
      "event": "login",
      "user_id": u.ID,
    })
  }

再写两个观察者：日志记录器和在线统计器：

  type Logger struct{}
  func (l Logger) Update(e interface{}) {
    log.Printf("LOG: %+v", e)
  }

  type OnlineCounter struct{ count int }
  func (c *OnlineCounter) Update(e interface{}) {
    if ev, ok := e.(map[string]string); ok && ev["event"] == "login" {
      c.count++
      log.Printf("Online now: %d", c.count)
    }
  }

组合使用：

  sess := &UserSession{
    Subject: &Subject{},
    ID: "u123",
  }

  sess.Register(Logger{})
  counter := &OnlineCounter{}
  sess.Register(counter)

  sess.Login() // 触发两个观察者的 Update

这样就实现了松耦合的动态响应：新增观察者只需实现接口并注册，不修改原有逻辑。

# go # golang # app # session # String # if # count # for # 封装 # printf # register # 字符串 # 结构体 # bool # int # 接口 # Struct # Interface # Event # 切片 # append # map # 并发 # 对象 # 事件 # 记录器 # 就能 # 多个 # 只需 # 并在 # 自定义 # 为例 # 第三方 # 用户登录 # 加锁

返回目录在线咨询

上一篇：无限智能建站：全自动SEO站对网站排名有何影响？
下一篇：如何解决WordPress网站加载速度慢的问题？

您的项目需求