观察者模式通过接口和组合在Go中实现对象间一对多依赖，当主体状态变化时自动通知所有观察者。示例中EventManager管理Observer列表，支持注册、注销与通知，EmailService和LogService作为具体观察者接收消息。主函数模拟用户登录触发通知，输出显示注册的观察者收到事件，注销后不再接收。使用互斥锁可保证并发安全，建议异步处理通知以避免阻塞，适用于解耦事件发布与处理逻辑。
观察者模式是一种行为设计模式，适用于对象之间存在一对多依赖关系的场景，当一个对象状态改变时，所有依赖它的对象都会自动收到通知。在 Go 语言中，虽然没有类和继承的概念，但通过接口和组合机制可以非常简洁地实现观察者模式。
定义主题（Subject）和观察者（Observer）接口
核心是定义两个角色：主题（被观察者）和观察者。主题维护一组观察者，并提供注册、注销和通知的方法；观察者实现接收通知的接口。
示例代码：
type Observer interface {
Update(message string)
}
type Subject interface {
Register(observer Observer)
Unregister(observer Observer)
Notify(message string)
}
这里定义了 Observer 接口，包含一个 Update 方法用于接收更新消息；Subject 接口则提供了注册、注销和广播通知的能力。
实现具体的主题和观察者
以一个简单的事件通知系统为例，比如用户登录后需要通知日志服务、邮件服务等模块。
立即学习“go语言免费学习笔记（深入）”；
type EventManager struct {
observers []Observer
}
func (em *EventManager) Register(observer Observer) {
em.observers = append(em.observers, observer)
}
func (em *EventManager) Unregister(observer Observer) {
for i, obs := range em.observers {
if obs == observer {
em.observers = append(em.observers[:i], em.observers[i+1:]...)
break
}
}
}
func (em *EventManager) Notify(message string) {
for _, observer := range em.observers {
observer.Update(message)
}
}
// 具体观察者
type EmailService struct{}
func (e *EmailService) Update(message string) {
fmt.Println("EmailService received:", message)
}
type LogService struct{}
func (l *LogService) Update(message string) {
fmt.Println("LogService logged:", message)
}
上面实现了 EventManager 作为具体主题，管理多个观察者。两个具体观察者 EmailService 和 LogService 在收到通知时执行各自逻辑。
使用场景示例：用户登录事件通知
模拟用户登录后触发事件，通知所有监听该事件的服务。
func main() {
eventManager := &EventManager{}
emailSvc := &EmailService{}
logSvc := &LogService{}
// 注册观察者
eventManager.Register(emailSvc)
eventManager.Register(logSvc)
// 模拟用户登录
eventManager.Notify("User logged in")
// 取消某个观察者
eventManager.Unregister(emailSvc)
// 再次通知，此时只有日志服务会收到
eventManager.Notify("User updated profile")
}
输出结果：
EmailService received: User logged inLogService logged: User logged in
LogService logged: User updated profile
可以看到，在注销邮箱服务后，它不再接收到后续的通知。
优化建议与注意事项
- 使用互斥锁保护观察者列表，避免并发修改问题
- 可扩展为支持多种事件类型（如按事件名分类通知）
- 观察者更新尽量异步执行，防止阻塞其他通知
- 注意循环引用或未及时注销导致的内存泄漏
基本上就这些。Go 的接口和结构体组合让观察者模式实现变得轻量且灵活，适合用于解耦事件发布与处理逻辑，提升系统的可维护性和扩展性。
