当前位置：首页 > 文章列表 > Golang > Go教程 > Golang观察者模式与事件通知实现

Golang观察者模式与事件通知实现

2025-12-20 21:15:39 0浏览收藏

推广推荐

支持 PC / 移动端，安全直达

目前golang学习网上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《Golang观察者模式实现与事件通知实践》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

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

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

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

观察者模式的基本结构

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

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

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

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

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

type Observer interface {
    Update(message string)
}

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

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

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学习网公众号吧！