Golang观察者模式与发布订阅实现方法

编程并不是一个机械性的工作，而是需要有思考，有创新的工作，语法是固定的，但解决问题的思路则是依靠人的思维，这就需要我们坚持学习和更新自己的知识。今天golang学习网就整理分享《Golang观察者模式与发布订阅实现技巧》，文章讲解的知识点主要包括，如果你对Golang方面的知识点感兴趣，就不要错过golang学习网，在这可以对大家的知识积累有所帮助，助力开发能力的提升。

观察者模式通过主题维护观察者列表并在状态变化时通知，发布订阅模式利用channel和EventBus解耦发布与订阅；两者均适用于消息广播、状态同步等场景。

观察者模式和发布订阅模式在事件驱动系统中非常常见，Golang 虽然没有内置的事件机制，但通过接口、channel 和 goroutine 可以轻松实现这两种模式。它们常用于解耦模块、实现消息广播、状态同步等场景。

观察者模式的基本实现

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

核心结构包含两个角色：主题（Subject）和观察者（Observer）。主题维护观察者列表，并在状态变化时通知它们。

示例代码：

type Observer interface {
    Update(message string)
}
<p>type Subject struct {
observers []Observer
state     string
}</p><p>func (s *Subject) Attach(o Observer) {
s.observers = append(s.observers, o)
}</p><p>func (s *Subject) Notify() {
for _, o := range s.observers {
o.Update(s.state)
}
}</p><p>func (s *Subject) SetState(state string) {
s.state = state
s.Notify()
}</p><p>type ConcreteObserver struct {
name string
}</p><p>func (co *ConcreteObserver) Update(message string) {
fmt.Printf("[%s] 收到通知: %s\n", co.name, message)
}
</p>

使用方式：创建主题，注册多个观察者，调用 SetState 后所有观察者自动更新。

发布订阅模式的实现（基于 Channel）

发布订阅模式更进一步，通过中间的“事件总线”解耦发布者和订阅者。Golang 的 channel 非常适合这种异步通信。

与观察者模式不同，发布者不直接维护订阅者列表，而是将消息发送到某个 topic 的 channel 中，由调度器转发给订阅者。

实现思路：

• 定义一个 EventBus，管理多个 topic 对应的 channel
• 订阅者通过 Subscribe 注册到指定 topic
• 发布者通过 Publish 向 topic 发送消息
• 使用 goroutine 异步处理消息，避免阻塞

type EventBus struct {
    subscribers map[string][]chan string
    mutex       sync.RWMutex
}
<p>func NewEventBus() *EventBus {
return &EventBus{
subscribers: make(map[string][]chan string),
}
}</p><p>func (eb *EventBus) Subscribe(topic string) <-chan string {
ch := make(chan string, 10) // 缓冲 channel 避免阻塞
eb.mutex.Lock()
eb.subscribers[topic] = append(eb.subscribers[topic], ch)
eb.mutex.Unlock()
return ch
}</p><p>func (eb *EventBus) Publish(topic, message string) {
eb.mutex.RLock()
subs := eb.subscribers[topic]
eb.mutex.RUnlock()</p><pre class="brush:php;toolbar:false"><code>for _, ch := range subs {
    select {
    case ch <- message:
    default:
        // 防止因消费者慢导致阻塞
    }
}</code>

}

实际应用场景与技巧

这类模式广泛应用于日志系统、配置热更新、微服务通信、UI 状态同步等。

技巧一：使用 goroutine 异步通知
避免在主线程中同步调用所有观察者，影响性能。可以为每个通知启动 goroutine：

for _, o := range s.observers {
    go o.Update(s.state) // 异步执行
}

技巧二：支持 topic 匹配（通配符）
高级消息系统常支持模糊订阅，如 "user.*" 匹配 "user.create" 和 "user.delete"。可通过正则或前缀匹配扩展 EventBus。

技巧三：资源清理
长时间运行的服务需注意 channel 泄漏。可提供 Unsubscribe 方法，并使用 context 控制生命周期：

func (eb *EventBus) Unsubscribe(topic string, ch <p><strong>技巧四：结合 context 实现超时控制</strong><br>
在发布消息时加入 context，防止某些订阅者处理过慢拖累整体：</p><p></p><pre class="brush:php;toolbar:false;">
ctx, cancel := context.WithTimeout(context.Background(), 100*time.Millisecond)
defer cancel()
<p>select {
case ch <- message:
case <-ctx.Done():
// 跳过慢速订阅者
}
</p>

基本上就这些。观察者模式适合对象间紧耦合的通知，发布订阅更适合跨模块、异步、松耦合的通信。Golang 凭借 channel 和并发模型，实现起来简洁高效。关键是根据业务选择合适粒度的 topic 和合理的缓冲策略，避免阻塞和泄漏。

到这里，我们也就讲完了《Golang观察者模式与发布订阅实现方法》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！