Golang如何使用观察者模式处理事件-Golang-PHP中文网

Golang如何使用观察者模式处理事件

P粉602998670

发布： 2025-10-22 13:40:01

原创

803人浏览过

观察者模式通过Subject和Observer接口实现事件驱动，Go中可用接口与切片维护订阅关系，配合sync.RWMutex保证并发安全，示例中EventBus注册、注销并通知观察者，Logger与Notifier响应事件，主函数演示注册、触发与移除流程。

golang如何使用观察者模式处理事件

在Go语言中，观察者模式常用于实现事件处理系统，让多个对象（观察者）监听某个主体（被观察者）的状态变化或事件发生。这种模式在解耦事件发布者和订阅者方面非常有效，适合构建灵活的事件驱动程序。

定义事件主体和观察者接口

观察者模式的核心是被观察者维护一个观察者列表，并在状态变化时通知它们。先定义两个基本接口：

- Subject（被观察者）：管理观察者并负责通知。
- Observer（观察者）：定义接收通知的方法。

示例代码：

type Event string
<p>type Observer interface {
OnEvent(event Event)
}</p><p>type Subject interface {
Register(obs Observer)
Unregister(obs Observer)
Notify(event Event)
}

登录后复制

实现具体的被观察者

创建一个结构体来实现 Subject 接口。它使用切片保存观察者列表，注意并发安全时可使用 sync.RWMutex。

立即学习“go语言免费学习笔记（深入）”；

动态WEB网站中的PHP和MySQL：直观的QuickPro指南第2版

动态WEB网站中的PHP和MySQL详细反映实际程序的需求，仔细地探讨外部数据的验证(例如信用卡卡号的格式)、用户登录以及如何使用模板建立网页的标准外观。动态WEB网站中的PHP和MySQL的内容不仅仅是这些。书中还提到如何串联JavaScript与PHP让用户操作时更快、更方便。还有正确处理用户输入错误的方法，让网站看起来更专业。另外还引入大量来自PEAR外挂函数库的强大功能，对常用的、强大的包

508

查看详情

type EventBus struct {
    observers []Observer
    mu        sync.RWMutex
}
<p>func (bus *EventBus) Register(obs Observer) {
bus.mu.Lock()
defer bus.mu.Unlock()
bus.observers = append(bus.observers, obs)
}</p><p>func (bus *EventBus) Unregister(obs Observer) {
bus.mu.Lock()
defer bus.mu.Unlock()
for i, o := range bus.observers {
if o == obs {
bus.observers = append(bus.observers[:i], bus.observers[i+1:]...)
break
}
}
}</p><p>func (bus *EventBus) Notify(event Event) {
bus.mu.RLock()
defer bus.mu.RUnlock()
for _, obs := range bus.observers {
obs.OnEvent(event)
}
}

登录后复制

编写具体的观察者

每个观察者实现 OnEvent 方法，定义自己对事件的响应逻辑。

type Logger struct{}
<p>func (l *Logger) OnEvent(event Event) {
log.Printf("日志记录: %s", event)
}</p><p>type Notifier struct{}</p><p>func (n *Notifier) OnEvent(event Event) {
fmt.Printf("发送通知: %s\n", event)
}

登录后复制

使用示例

将观察者注册到事件总线，触发事件后自动广播给所有订阅者。

func main() {
    bus := &EventBus{}
    logger := &Logger{}
    notifier := &Notifier{}
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">bus.Register(logger)
bus.Register(notifier)

bus.Notify("user.login") // 两个观察者都会收到通知

bus.Unregister(notifier)
bus.Notify("system.shutdown") // 只有 logger 收到

登录后复制

}

基本上就这些。通过接口和组合，Go能简洁地实现观察者模式。如果项目更复杂，可扩展支持事件类型过滤、异步通知或基于 channel 的轻量机制。关键是保持订阅与通知逻辑清晰，避免内存泄漏（及时注销观察者）。

以上就是Golang如何使用观察者模式处理事件的详细内容，更多请关注php中文网其它相关文章！