Go语言中的观察者模式-小浪学习网

Go语言中的观察者模式

本文介绍了在go语言中实现观察者模式的方法，利用Go语言的特性，特别是channel，可以简洁高效地实现对象间的通知机制。通过定义发布者和订阅者，并使用channel进行消息传递，可以轻松实现一对多的依赖关系，实现事件驱动的编程模型。

观察者模式是一种行为设计模式，它定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。当主题对象的状态发生改变时，所有依赖它的观察者都会收到通知并自动更新。在Go语言中，我们可以利用channel来实现观察者模式，从而实现对象间的解耦和高效的消息传递。

核心概念

主题（Subject）： 也称为发布者（Publisher），维护一个观察者列表，负责注册、移除和通知观察者。
观察者（Observer）： 也称为订阅者（Subscriber），监听主题对象的状态变化，并在收到通知后执行相应的操作。

使用Channel实现观察者模式

Go语言的channel提供了一种强大的并发通信机制，非常适合用于实现观察者模式。发布者可以将消息发送到channel，而订阅者可以从channel接收消息，从而实现发布者和订阅者之间的解耦。

以下是一个使用channel实现观察者模式的示例代码：

立即学习“go语言免费学习笔记（深入）”；

package main  import (     "fmt"     "time" )  // Msg represents the message being passed between publisher and subscribers type Msg struct {     Data string }  // Publisher represents the subject in the Observer pattern type Publisher struct {     listeners []chan *Msg }  // Subscriber represents the observer in the Observer pattern type Subscriber struct {     Channel chan *Msg     ID      int }  // NewPublisher creates a new Publisher instance func NewPublisher() *Publisher {     return &Publisher{         listeners: make([]chan *Msg, 0),     } }  // NewSubscriber creates a new Subscriber instance func NewSubscriber(id int) *Subscriber {     return &Subscriber{         Channel: make(chan *Msg),         ID:      id,     } }  // Sub adds a subscriber's channel to the publisher's list of listeners func (p *Publisher) Sub(c chan *Msg) {     p.listeners = append(p.listeners, c) }  // Pub publishes a message to all subscribers func (p *Publisher) Pub(m *Msg) {     for _, c := range p.listeners {         // Sending to channel may block. Use non-blocking send.         select {         case c <- m:             fmt.Printf("Published message to subscribern")         default:             fmt.Printf("Subscriber channel is full, skipping messagen")         }      } }  // ListenOnChannel listens for messages on the subscriber's channel and processes them func (s *Subscriber) ListenOnChannel() {     for data := range s.Channel {         fmt.Printf("Subscriber %d received: %sn", s.ID, data.Data)     } }  func main() {     publisher := NewPublisher()      subscriber1 := NewSubscriber(1)     subscriber2 := NewSubscriber(2)      publisher.Sub(subscriber1.Channel)     publisher.Sub(subscriber2.Channel)      go subscriber1.ListenOnChannel()     go subscriber2.ListenOnChannel()      // Publish some messages     publisher.Pub(&Msg{Data: "Hello Subscriber 1 and 2!"})     publisher.Pub(&Msg{Data: "Another message!"})      time.Sleep(1 * time.Second) // Allow time for messages to be processed      close(subscriber1.Channel) // Signal subscriber1 to exit     close(subscriber2.Channel) // Signal subscriber2 to exit     fmt.Println("Finished") }

代码解释：

Msg 结构体: 定义了消息的结构，包含 Data 字段。
Publisher 结构体: 包含一个 listeners 字段，它是一个 chan *Msg 的切片，用于存储所有订阅者的channel。
Subscriber 结构体: 包含一个 Channel 字段，用于接收消息。
NewPublisher() 和 NewSubscriber() 函数: 用于创建 Publisher 和 Subscriber 的实例。
Sub() 方法: 将订阅者的channel添加到发布者的 listeners 列表中。
Pub() 方法: 遍历 listeners 列表，将消息发送到每个订阅者的channel。使用了非阻塞发送 (select 语句) 来避免因某个channel阻塞而影响其他channel的消息发送。
ListenOnChannel() 方法: 在一个goroutine中运行，监听订阅者的channel，并处理接收到的消息。
main() 函数: 创建发布者和订阅者，将订阅者的channel注册到发布者，然后发布一些消息。最后关闭channel，通知订阅者退出。

运行结果:

Published message to subscriber Published message to subscriber Subscriber 1 received: Hello Subscriber 1 and 2! Subscriber 2 received: Hello Subscriber 1 and 2! Published message to subscriber Published message to subscriber Subscriber 1 received: Another message! Subscriber 2 received: Another message! Finished

注意事项

Channel的关闭: 在发布者完成消息发布后，应该关闭所有订阅者的channel，以通知订阅者退出监听。否则，订阅者会一直阻塞在channel的接收操作上，导致goroutine泄漏。
错误处理: 在实际应用中，应该添加错误处理机制，例如在发送消息到channel时，可以检查channel是否已关闭，或者在接收消息时，可以处理channel关闭的信号。
并发安全: 如果多个goroutine同时访问发布者的 listeners 列表，需要使用锁来保证并发安全。
缓冲Channel: 如果发布者的发布速度远大于订阅者的处理速度，可以考虑使用带缓冲的channel，以避免发布者阻塞。但是，需要注意缓冲channel可能会导致消息的延迟。
非阻塞发送: 使用 select 语句实现非阻塞发送，防止某个订阅者阻塞导致其他订阅者无法接收消息。