当前位置：首页 > 文章列表 > Golang > Go教程 > Golang实现观察者模式：对象状态变化通知多观察者

Golang实现观察者模式：对象状态变化通知多观察者

2026-03-27 09:42:24 0浏览收藏

本文深入讲解了如何在Go语言中简洁高效地实现观察者模式——通过函数类型定义轻量灵活的Observer、结合sync.RWMutex保障并发安全的Subject结构体，以及嵌入式封装（如TemperatureSensor）将状态变更与自动通知无缝集成；不仅展示了日志记录、阈值告警、UI更新等多观察者协同响应的实际用例，还进一步拓展了泛型增强类型安全、goroutine异步通知避免阻塞、以及context或取消函数支持的进阶实践，为构建高内聚、松耦合、可扩展的事件驱动系统提供了扎实的Go原生解决方案。

如何使用Golang实现观察者模式_对象状态变化通知多个观察者

用 Go 实现观察者模式，核心是定义一个被观察对象（Subject）和多个观察者（Observer），当 Subject 状态变化时，自动通知所有已注册的 Observer。Go 没有内置接口继承机制，但通过接口+组合+函数类型，能简洁、高效地实现该模式。

定义 Observer 接口与 Subject 结构体

Observer 是一个函数类型或接口，用于接收状态更新；Subject 维护观察者列表，并提供注册、移除、通知方法。

推荐使用函数类型作为 Observer，更轻量灵活：

// Observer 是一个接受更新数据的函数类型
type Observer func(data interface{})

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

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

func (s *Subject) Unregister(obs Observer) {
    s.mu.Lock()
    defer s.mu.Unlock()
    for i, o := range s.observers {
        if o == obs {
            s.observers = append(s.observers[:i], s.observers[i+1:]...)
            break
        }
    }
}

func (s *Subject) Notify(data interface{}) {
    s.mu.RLock()
    defer s.mu.RUnlock()
    for _, obs := range s.observers {
        obs(data) // 异步通知？可另起 goroutine，但需注意并发安全
    }
}

封装具体业务对象：状态变更自动触发 Notify

让业务结构体嵌入 *Subject 或持有其指针，把状态字段的 setter 改为带通知逻辑的方法。

例如实现一个温度传感器：

type TemperatureSensor struct {
    *Subject
    temperature float64
}

func NewTemperatureSensor() *TemperatureSensor {
    return &TemperatureSensor{
        Subject: &Subject{observers: make([]Observer, 0)},
    }
}

func (t *TemperatureSensor) SetTemperature(temp float64) {
    t.temperature = temp
    t.Notify(map[string]float64{"temperature": temp})
}

func (t *TemperatureSensor) GetTemperature() float64 {
    return t.temperature
}

注册多个观察者：日志、告警、UI 更新等职责分离

每个 Observer 函数专注单一响应逻辑，便于测试与复用：

日志观察者：打印变更信息
告警观察者：温度超阈值时发邮件/短信
缓存同步观察者：更新本地缓存或推送至 Redis

示例注册方式：

sensor := NewTemperatureSensor()

// 日志观察者
sensor.Register(func(data interface{}) {
    fmt.Println("LOG: sensor updated →", data)
})

// 告警观察者
sensor.Register(func(data interface{}) {
    if v, ok := data.(map[string]float64); ok {
        if t := v["temperature"]; t > 80.0 {
            fmt.Println("ALERT: High temperature detected!", t)
        }
    }
})

// 触发变更
sensor.SetTemperature(85.5) // 同时输出 log 和 alert

进阶建议：支持泛型、异步通知与取消机制

Go 1.18+ 可用泛型增强类型安全，比如定义 Subject[T]；若通知耗时长，可用 channel + goroutine 异步分发；如需支持取消，可结合 context.Context 或返回 func() 取消函数。

简单异步版 Notify 示例：

func (s *Subject) NotifyAsync(data interface{}) {
    s.mu.RLock()
    obsCopy := append([]Observer(nil), s.observers...) // 安全拷贝
    s.mu.RUnlock()

    var wg sync.WaitGroup
    for _, obs := range obsCopy {
        wg.Add(1)
        go func(o Observer) {
            defer wg.Done()
            o(data)
        }(obs)
    }
    wg.Wait()
}

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《Golang实现观察者模式：对象状态变化通知多观察者》文章吧，也可关注golang学习网公众号了解相关技术文章。