Go中观察者模式通过函数类型Observer和Subject结构体实现，支持注册、移除、通知，结合嵌入或组合封装业务对象，如TemperatureSensor，并可扩展泛型、异步通知与取消机制。
用 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 改为带通知逻辑的方法。
立即学习“go语言免费学习笔记（深入）”；
例如实现一个温度传感器：
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()
}
