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

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

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

2025-12-06

浏览次数：次

返回列表

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 保证并发安全：

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

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

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

简小派

简小派是一款AI原生求职工具，通过简历优化、岗位匹配、项目生成、模拟面试与智能投递，全链路提升求职成功率，帮助普通人更快拿到更好的 offer。

123 查看详情简小派

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") // 输出两行日志