观察者模式通过定义Subject和Observer接口实现解耦，EventCenter作为具体主体管理观察者列表并通知，Logger和Mailer作为观察者接收消息，使用互斥锁保证并发安全，通过复制列表避免通知时的竞态问题，适用于状态变更通知场景。
在Go语言中实现观察者模式，可以很好地解耦事件的发布者与订阅者。这种设计模式常用于状态变更通知、消息广播等场景。核心思想是：一个主体（被观察者）维护一组观察者列表，当主体状态发生变化时，自动通知所有注册的观察者。
定义观察者接口和主体
要实现观察者模式，先定义两个核心部分：主体（Subject）和观察者（Observer）。主体负责管理订阅者并发送通知，观察者则实现接收更新的方法。
Observer 接口：包含一个 Notify 方法，用于接收通知。
Subject 接口：提供 Subscribe 和 Notify 方法，用于增删观察者和触发通知。
立即学习“go语言免费学习笔记（深入）”；
示例代码：
Alibabacloud Sdk Client Initialization For Golang
下载
初始化并管理阿里云SDK Go 客户端，涵盖 sync.Once 单例、goroutine 安全、endpoint 与 region 配置、VPC 端点及调试。
type Observer interface {
Notify(data interface{})
}
type Subject interface {
Subscribe(obs Observer)
Unsubscribe(obs Observer)
NotifyAll(data interface{})
}
实现具体的被观察者
以一个简单的事件中心为例，使用切片存储观察者，并通过互斥锁保证并发安全。
type EventCenter struct {
observers []Observer
mutex sync.Mutex
}
func NewEventCenter() *EventCenter {
return &EventCenter{
observers: make([]Observer, 0),
}
}
func (ec *EventCenter) Subscribe(obs Observer) {
ec.mutex.Lock()
defer ec.mutex.Unlock()
ec.observers = append(ec.observers, obs)
}
func (ec *EventCenter) Unsubscribe(obs Observer) {
ec.mutex.Lock()
defer ec.mutex.Unlock()
for i, o := range ec.observers {
if o == obs {
ec.observers = append(ec.observers[:i], ec.observers[i+1:]...)
break
}
}
}
func (ec *EventCenter) NotifyAll(data interface{}) {
ec.mutex.Lock()
observers := make([]Observer, len(ec.observers))
copy(observers, ec.observers)
ec.mutex.Unlock()
for _, obs := range observers {
obs.Notify(data)
}
}
这里复制观察者列表是为了避免在通知过程中因加锁时间过长影响性能，也防止观察者在回调中修改列表导致竞态问题。
定义具体观察者
每个观察者只需实现 Notify 方法即可响应事件。例如，创建两个处理日志和发送邮件的观察者：
type Logger struct{}
func (l *Logger) Notify(data interface{}) {
fmt.Printf("日志记录: %v\n", data)
}
type Mailer struct{}
func (m *Mailer) Notify(data interface{}) {
if user, ok := data.(map[string]string); ok {
fmt.Printf("发送邮件给: %s, 内容: 欢迎 %s\n", user["email"], user["name"])
}
}
使用示例
将观察者注册到事件中心，触发事件后自动通知所有订阅者：
func main() {
center := NewEventCenter()
logger := &Logger{}
mailer := &Mailer{}
center.Subscribe(logger)
center.Subscribe(mailer)
newUser := map[string]string{
"name": "Alice",
"email": "alice@example.com",
}
center.NotifyAll(newUser)
center.Unsubscribe(mailer)
center.NotifyAll("系统更新")
}
输出结果：
日志记录: map[name:Alice email:alice@example.com] 发送邮件给: alice@example.com, 内容: 欢迎 Alice 日志记录: 系统更新
可以看到，第一次通知时两个观察者都收到消息；取消订阅后，只有日志观察者继续接收。
基本上就这些。用接口和切片就能清晰实现事件的订阅与通知机制，适合中小型场景。如果需要更复杂的调度或异步处理，可结合 channel 进一步扩展。
