如何使用Golang实现观察者模式事件监听_Golang观察者模式实现技巧-Golang-PHP中文网

如何使用Golang实现观察者模式事件监听_Golang观察者模式实现技巧

php中文网

发布： 2025-12-06 15:01:41

原创

586人浏览过

Go实现观察者模式需定义Observer和Subject接口，用切片存储监听器、sync.RWMutex保障并发安全，支持动态注册/移除；Notify中应避免锁内耗时操作或panic，可异步处理并recover隔离错误。

如何使用golang实现观察者模式事件监听_golang观察者模式实现技巧

用 Go 实现观察者模式，核心是定义事件源（Subject）和监听器（Observer），通过接口解耦、切片管理订阅者，并支持动态注册/移除。Go 没有内置的 event emitter，但靠简洁的接口和并发安全设计，能写出轻量、易维护的事件系统。

定义 Observer 和 Subject 接口

先抽象出监听器行为和事件源能力，避免强依赖具体类型：

Observer：定义一个 Update(event interface{}) 方法，所有监听器都实现它
Subject：提供 Register(o Observer)、Deregister(o Observer) 和 Notify(event interface{}) 方法

这样后续增删监听逻辑、更换事件类型都不用改核心结构。

用切片+互斥锁管理订阅者列表

Go 中常用 []Observer 存储监听器，配合 sync.RWMutex 保证并发安全：

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

Anakin

一站式 AI 应用聚合平台，无代码的AI应用程序构建器

290

查看详情

读多写少场景下，RWMutex 比普通 Mutex 更高效
Register/Deregister 用写锁，Notify 用读锁遍历调用
注意在 Notify 中避免锁内执行耗时操作（如网络请求），可启动 goroutine 异步处理

支持泛型事件类型（Go 1.18+）

如果事件结构统一，可用泛型提升类型安全：

type Eventer[T any] interface {
    Register(obs Observer[T])
    Notify(event T)
}

type Observer[T any] interface {
    Update(event T)
}

登录后复制

这样编译期就能检查事件类型是否匹配，比如 Observer[UserLoginEvent] 不会误收 OrderPaidEvent。

简单可运行示例（无泛型版）

以下是一个最小可用实现：

type Observer interface {
    Update(event string)
}

type Subject struct {
    mu        sync.RWMutex
    observers []Observer
}

func (s *Subject) Register(o Observer) {
    s.mu.Lock()
    defer s.mu.Unlock()
    s.observers = append(s.observers, o)
}

func (s *Subject) Notify(event string) {
    s.mu.RLock()
    defer s.mu.RUnlock()
    for _, o := range s.observers {
        o.Update(event)
    }
}

// 使用示例：
type EmailNotifier struct{}
func (e EmailNotifier) Update(event string) { fmt.Println("Email:", event) }

type LogNotifier struct{}
func (l LogNotifier) Update(event string) { fmt.Println("Log:", event)

s := &Subject{}
s.Register(EmailNotifier{})
s.Register(LogNotifier{})
s.Notify("user logged in") // 输出两行日志

登录后复制

基本上就这些。不复杂但容易忽略的是并发安全和通知时机——别在锁里做阻塞操作，也别让某个 Observer panic 影响其他监听器，必要时加 recover 隔离错误。

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