Golang如何实现观察者模式_Golang Observer模式事件通知实践-Golang-PHP中文网

Golang如何实现观察者模式_Golang Observer模式事件通知实践

P粉602998670

发布： 2025-12-05 09:29:02

原创

411人浏览过

观察者模式在Golang中通过接口与结构体实现一对多状态通知，核心为Subject维护Observer列表并支持注册、删除与广播，如WeatherStation在温度变化时通知PhoneDisplay和WebDisplay等观察者，利用Update方法接收消息，实现解耦与事件驱动，可结合sync.Mutex保障并发安全。

golang如何实现观察者模式_golang observer模式事件通知实践

在Golang中实现观察者模式（Observer Pattern）是一种常见的解耦设计方式，适用于事件驱动场景，比如状态变更通知、消息广播等。该模式的核心是定义一种一对多的依赖关系，当一个对象的状态发生变化时，所有依赖它的对象都会自动收到通知。

观察者模式的基本结构

观察者模式包含两个主要角色：

Subject（被观察者）：维护观察者列表，提供注册、删除和通知接口。
Observer（观察者）：定义接收通知的接口，通常是一个方法，如 Update()。

在Go语言中，由于没有类的概念，我们通过接口和结构体组合来实现这一模式。

用接口定义观察者与被观察者

首先定义 Observer 接口和 Subject 接口：

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

type Observer interface {
    Update(message string)
}

type Subject interface {
    Register(obs Observer)
    Deregister(obs Observer)
    Notify(message string)
}

登录后复制

接下来实现一个具体的被观察者，例如一个天气站（WeatherStation），它会在天气变化时通知所有注册的观察者：

Motiff

Motiff是由猿辅导旗下的一款界面设计工具，定位为“AI时代设计工具”

126

查看详情

type WeatherStation struct {
    observers []Observer
    temperature float64
}

func (w *WeatherStation) Register(obs Observer) {
    w.observers = append(w.observers, obs)
}

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

func (w *WeatherStation) Notify(message string) {
    for _, obs := range w.observers {
        obs.Update(message)
    }
}

func (w *WeatherStation) SetTemperature(temp float64) {
    w.temperature = temp
    w.Notify(fmt.Sprintf("Temperature changed to %.2f°C", temp))
}

登录后复制

实现具体的观察者

比如手机端和Web端显示天气信息：

type PhoneDisplay struct {
    name string
}

func (p *PhoneDisplay) Update(message string) {
    fmt.Printf("[%s] Received update: %s\n", p.name, message)
}

type WebDisplay struct{}

func (w *WebDisplay) Update(message string) {
    fmt.Println("[Web] Updating dashboard:", message)
}

登录后复制

使用示例

将观察者注册到被观察者，并触发事件：

func main() {
    station := &WeatherStation{}

    phone1 := &PhoneDisplay{name: "iPhone"}
    phone2 := &PhoneDisplay{name: "Android"}
    web := &WebDisplay{}

    station.Register(phone1)
    station.Register(phone2)
    station.Register(web)

    station.SetTemperature(25.5)
    // 输出：
    // [iPhone] Received update: Temperature changed to 25.50°C
    // [Android] Received update: Temperature changed to 25.50°C
    // [Web] Updating dashboard: Temperature changed to 25.50°C

    station.Deregister(phone2)
    station.SetTemperature(27.0)
    // 此时 Android 不再接收通知
}

登录后复制

这种实现方式简洁清晰，适用于大多数需要事件通知的场景。如果需要支持并发安全，可以在 Subject 中加入互斥锁（sync.Mutex）保护观察者列表的读写操作。

基本上就这些。Golang通过接口和组合轻松实现了观察者模式，无需复杂继承，适合现代应用开发中的松耦合需求。

以上就是Golang如何实现观察者模式_Golang Observer模式事件通知实践的详细内容，更多请关注php中文网其它相关文章！