首页 > Golang > Go教程

Golang观察者模式：对象变化通知多个观察者

时间：2026-01-12 09:27:43 444浏览收藏

一分耕耘，一分收获！既然打开了这篇文章《Golang实现观察者模式：对象状态变化通知多个观察者》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

Go中观察者模式通过函数类型Observer和Subject结构体实现，支持注册、移除、通知，结合嵌入或组合封装业务对象，如TemperatureSensor，并可扩展泛型、异步通知与取消机制。

如何使用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学习网公众号！

前往漫画官网入口并下载 ➜