Go中观察者模式可通过channel和goroutine实现，核心为Subject维护观察者channel列表，状态变更时通过Notify向各observer广播Event，利用RWMutex保证并发安全，select+default实现非阻塞通知，Close方法关闭所有channel防止泄漏，适用于事件驱动架构。
在Go语言中，观察者模式可以通过
channel
和
goroutine
天然地实现事件通知机制。这种模式适用于解耦事件发布者和多个订阅者，比如在系统状态变更、消息广播或事件驱动架构中非常实用。
观察者模式核心思想
观察者模式定义了一种一对多的依赖关系，当一个对象（被观察者）的状态发生变化时，所有依赖它的对象（观察者）都会收到通知并自动更新。
在Go中，我们可以使用
channel
作为消息传递的媒介，利用其并发安全的特性，避免显式加锁。
基本结构设计
我们需要三个核心组件：
立即学习“go语言免费学习笔记（深入）”；
Event：表示事件数据Observer：接收事件的订阅者Subject：事件发布者，维护观察者列表并通过channel广播
以下是一个简洁的实现示例：
package mainimport ( "fmt" "sync")// Event 事件结构type Event struct { Type string Data interface{}}// Observer 观察者接口type Observer interface { Update(event Event)}// Subject 被观察者type Subject struct { observers []chan Event // 所有观察者的channel mutex sync.RWMutex closed bool}func NewSubject() *Subject { return &Subject{ observers: make([]chan Event, 0), closed: false, }}// Subscribe 添加观察者，返回用于接收事件的channelfunc (s *Subject) Subscribe() <-chan Event { s.mutex.Lock() defer s.mutex.Unlock() if s.closed { return nil } ch := make(chan Event, 10) // 带缓冲避免阻塞 s.observers = append(s.observers, ch) return ch}// Notify 通知所有观察者func (s *Subject) Notify(event Event) { s.mutex.RLock() defer s.mutex.RUnlock() for _, ch := range s.observers { select { case ch <- event: default: // 非阻塞发送，观察者处理慢也不会影响发布者 } } }}// Close 关闭所有观察者channelfunc (s *Subject) Close() { s.mutex.Lock() defer s.mutex.Unlock() if s.closed { return } s.closed = true for _, ch := range s.observers { close(ch) } s.observers = nil}
使用示例
下面演示如何使用上述实现：
func main() { subject := NewSubject() // 创建两个观察者 observer1 := subject.Subscribe() observer2 := subject.Subscribe() // 启动两个监听goroutine go func() { for event := range observer1 { fmt.Printf("Observer1 收到事件: %s, 数据: %vn", event.Type, event.Data) } fmt.Println("Observer1 已关闭") }() go func() { for event := range observer2 { fmt.Printf("Observer2 收到事件: %s, 数据: %vn", event.Type, event.Data) } fmt.Println("Observer2 已关闭") }() // 发布事件 subject.Notify(Event{Type: "user.login", Data: "alice"}) subject.Notify(Event{Type: "system.update", Data: "v1.0.0"}) // 模拟运行一段时间后关闭 subject.Close() // 防止主goroutine退出过早 select {}}
关键设计点说明
并发安全：使用
sync.RWMutex
保护观察者列表的读写操作，确保多goroutine环境下安全。
非阻塞通知：通过
select...default
实现非阻塞发送，避免某个观察者处理缓慢拖慢整个系统。
资源释放：提供
Close()
方法关闭所有channel，防止goroutine泄漏。
缓冲channel：每个观察者使用带缓冲的channel，提升异步处理能力。
基本上就这些。这种基于channel的实现简洁、高效，符合Go的并发哲学，适合大多数事件通知场景。
以上就是Golang观察者模式实现 channel事件通知机制的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1399064.html
微信扫一扫 
支付宝扫一扫 
