观察者模式在Golang中通过接口与结构体实现一对多状态通知，核心为Subject维护Observer列表并支持注册、删除与广播，如WeatherStation在温度变化时通知PhoneDisplay和WebDisplay等观察者，利用Update方法接收消息，实现解耦与事件驱动，可结合sync.Mutex保障并发安全。
在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），它会在天气变化时通知所有注册的观察者：
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通过接口和组合轻松实现了观察者模式，无需复杂继承，适合现代应用开发中的松耦合需求。
