观察者模式是一种“一对多”的依赖关系设计，当一个对象状态变化时，所有依赖它的对象都会收到通知并自动更新。在 golang 中，可通过 channel 实现事件发布/订阅机制：1. 定义 event 结构表示事件数据；2. observer 作为接收事件的函数类型；3. eventbus 维护 observer 的 channel 列表。注册时通过 subscribe() 添加 channel，发布时通过 publish() 使用 goroutine 广播事件。注意事项包括使用缓冲 channel、实现取消订阅、处理错误和优化性能。实际中可结合业务场景灵活扩展功能。
在用 Golang 实现观察者模式时，利用 channel 来实现事件驱动是一种常见且高效的做法。Golang 的并发模型天然支持 goroutine 和 channel，这让事件订阅和通知机制变得简单清晰。
什么是观察者模式？
观察者模式的核心是“一对多”的依赖关系：当一个对象状态发生变化时，所有依赖它的对象都会收到通知并自动更新。这种模式非常适合用来实现事件系统，比如 UI 状态变化、日志通知、消息推送等场景。
在 Golang 中，我们可以借助接口(interface)来定义观察者的行为，使用 channel 来作为事件的传输通道，再配合 goroutine 来异步处理通知逻辑。
立即学习“go语言免费学习笔记（深入）”；
如何用 channel 实现事件发布/订阅
为了实现事件驱动的观察者模式，我们需要几个核心组件：
- 事件源（Subject）：负责管理观察者列表，并在事件发生时通知它们。
- 观察者（Observer）：接收事件并做出响应。
- 事件通道（Channel）：用于传递事件数据。
示例结构如下：
type Event struct {
Name string
Data interface{}
}
type Observer func(Event)
type EventBus struct {
observers []chan Event
}在这个例子中：
-
Event是事件的数据结构； -
Observer是一个函数类型，接受一个事件； -
EventBus是事件总线，维护多个 observer 的 channel。
注册观察者
观察者的注册其实就是向 EventBus 添加一个 channel 的过程：
func (bus *EventBus) Subscribe() chan Event {
ch := make(chan Event)
bus.observers = append(bus.observers, ch)
return ch
}每个调用 Subscribe() 的地方都会得到一个独立的 channel，用于监听事件。
发布事件
发布事件就是把事件广播给所有注册了的 channel：
func (bus *EventBus) Publish(event Event) {
for _, ch := range bus.observers {
go func(c chan Event) {
c <- event
}(ch)
}
}这里用了 goroutine 来发送事件，避免阻塞主线程。
实际使用中的注意事项
虽然上面的结构已经可以运行，但在实际项目中还需要注意以下几点：
- channel 缓冲问题：如果事件频率高，建议使用带缓冲的 channel，否则容易造成 goroutine 阻塞。
- 取消订阅机制：目前没有提供取消订阅的功能，可以考虑通过返回一个取消函数或维护 map 来优化。
- 错误处理：观察者可能 panic 或出错，建议在接收端加上 recover 处理。
- 性能问题：如果观察者很多，要考虑是否需要限制并发数量或采用 worker pool 模式。
举个例子，在事件消费端你可以这样写：
ch := bus.Subscribe()
go func() {
for event := range ch {
fmt.Printf("Received event: %s\n", event.Name)
}
}()结合业务场景灵活使用
在实际开发中，事件系统往往不会这么简单。例如：
- 可能需要根据事件类型过滤；
- 有些事件需要同步执行，有些可以异步；
- 还可能需要优先级队列、超时控制等高级功能。
但如果你只是想快速搭建一个轻量级的事件通知系统，上面的方法已经足够使用。
基本上就这些。
