当前位置：首页 > 文章列表 > Golang > Go教程 > Go语言观察者模式实现与通知教程

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

2026-03-05 20:27:57 0浏览收藏

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

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
}

注意事项与最佳实践：