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

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

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

2025-12-05

浏览次数：次

返回列表

观察者模式在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），它会在天气变化时通知所有注册的观察者：

星辰Agent

科大讯飞推出的智能体Agent开发平台，助力开发者快速搭建生产级智能体

378 查看详情星辰Agent

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模式事件通知实践的详细内容，更多请关注其它相关文章！

# go # 南充网站优化哪里有 # seo全网营销推广广告 # 马士基网站建设中国 # 企业网站建设详细步骤 # 涞源县网站推广推荐 # 如何推广微商网站赚钱快 # 设计网站推广首页 # 一站式推广营销 # seo2价格 # 相关文章 # 会在 # 是一种 # 这一 # 可行性分析 # 是一个 # 多语言 # 来实现 # 适用于 # 如何实现 # 应用开发 # ai # iphone # app # go语言 # golang # android # 驻马店seo排名软件