观察者模式在Go中通过接口和切片实现，用于解耦事件发布与处理；示例中Subject维护Observer列表，支持动态订阅与通知，适用于消息广播、状态更新等场景。
在Go语言中，Observer（观察者）模式是一种常用的设计模式，适用于事件驱动的场景，比如消息通知、状态变更广播等。该模式定义了对象之间的一对多依赖关系，当一个对象状态改变时，所有依赖它的对象都会收到通知。
基本结构说明
观察者模式包含两个核心角色：
Subject（主题）：维护观察者列表，提供订阅、取消订阅和通知方法。 Observer（观察者）：实现通知接口，接收状态更新。
在Go中，可以通过接口和切片来实现这一模式。
代码实现示例
下面是一个简单的事件订阅与通知示例：
立即学习“go语言免费学习笔记（深入）”；
package mainimport "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 registeredLog recorded: User registeredLog recorded: User logged in
第一次通知时，两个观察者都收到消息；取消email订阅后，第二次仅日志服务被触发。
实际应用场景
这种模式适合用于解耦事件发布与处理逻辑，例如：
用户注册后发送邮件、记录日志、初始化配置等。 系统状态变更时通知多个监控模块。 微服务间通过事件总线通信（可结合channel进一步封装）。
基本上就这些。Go的接口和组合机制让Observer模式实现简洁清晰，无需复杂继承体系。根据需要，还可以加入goroutine实现异步通知，提升性能。
以上就是Golang Observer事件订阅与通知模式示例的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1411077.html
微信扫一扫 
支付宝扫一扫 
