观察者模式在Go中通过接口和切片实现，用于解耦事件发布与处理；示例中Subject维护Observer列表，支持动态订阅与通知，适用于消息广播、状态更新等场景。
在Go语言中，Observer（观察者）模式是一种常用的设计模式，适用于事件驱动的场景，比如消息通知、状态变更广播等。该模式定义了对象之间的一对多依赖关系，当一个对象状态改变时，所有依赖它的对象都会收到通知。
基本结构说明
观察者模式包含两个核心角色：
- Subject（主题）：维护观察者列表，提供订阅、取消订阅和通知方法。
- Observer（观察者）：实现通知接口，接收状态更新。
在Go中，可以通过接口和切片来实现这一模式。
代码实现示例
下面是一个简单的事件订阅与通知示例：
立即学习“go语言免费学习笔记（深入）”；
package main
import "fmt"
// Observer 观察者接口
type Observer interface {
Update(message string)
}
// Subject 主题结构体
type Subject struct {
observers []Observer
}
// Subscribe 添加观察者
func (s *Subject) Subscribe(o Observer) {
s.observers = append(s.observers, o)
}
// Unsubscribe 移除观察者
func (s *Subject) Unsubscribe(o Observer) {
for i, obs := range s.observers {
if obs == o {
s.observers = append(s.observers[:i], s.observers[i+1:]...)
break
}
}
}
// Notify 通知所有观察者
func (s *Subject) Notify(message string) {
for _, observer := range s.observers {
observer.Update(message)
}
}
// 具体观察者：邮件服务
type EmailService struct{}
func (e *EmailService) Update(message string) {
fmt.Println("Email sent:", message)
}
// 具体观察者：日志服务
type LogService struct{}
func (l *LogService) Update(message string) {
fmt.Println("Log recorded:", message)
}
// 示例使用
func main() {
subject := &Subject{}
email := &EmailService{}
log := &LogService{}
// 订阅
subject.Subscribe(email)
subject.Subscribe(log)
// 发布事件
subject.Notify("User registered")
// 取消订阅
subject.Unsubscribe(email)
// 再次通知
subject.Notify("User logged in")
}
运行结果说明
上述代码输出为：
Email sent: User registered Log recorded: User registered Log recorded: User logged in
第一次通知时，两个观察者都收到消息；取消email订阅后，第二次仅日志服务被触发。
实际应用场景
这种模式适合用于解耦事件发布与处理逻辑，例如：
- 用户注册后发送邮件、记录日志、初始化配置等。
- 系统状态变更时通知多个监控模块。
- 微服务间通过事件总线通信（可结合channel进一步封装）。
基本上就这些。Go的接口和组合机制让Observer模式实现简洁清晰，无需复杂继承体系。根据需要，还可以加入goroutine实现异步通知，提升性能。
