观察者模式通过Subject和Observer接口实现事件订阅与通知，使用EventCenter管理观察者并线程安全地广播事件，需注意及时取消订阅以避免内存泄漏。
在Go语言中，观察者模式可用于实现事件的订阅与通知机制，常见于解耦事件发布者和多个响应者。通过定义主题（Subject）和观察者（Observer）接口，可以灵活地管理事件订阅、取消和广播。
定义观察者和主题接口
观察者模式的核心是主题和观察者之间的约定。主题负责维护订阅者列表，并在状态变化时通知所有观察者。
以下是一个基础接口设计：Observer接口：定义接收通知的方法。
Subject接口：定义添加、删除和通知观察者的方法。
type Event string
type Observer interface {
OnNotify(Event)
}
type Subject interface {
Subscribe(Observer)
Unsubscribe(Observer)
Notify(Event)
}实现事件中心
使用一个结构体实现Subject接口，维护观察者集合，并提供线程安全的操作。
示例：基于map的简单事件中心 ```go type EventCenter struct { observers map[Observer]bool mutex sync.RWMutex }func NewEventCenter() *EventCenter { return &EventCenter{ observers: make(map[Observer]bool), } }
func (ec *EventCenter) Subscribe(o Observer) { ec.mutex.Lock() defer ec.mutex.Unlock() ec.observers[o] = true }
func (ec *EventCenter) Unsubscribe(o Observer) { ec.mutex.Lock() defer ec.mutex.Unlock() delete(ec.observers, o) }
func (ec *EventCenter) Notify(event Event) { ec.mutex.RLock() defer ec.mutex.RUnlock() for observer := range ec.observers { observer.OnNotify(event) } }
编写具体观察者
每个需要响应事件的组件实现Observer接口即可自动接收通知。
立即学习“go语言免费学习笔记（深入）”；
例如，日志记录器和邮件通知服务： ```go type Logger struct{} func (l *Logger) OnNotify(event Event) { fmt.Printf("日志记录: %s\n", event) } type EmailNotifier struct{} func (e *EmailNotifier) OnNotify(event Event) { if event == "user_registered" { fmt.Println("发送欢迎邮件...") } }
使用示例
将观察者注册到事件中心，触发事件后自动广播。
```go func main() { center := NewEventCenter()logger := &Logger{}
emailer := &EmailNotifier{}
center.Subscribe(logger)
center.Subscribe(emailer)
center.Notify("user_registered")
// 输出:
// 日志记录: user_registered
// 发送欢迎邮件...
center.Unsubscribe(emailer)
center.Notify("order_paid")
// 只有日志输出}
基本上就这些。Go没有内置事件系统，但通过接口和组合，能简洁实现观察者模式。关键是避免内存泄漏——记得在适当时机取消订阅，尤其是短期存在的观察者。
