Go语言观察者模式实现与通知教程

本文介绍了如何在Go语言中利用通道（channel）、goroutine和互斥锁等原生并发机制，从零实现一个轻量、线程安全且可扩展的观察者模式属性通知系统——无需依赖第三方框架或语言内置特性，就能让多个监听器实时响应共享变量的变化，特别适用于进度条更新、多视图状态同步等典型场景，代码简洁易懂、高度复用，充分展现了Go“通过通信共享内存”的设计哲学与工程实践力。

在 Go 中可通过通道（channel）构建轻量级属性变更通知机制，让多个监听器实时响应共享变量的变化，适用于进度条、状态同步等多视图更新场景。

Go 作为一门强调显式通信与并发安全的语言，并未内置类似 Qt 的 Q_PROPERTY 或 C# 的 INotifyPropertyChanged 等属性变更通知机制。但我们可以利用其核心并发原语——带缓冲的通道（buffered channel） 和 goroutine，轻松实现一个线程安全、可扩展的“发布-订阅”式属性变更通知系统。

以下是一个简洁、可复用的实现思路：将属性封装为结构体，内部维护值、监听者通道切片及互斥锁（保障并发写安全），并提供 GetNotifier() 和 Set() 方法：

package main

import (
    "fmt"
    "sync"
    "time"
)

type ObservableInt struct {
    mu       sync.RWMutex
    value    int
    listeners []chan int
}

func NewObservableInt(initial int) *ObservableInt {
    return &ObservableInt{
        value: initial,
        listeners: make([]chan int, 0),
    }
}

// GetNotifier 返回一个新的只读通知通道，用于监听值变更
func (o *ObservableInt) GetNotifier() <-chan int {
    ch := make(chan int, 5) // 缓冲避免阻塞发送方
    o.mu.Lock()
    o.listeners = append(o.listeners, ch)
    o.mu.Unlock()
    return ch
}

// Set 更新值并广播给所有监听者
func (o *ObservableInt) Set(v int) {
    o.mu.Lock()
    o.value = v
    // 广播前复制切片，避免遍历时被并发修改
    listeners := make([]chan int, len(o.listeners))
    copy(listeners, o.listeners)
    o.mu.Unlock()

    for _, ch := range listeners {
        select {
        case ch <- v:
        default:
            // 通道满时跳过（可按需替换为日志或重试逻辑）
        }
    }
}

// CloseAll 关闭所有监听通道，通知监听器停止
func (o *ObservableInt) CloseAll() {
    o.mu.Lock()
    defer o.mu.Unlock()
    for _, ch := range o.listeners {
        close(ch)
    }
    o.listeners = nil
}

监听端只需启动 goroutine 持续接收通知：

func Watch(name string, ch <-chan int, done chan<- bool) {
    for v := range ch {
        fmt.Printf("[%s] received update: %d\n", name, v)
    }
    done <- true
}

完整使用示例：

func main() {
    obs := NewObservableInt(0)

    done := make(chan bool, 2)
    go Watch("ProgressBar", obs.GetNotifier(), done)
    go Watch("TextDisplay", obs.GetNotifier(), done)

    time.Sleep(100 * time.Millisecond)
    obs.Set(42)
    time.Sleep(100 * time.Millisecond)
    obs.Set(87)

    obs.CloseAll()
    <-done
    <-done
}

注意事项与最佳实践：

• ✅ 使用 sync.RWMutex 保护监听器列表读写，避免并发 panic；
• ✅ 通道设为带缓冲（如 make(chan int, 5)），防止广播时因某个监听器处理慢而阻塞全局更新；
• ✅ Set() 中先复制监听器切片再广播，规避“遍历中修改 slice”的竞态风险；
• ⚠️ 避免无限缓存：若监听器长期不消费，缓冲区满后新通知将被丢弃（default 分支）——可根据业务选择阻塞发送、日志告警或动态扩容通道；
• ? 进阶可封装为泛型版本（Go 1.18+）支持任意类型，或集成 context.Context 实现优雅关闭。

该模式轻量、无第三方依赖，完美契合 Go “通过通信共享内存”的哲学，是构建响应式 UI 层、状态同步服务或配置热更新系统的理想起点。

理论要掌握，实操不能落！以上关于《Go语言观察者模式实现与通知教程》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！