golang 订阅模式

发布时间:2024-11-05 19:05:14

Golang订阅模式: 实现松耦合的系统通信

什么是订阅模式

订阅模式是一种常用的软件设计模式，它用于实现系统中不同组件之间的松耦合通信。通过订阅模式，系统中的一个组件可以向其他组件发布消息，并且只有那些订阅了相关消息的组件才会收到通知。

Golang中的订阅模式

在Golang中，我们可以使用一些机制来实现订阅模式。最常见的是使用回调函数或者使用通道来传递消息。

使用回调函数实现订阅模式

回调函数是指一个函数作为参数传递给另一个函数，并在特定事件触发时被调用。在Golang中，我们可以定义一个回调函数类型，并将其作为参数传递给其他函数。这样，当某个事件触发时，我们可以调用该回调函数来执行相应的逻辑。

以下是一个使用回调函数实现订阅模式的简单示例：

```go package main import "fmt" type Callback func(string) type Publisher struct { callbacks []Callback } func (p *Publisher) Subscribe(callback Callback) { p.callbacks = append(p.callbacks, callback) } func (p *Publisher) Publish(message string) { for _, callback := range p.callbacks { callback(message) } } func main() { publisher := Publisher{} // 订阅者A subscriberA := func(message string) { fmt.Println("Subscriber A received:", message) } // 订阅者B subscriberB := func(message string) { fmt.Println("Subscriber B received:", message) } // 订阅消息 publisher.Subscribe(subscriberA) publisher.Subscribe(subscriberB) // 发布消息 publisher.Publish("Hello, World!") } ```

输出结果：

``` Subscriber A received: Hello, World! Subscriber B received: Hello, World! ```

使用通道实现订阅模式

通道是Golang中用于在协程之间进行通信的主要机制。我们可以使用通道来实现订阅模式，通过将消息发送到通道中的订阅者来实现消息的传递。

以下是一个使用通道实现订阅模式的简单示例：

```go package main import "fmt" type Subscriber struct { channel chan string } func NewSubscriber() *Subscriber { return &Subscriber{channel: make(chan string)} } func (s *Subscriber) Subscribe() <-chan string { return s.channel } type Publisher struct { subscribers []*Subscriber } func (p *Publisher) AddSubscriber(subscriber *Subscriber) { p.subscribers = append(p.subscribers, subscriber) } func (p *Publisher) Publish(message string) { for _, subscriber := range p.subscribers { subscriber.channel <- message } } func main() { publisher := Publisher{} // 创建订阅者 subscriberA := NewSubscriber() subscriberB := NewSubscriber() // 添加订阅者 publisher.AddSubscriber(subscriberA) publisher.AddSubscriber(subscriberB) // 开启协程，监听订阅者的消息 go func() { for { select { case message := <-subscriberA.Subscribe(): fmt.Println("Subscriber A received:", message) case message := <-subscriberB.Subscribe(): fmt.Println("Subscriber B received:", message) } } }() // 发布消息 publisher.Publish("Hello, World!") // 阻塞主协程，避免程序退出 c := make(chan struct{}) <-c } ```