观察者模式通过主题与观察者接口实现一对多依赖，Go中用切片管理观察者并结合sync锁和goroutine确保并发安全与非阻塞通知，适用于解耦事件的产生与处理。
在Go语言中，观察者模式是一种常用的设计模式，用于实现对象间的一对多依赖关系，当一个对象状态改变时，所有依赖它的对象都会收到通知。这种模式非常适合实现事件通知机制。
定义主题（Subject）和观察者（Observer）接口
观察者模式的核心是主题和观察者两个角色。主题维护一组观察者，在状态变化时通知它们；观察者则定义接收通知的方法。
以下是一个简单的接口定义：
type Observer interface {
立即学习“go语言免费学习笔记（深入）”；
Update(data interface{})
}
type Subject interface {
Register(obs Observer)
Unregister(obs Observer)
Notify(data interface{})
}
实现具体主题
具体主题通常持有一个观察者列表，并提供注册、注销和广播通知的功能。例如，我们可以实现一个事件中心：
type EventCenter struct {
observers []Observer
mutex sync.RWMutex
}
func (ec *EventCenter) Register(obs Observer) {
ec.mutex.Lock()
defer ec.mutex.Unlock()
ec.observers = append(ec.observers, obs)
}
func (ec *EventCenter) Unregister(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) Notify(data interface{}) {
ec.mutex.RLock()
defer ec.mutex.RUnlock()
for _, obs := range ec.observers {
go obs.Update(data)
}
}
实现观察者
观察者实现Update方法来响应通知。可以有多个不同的观察者处理不同逻辑。
type EmailService struct{}
func (e *EmailService) Update(data interface{}) {
fmt.Printf("发送邮件: %v\n", data)
}
type LogService struct{}
func (l *LogService) Update(data interface{}) {
fmt.Printf("记录日志: %v\n", data)
}
使用示例
将主题和观察者组合起来，即可实现事件通知：
eventCenter := &EventCenter{observers: make([]Observer, 0)}
emailSvc := &EmailService{}
logSvc := &LogService{}
eventCenter.Register(emailSvc)
eventCenter.Register(logSvc)
eventCenter.Notify("用户已注册")
运行后，两个服务都会收到通知并执行相应操作。
基本上就这些。通过接口抽象和切片管理观察者，Golang能简洁地实现观察者模式。加上sync锁可保证并发安全，用goroutine发送通知可避免阻塞主流程。这种结构适合解耦事件产生和处理逻辑。不复杂但容易忽略细节，比如注销时的切片操作和并发控制。
