Golang优雅实现观察者模式：channel与goroutine方案

观察者模式在 Go 中通过 channel 和 goroutine 实现，核心组件包括 Subject、Observer 和 Event。1. Subject 管理观察者列表并在状态变化时通知它们；2. Observer 是监听 channel 的 goroutine，接收事件并处理；3. Event 用于封装通知内容。注册观察者即将其加入 Subject 列表，通知则通过遍历列表发送事件，并使用 goroutine 并发执行以避免阻塞。为支持反馈，可使用结构体代替简单事件。每个观察者持续监听 channel，处理事件时可结合业务逻辑。程序退出时应关闭 channel 并回收 goroutine，防止泄漏，可通过维护 done channel 实现优雅关闭。这种方式轻量且易扩展，符合 Go 的并发模型。

观察者模式的核心在于“事件通知”，当某个对象状态发生变化时，所有依赖它的对象都会被自动通知。在 Go 语言中，使用 channel 和 goroutine 实现这一模式既高效又简洁。

基本结构设计

要实现观察者模式，需要定义几个核心组件：

• Subject（主题）：负责管理观察者列表，并在状态变化时通知它们。
• Observer（观察者）：接收通知并作出响应。
• Event（事件）：可选，用于封装通知内容。

用 Go 来实现的话，可以将 Subject 看作一个包含 channel 的结构体，每个 Observer 是一个监听该 channel 的 goroutine。

type Event string

type Observer chan Event

type Subject struct {
    observers []Observer
}

这样每个 Observer 都是一个接收 Event 的 channel。

注册和通知机制

注册观察者的过程其实就是把 Observer 添加到 Subject 的列表中。而通知就是遍历这些 Observer 并发送事件。

func (s *Subject) Register(obs Observer) {
    s.observers = append(s.observers, obs)
}

func (s *Subject) Notify(event Event) {
    for _, obs := range s.observers {
        go func(o Observer) {
            o <- event
        }(obs)
    }
}

这里用了 go func(...) 包裹发送操作，确保每个通知都在独立的 goroutine 中执行，避免阻塞主线程。

小技巧：如果你希望观察者处理完事件后能反馈结果，可以在 Observer channel 中使用结构体而不是简单字符串，比如：

type Response struct {
    Success bool
    Msg     string
}

type Observer chan struct {
    Event    Event
    Response chan Response
}

观察者的启动与处理

每个观察者本质上是一个运行中的 goroutine，持续监听来自 channel 的事件：

func StartObserver(id string) Observer {
    obs := make(Observer)
    go func() {
        for event := range obs {
            fmt.Printf("Observer %s received event: %s\n", id, event)
            // 处理逻辑
        }
    }()
    return obs
}

你可以创建多个这样的观察者，并注册到 Subject 上。

完整使用示例：

subject := &Subject{}
observer1 := StartObserver("A")
observer2 := StartObserver("B")

subject.Register(observer1)
subject.Register(observer2)

subject.Notify("system:reboot")

这样就能看到两个观察者各自收到通知并打印信息了。

优雅关闭和资源回收

如果程序是长期运行的服务，要注意对 Observer channel 的关闭，避免 goroutine 泄漏。

一种做法是在 Subject 中维护一个 done channel，在清理时关闭所有 Observer：

type Subject struct {
    observers []Observer
    done      chan struct{}
}

func (s *Subject) Stop() {
    close(s.done)
    for _, obs := range s.observers {
        close(chan obs)
    }
}

然后在观察者的循环中监听 done 信号：

go func() {
    for {
        select {
        case event := <-obs:
            // handle event
        case <-s.done:
            return
        }
    }
}()

这样就能安全退出所有 goroutine。

基本上就这些。这种基于 channel 和 goroutine 的方式非常符合 Go 的并发模型，也足够轻量、易扩展。只要注意好 channel 的生命周期和 goroutine 的回收，就是一个很实用的观察者实现方案。