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 的订阅后，它不再接收后续通知。
基本上就这些。这个实现简单、清晰，适用于大多数本地事件通知场景。可根据需要扩展支持按事件类型分类、异步通知、带上下文的事件等。不复杂但容易忽略并发安全和取消订阅的边界处理。
以上就是Golang观察者模式事件订阅与通知示例的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1404607.html
微信扫一扫 
支付宝扫一扫 
