Go语言中的观察者模式实现

浅瑶同学_5482

发布时间：2025-07-18 17:28:12

748人浏览过

来源于php中文网

原创

go语言中的观察者模式实现

本文将介绍如何在Go语言中实现观察者模式，利用Go语言的channel特性，我们可以轻松构建发布者-订阅者模型，实现对象间的事件通知。文章提供了代码示例，展示了如何创建发布者、订阅者，以及如何进行订阅和发布消息，并强调了使用channel进行并发处理的重要性。

观察者模式是一种行为设计模式，它定义了对象之间的一对多依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都会收到通知并自动更新。在Go语言中，我们可以利用channel来实现观察者模式，充分发挥Go语言在并发处理方面的优势。

实现思路

核心思想是使用channel作为消息传递的媒介。发布者（Publisher）维护一个订阅者（Subscriber）channel列表，当发布者状态发生改变时，它会将消息发送到所有订阅者的channel中。订阅者则监听自己的channel，一旦收到消息，就进行相应的处理。

Go语言（Golang）1.26.0

Go语言（Golang）1.26.0版本官方下载，版本号 1.26.0，适合旧项目维护、兼容性测试和指定版本开发环境搭建。

下载

代码示例

以下是一个简单的观察者模式的Go语言实现示例：

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

package main

import (
    "fmt"
    "time"
)

// Msg 定义消息结构
type Msg struct {
    Data string
}

// Publisher 定义发布者
type Publisher struct {
    listeners []chan *Msg
}

// Subscriber 定义订阅者
type Subscriber struct {
    ID      int
    Channel chan *Msg
}

// NewPublisher 创建一个新的发布者
func NewPublisher() *Publisher {
    return &Publisher{
        listeners: make([]chan *Msg, 0),
    }
}

// NewSubscriber 创建一个新的订阅者
func NewSubscriber(id int) *Subscriber {
    return &Subscriber{
        ID:      id,
        Channel: make(chan *Msg, 1), // 使用缓冲channel防止阻塞
    }
}

// Sub 订阅方法，将订阅者的channel添加到发布者的监听列表
func (p *Publisher) Sub(c chan *Msg) {
    p.listeners = append(p.listeners, c)
}

// Pub 发布消息方法，将消息发送到所有订阅者的channel
func (p *Publisher) Pub(m *Msg) {
    for _, c := range p.listeners {
        // 使用 goroutine 防止某个订阅者阻塞导致其他订阅者无法收到消息
        go func(ch chan *Msg) {
            ch <- m
        }(c)
    }
}

// ListenOnChannel 订阅者监听channel并处理消息
func (s *Subscriber) ListenOnChannel() {
    for data := range s.Channel {
        fmt.Printf("Subscriber %d received message: %s\n", s.ID, data.Data)
    }
}

func main() {
    // 创建发布者
    publisher := NewPublisher()

    // 创建订阅者
    subscriber1 := NewSubscriber(1)
    subscriber2 := NewSubscriber(2)

    // 订阅
    publisher.Sub(subscriber1.Channel)
    publisher.Sub(subscriber2.Channel)

    // 启动订阅者的监听goroutine
    go subscriber1.ListenOnChannel()
    go subscriber2.ListenOnChannel()

    // 发布消息
    publisher.Pub(&Msg{Data: "Hello, Subscriber 1 and 2!"})
    publisher.Pub(&Msg{Data: "Another message!"})

    // 等待一段时间，确保所有消息都被处理
    time.Sleep(1 * time.Second)

    // 关闭channel，通知订阅者退出
    close(subscriber1.Channel)
    close(subscriber2.Channel)
}