golang实现发布订阅模式

发布订阅模式是一种常用的软件设计模式，它允许多个观察者订阅某个主题，并在主题发生变化时自动收到通知。在Golang中，我们可以通过使用goroutine和channel来实现发布订阅模式，本文将介绍如何使用Golang实现这一模式。

使用golang中的goroutine和channel

Golang中的goroutine是轻量级的线程，可以在并发中高效地执行任务。同时，Golang中的channel则允许不同goroutine之间进行通信。这两个特性使得Golang成为实现发布订阅模式的理想语言。

要实现发布订阅模式，我们首先需要定义一个主题（Topic）结构体，其中包含一个订阅者列表，用于保存订阅了该主题的观察者：

```go type Topic struct { subscribers []chan string } ```

接下来，我们可以定义一些与主题相关的操作方法，比如添加订阅者（AddSubscriber）和发布消息（PublishMessage）：

```go func (t *Topic) AddSubscriber() chan string { ch := make(chan string) t.subscribers = append(t.subscribers, ch) return ch } func (t *Topic) PublishMessage(message string) { for _, ch := range t.subscribers { go func(c chan string) { c <- message }(ch) } } ```

订阅者和观察者

在发布订阅模式中，观察者（Observer）是订阅了某个主题的对象，而订阅者（Subscriber）则是用于保存观察者的数据结构。

在Golang中，我们可以使用channel来实现观察者和订阅者之间的通信。当一个观察者订阅某个主题时，我们为其创建一个channel，并保存到订阅者中。每当主题发布消息时，观察者将会从channel中接收到该消息。

下面是一个示例代码，演示了如何创建一个订阅者，并订阅一个主题：

```go type Subscriber struct { name string ch chan string } func main() { topic := Topic{} subscriber := Subscriber{ name: "Alice", ch: topic.AddSubscriber(), } go func() { for { message := <-subscriber.ch fmt.Println(subscriber.name, "received:", message) } }() topic.PublishMessage("Hello, world!") time.Sleep(time.Second) } ```

多个观察者订阅同一主题

通过上述方式，我们可以让一个观察者订阅一个主题。但实际上，发布订阅模式的一个重要特性是允许多个观察者订阅同一主题。

为了实现此功能，我们可以将订阅者列表从主题结构体中移动到外部，使用一个全局的map来保存所有订阅者。在发布消息时，我们遍历该map并逐个向订阅者发送消息。

下面是一个示例代码，演示了如何实现多个观察者订阅同一主题：

```go var subscribers = make(map[string]chan string) func AddSubscriber(name string) chan string { ch := make(chan string) subscribers[name] = ch return ch } func PublishMessage(message string) { for _, ch := range subscribers { go func(c chan string) { c <- message }(ch) } } func main() { subscriber1 := AddSubscriber("Alice") subscriber2 := AddSubscriber("Bob") go func() { for { message := <-subscriber1 fmt.Println("Alice received:", message) } }() go func() { for { message := <-subscriber2 fmt.Println("Bob received:", message) } }() PublishMessage("Hello, world!") time.Sleep(time.Second) } ```

通过以上代码，我们可以让多个观察者同时订阅同一个主题，并在主题发生变化时，所有观察者都会收到通知。

总之，在Golang中，通过使用goroutine和channel，我们可以轻松地实现发布订阅模式。通过将订阅者和观察者间的通信抽象为channel，并借助goroutine实现并发，我们可以高效地处理主题和观察者之间的消息传递。同时，我们还可以使用全局变量保存所有订阅者，并在发布消息时向所有订阅者发送通知。