观察者模式通过接口与结构体实现事件订阅，主题维护观察者列表并通知状态变更，如用户注册时触发邮件发送与资料初始化。
在Go语言中，观察者模式是一种常见的设计模式，用于实现对象间的一对多依赖关系，当一个对象状态改变时，所有依赖它的对象都会得到通知。这种机制非常适合实现事件订阅系统。下面通过一个清晰的结构来说明如何用Golang实践观察者模式来实现事件订阅。
观察者模式的核心组成
观察者模式包含两个主要角色：
- 主题（Subject）：维护观察者列表，提供注册、注销和通知接口。
- 观察者（Observer）：实现通知响应方法，接收主题的状态更新。
在事件系统中，主题通常称为“事件发布者”，观察者则是“事件订阅者”。
定义接口与结构体
先定义统一的接口，让代码更灵活可扩展。
立即学习“go语言免费学习笔记（深入）”；
type Event string
type Observer interface {
OnNotify(Event)
}
type Subject struct {
observers []Observer
}
Subject结构体持有一个Observer切片，用来管理所有订阅者。接下来实现注册、注销和广播方法。
func (s *Subject) Subscribe(o Observer) {
s.observers = append(s.observers, o)
}
func (s *Subject) Unsubscribe(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 Event) {
for _, observer := range s.observers {
observer.OnNotify(event)
}
}
实现具体的事件订阅逻辑
现在我们创建几个实际的观察者来响应事件。
type UserEmailService struct{}
func (u *UserEmailService) OnNotify(event Event) {
if event == "user_registered" {
println("发送欢迎邮件...")
}
}
type UserService struct{}
func (u *UserService) OnNotify(event Event) {
if event == "user_registered" {
println("初始化用户资料...")
}
}
这两个服务会在用户注册时被触发。使用方式如下：
func main() {
subject := &Subject{}
emailService := &UserEmailService{}
profileService := &UserService{}
subject.Subscribe(emailService)
subject.Subscribe(profileService)
// 模拟用户注册事件
subject.Notify("user_registered")
}
输出结果为：
发送欢迎邮件...初始化用户资料...
优化建议与注意事项
-
线程安全：如果在并发环境下使用，需使用
sync.RWMutex保护观察者列表。 - 避免内存泄漏：长时间运行的服务应记得调用Unsubscribe，防止无效引用堆积。
- 异步通知：对于耗时操作（如发邮件），可在OnNotify中启动goroutine处理，避免阻塞主流程。
- 事件类型细化：可将Event扩展为结构体，携带更多上下文数据，比如用户ID、时间戳等。
基本上就这些。Golang没有继承机制，但通过接口和组合，能非常简洁地实现观察者模式。只要理清主题与观察者的职责边界，就能构建出灵活、解耦的事件驱动系统。
