观察者模式通过定义Observer接口和Subject结构实现事件广播，支持同步或异步通知，可用于解耦组件通信。1. Observer接口声明Update方法；2. Subject维护观察者列表并提供注册、注销及通知功能；3. 具体观察者如LoggerObserver、EmailNotifier实现Update；4. 调用Notify触发广播；5. 可扩展为异步通知并使用锁保证并发安全。该模式适用于事件驱动系统，提升可扩展性。
在 Golang 中实现观察者模式（Observer Pattern）来广播事件，是一种常见的解耦组件间通信的方式。它允许一个对象（被观察者）在状态变化时，自动通知所有依赖的观察者对象。这种模式特别适用于事件驱动系统、消息通知、状态同步等场景。
定义观察者接口和被观察者结构
观察者模式的核心是定义两个角色：被观察者（Subject）和观察者（Observer）。观察者需要实现一个统一的更新方法，被观察者维护一个观察者列表，并在事件发生时调用它们的更新函数。
示例代码：Observer 接口 定义接收通知的方法：
type Observer interface {
Update(event string)
}
Subject 是被观察者，管理观察者列表并支持注册、注销和通知：
立即学习“go语言免费学习笔记（深入）”；
type Subject struct {
observers []Observer
}
func (s *Subject) Register(o Observer) {
s.observers = append(s.observers, o)
}
func (s *Subject) Unregister(o Observer) {
for i, observer := range s.observers {
if observer == o {
s.observers = append(s.observers[:i], s.observers[i+1:]...)
break
}
}
}
func (s *Subject) Notify(event string) {
for _, observer := range s.observers {
observer.Update(event)
}
}
实现具体的观察者
你可以定义多个具体类型的观察者，比如日志记录器、邮件通知器等，它们都实现 Update 方法。
type LoggerObserver struct{}
func (l *LoggerObserver) Update(event string) {
fmt.Printf("日志记录: %s\n", event)
}
type EmailNotifier struct{}
func (e *EmailNotifier) Update(event string) {
fmt.Printf("发送邮件通知: %s\n", event)
}
使用观察者模式广播事件
将观察者注册到被观察者，当有事件发生时调用 Notify 即可实现广播。
func main() {
subject := &Subject{}
logger := &LoggerObserver{}
emailer := &EmailNotifier{}
subject.Register(logger)
subject.Register(emailer)
subject.Notify("用户已登录") // 两个观察者都会收到通知
subject.Unregister(emailer)
subject.Notify("数据已保存") // 只有日志观察者收到
}
输出结果：
日志记录: 用户已登录 发送邮件通知: 用户已登录 日志记录: 数据已保存
进阶：支持异步通知与泛型事件
在实际项目中，可以扩展该模式以支持异步通知，避免某个观察者阻塞整体流程。也可以使用 interface{} 或 Go 1.18+ 的泛型来传递更复杂的事件数据。
func (s *Subject) NotifyAsync(event string) {
for _, observer := range s.observers {
go func(o Observer) {
o.Update(event)
}(observer)
}
}
这种方式适合耗时操作如网络请求，但需注意并发安全。若涉及并发读写观察者列表，应使用 sync.RWMutex 保护。
基本上就这些。Golang 虽无类继承，但通过接口和组合能简洁地实现观察者模式，有效解耦模块，提升系统可扩展性。
