Golang观察者模式实现 channel事件通知机制-Golang-PHP中文网

Golang观察者模式实现 channel事件通知机制

P粉602998670

发布： 2025-08-20 08:52:01

原创

909人浏览过

Go中观察者模式可通过channel和goroutine实现，核心为Subject维护观察者channel列表，状态变更时通过Notify向各observer广播Event，利用RWMutex保证并发安全，select+default实现非阻塞通知，Close方法关闭所有channel防止泄漏，适用于事件驱动架构。

golang观察者模式实现 channel事件通知机制

在Go语言中，观察者模式可以通过

channel

登录后复制

和

goroutine

登录后复制

天然地实现事件通知机制。这种模式适用于解耦事件发布者和多个订阅者，比如在系统状态变更、消息广播或事件驱动架构中非常实用。

观察者模式核心思想

观察者模式定义了一种一对多的依赖关系，当一个对象（被观察者）的状态发生变化时，所有依赖它的对象（观察者）都会收到通知并自动更新。

在Go中，我们可以使用

channel

登录后复制

作为消息传递的媒介，利用其并发安全的特性，避免显式加锁。

基本结构设计

我们需要三个核心组件：

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

Event：表示事件数据
Observer：接收事件的订阅者
Subject：事件发布者，维护观察者列表并通过channel广播

以下是一个简洁的实现示例：

package main

import (
    "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 添加观察者，返回用于接收事件的channel
func (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 关闭所有观察者channel
func (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
}

登录后复制

使用示例

下面演示如何使用上述实现：

知我AI·PC客户端

离线运行 AI 大模型，构建你的私有个人知识库，对话式提取文件知识，保证个人文件数据安全

查看详情

func main() {
    subject := NewSubject()

    // 创建两个观察者
    observer1 := subject.Subscribe()
    observer2 := subject.Subscribe()

    // 启动两个监听goroutine
    go func() {
        for event := range observer1 {
            fmt.Printf("Observer1 收到事件: %s, 数据: %v\n", event.Type, event.Data)
        }
        fmt.Println("Observer1 已关闭")
    }()

    go func() {
        for event := range observer2 {
            fmt.Printf("Observer2 收到事件: %s, 数据: %v\n", 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 {}
}

登录后复制