Golang如何使用观察者模式实现事件订阅

观察者模式通过Subject和Observer接口实现事件订阅与通知，使用EventCenter管理观察者并线程安全地广播事件，需注意及时取消订阅以避免内存泄漏。

在Go语言中，观察者模式可用于实现事件的订阅与通知机制，常见于解耦事件发布者和多个响应者。通过定义主题（Subject）和观察者（Observer）接口，可以灵活地管理事件订阅、取消和广播。

定义观察者和主题接口

观察者模式的核心是主题和观察者之间的约定。主题负责维护订阅者列表，并在状态变化时通知所有观察者。

Observer接口：定义接收通知的方法。
Subject接口：定义添加、删除和通知观察者的方法。

type Event string

type Observer interface {
    OnNotify(Event)
}

type Subject interface {
    Subscribe(Observer)
    Unsubscribe(Observer)
    Notify(Event)
}

实现事件中心

使用一个结构体实现Subject接口，维护观察者集合，并提供线程安全的操作。

func NewEventCenter() *EventCenter { return &EventCenter{ observers: make(map[Observer]bool), } }

func (ec *EventCenter) Subscribe(o Observer) { ec.mutex.Lock() defer ec.mutex.Unlock() ec.observers[o] = true }

func (ec *EventCenter) Unsubscribe(o Observer) { ec.mutex.Lock() defer ec.mutex.Unlock() delete(ec.observers, o) }

func (ec *EventCenter) Notify(event Event) { ec.mutex.RLock() defer ec.mutex.RUnlock() for observer := range ec.observers { observer.OnNotify(event) } }

编写具体观察者
每个需要响应事件的组件实现Observer接口即可自动接收通知。
立即学习“go语言免费学习笔记（深入）”；

							

								
								

									百度文心百中
									
百度大模型语义搜索体验中心
								
								下载 
							
						
例如，日志记录器和邮件通知服务：
```go
type Logger struct{}

func (l *Logger) OnNotify(event Event) {
    fmt.Printf("日志记录: %s\n", event)
}

type EmailNotifier struct{}

func (e *EmailNotifier) OnNotify(event Event) {
    if event == "user_registered" {
        fmt.Println("发送欢迎邮件...")
    }
}

使用示例

将观察者注册到事件中心，触发事件后自动广播。

logger := &Logger{}
emailer := &EmailNotifier{}

center.Subscribe(logger)
center.Subscribe(emailer)

center.Notify("user_registered")
// 输出:
// 日志记录: user_registered
// 发送欢迎邮件...

center.Unsubscribe(emailer)
center.Notify("order_paid")
// 只有日志输出

}

基本上就这些。Go没有内置事件系统，但通过接口和组合，能简洁实现观察者模式。关键是避免内存泄漏——记得在适当时机取消订阅，尤其是短期存在的观察者。