Go语言通过观察者模式解耦事件发布与订阅，定义Observer和Subject接口，实现EventCenter管理订阅并通知，结合具体观察者完成状态广播。
在Go语言中实现观察者模式，可以很好地解耦事件的发布者与订阅者。这种设计模式常用于状态变更通知、消息广播等场景。下面通过一个简单的例子展示如何用Golang实现事件的订阅与通知机制。
定义观察者接口与主题
观察者模式包含两个核心部分：一是被观察的主题（Subject），它维护一组观察者并负责通知它们；二是观察者（Observer），它实现更新方法以响应状态变化。
我们先定义接口：
// Observer 观察者接口
type Observer interface {
Update(message string)
}
// Subject 主题接口
type Subject interface {
Subscribe(observer Observer)
Unsubscribe(observer Observer)
Notify(message string)
}Observer 接口只有一个 Update 方法，用于接收通知。Subject 接口提供订阅、取消订阅和广播通知的功能。
立即学习“go语言免费学习笔记（深入）”；
实现事件中心
接下来实现一个事件中心，作为具体的主题，管理所有订阅者。
import "sync"
// EventCenter 具体的主题实现
type EventCenter struct {
observers []Observer
mutex sync.Mutex
}
// NewEventCenter 创建新的事件中心
func NewEventCenter() *EventCenter {
return &EventCenter{
observers: make([]Observer, 0),
}
}
// Subscribe 添加观察者
func (ec *EventCenter) Subscribe(observer Observer) {
ec.mutex.Lock()
defer ec.mutex.Unlock()
ec.observers = append(ec.observers, observer)
}
// Unsubscribe 移除观察者
func (ec *EventCenter) Unsubscribe(observer Observer) {
ec.mutex.Lock()
defer ec.mutex.Unlock()
for i, obs := range ec.observers {
if obs == observer {
ec.observers = append(ec.observers[:i], ec.observers[i+1:]...)
break
}
}
}
// Notify 向所有观察者发送通知
func (ec *EventCenter) Notify(message string) {
ec.mutex.Lock()
defer ec.mutex.Unlock()
for _, observer := range ec.observers {
observer.Update(message)
}
}使用 sync.Mutex 保证并发安全，避免多个goroutine同时修改观察者列表。
创建具体观察者
定义几个具体的观察者类型，比如邮件通知和日志记录。
// EmailNotifier 邮件通知观察者
type EmailNotifier struct{}
func (e *EmailNotifier) Update(message string) {
println("发送邮件通知: " + message)
}
// LogWatcher 日志监听观察者
type LogWatcher struct{}
func (l *LogWatcher) Update(message string) {
println("记录日志: " + message)
}使用示例
现在将所有部分组合起来，测试事件订阅与通知流程。
func main() {
// 创建事件中心
eventCenter := NewEventCenter()
// 创建观察者
emailNotifier := &EmailNotifier{}
logWatcher := &LogWatcher{}
// 订阅事件
eventCenter.Subscribe(emailNotifier)
eventCenter.Subscribe(logWatcher)
// 发布通知
eventCenter.Notify("系统配置已更新")
// 取消某个订阅
eventCenter.Unsubscribe(emailNotifier)
// 再次通知，只有日志观察者收到
eventCenter.Notify("用户登录成功")
}输出结果：
发送邮件通知: 系统配置已更新 记录日志: 系统配置已更新 记录日志: 用户登录成功
可以看到，第一次通知时两个观察者都收到了消息；取消 emailNotifier 的订阅后，它不再接收后续通知。
基本上就这些。这个实现简单、清晰，适用于大多数本地事件通知场景。可根据需要扩展支持按事件类型分类、异步通知、带上下文的事件等。不复杂但容易忽略并发安全和取消订阅的边界处理。
