如何用Golang实现观察者模式与事件通知_Golang 观察者模式事件实践-Golang-PHP中文网

如何用Golang实现观察者模式与事件通知_Golang 观察者模式事件实践

P粉602998670

发布： 2025-11-25 16:36:07

原创

941人浏览过

答案：通过接口和切片实现观察者模式，使用EventBus管理订阅与通知。定义Observer和Subject接口，用EventBus结构体实现注册、注销和通知功能，结合sync.RWMutex保证并发安全，创建具体观察者如Logger和Notifier处理事件，主函数中演示注册、通知与注销流程，实现解耦的事件系统。

如何用golang实现观察者模式与事件通知_golang 观察者模式事件实践

在 Golang 中实现观察者模式，核心是解耦事件发布者与订阅者之间的依赖。通过接口和切片管理订阅关系，可以轻松构建灵活的事件通知系统。下面介绍一种简洁、可扩展的实现方式。

定义观察者与主题接口

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

先定义接口：

type Event string

type Observer interface {
    OnNotify(Event)
}

type Subject interface {
    Register(Observer)
    Deregister(Observer)
    Notify(Event)
}

登录后复制

Event 是事件类型，用字符串标识不同事件。Observer 接口只需实现 OnNotify 方法接收事件。Subject 提供注册、注销和广播通知的能力。

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

实现事件中心（EventBus）

使用结构体实现 Subject 接口，作为全局事件中心：

type EventBus struct {
    observers []Observer
    mutex     sync.RWMutex
}

func NewEventBus() *EventBus {
    return &EventBus{
        observers: make([]Observer, 0),
    }
}

func (bus *EventBus) Register(obs Observer) {
    bus.mutex.Lock()
    defer bus.mutex.Unlock()
    bus.observers = append(bus.observers, obs)
}

func (bus *EventBus) Deregister(obs Observer) {
    bus.mutex.Lock()
    defer bus.mutex.Unlock()
    for i, observer := range bus.observers {
        if observer == obs {
            bus.observers = append(bus.observers[:i], bus.observers[i+1:]...)
            break
        }
    }
}

func (bus *EventBus) Notify(event Event) {
    bus.mutex.RLock()
    defer bus.mutex.RUnlock()
    for _, obs := range bus.observers {
        obs.OnNotify(event)
    }
}

登录后复制

使用 sync.RWMutex 保证并发安全。读操作（Notify）用读锁，写操作（Register/Deregister）用写锁，提升性能。

爱图表

AI驱动的智能化图表创作平台

305

查看详情

创建具体观察者

定义实际处理事件的观察者：

type Logger struct{}

func (l *Logger) OnNotify(event Event) {
    fmt.Printf("日志记录: %s\n", event)
}

type Notifier struct{}

func (n *Notifier) OnNotify(event Event) {
    fmt.Printf("发送通知: %s\n", event)
}

登录后复制

每个观察者根据自身职责响应事件。比如 Logger 记录日志，Notifier 发送提醒。

使用示例

将各部分组合起来：

func main() {
    bus := NewEventBus()

    logger := &Logger{}
    notifier := &Notifier{}

    bus.Register(logger)
    bus.Register(notifier)

    bus.Notify("user.login")
    bus.Deregister(notifier)
    bus.Notify("user.logout")
}

登录后复制

输出：

日志记录: user.login
发送通知: user.login
日志记录: user.logout

登录后复制

可以看到 notifier 在注销后不再接收事件。

基本上就这些。这种实现简单清晰，适合中小型项目中的事件通信。如需支持多种事件类型，可扩展为按事件名分类的多通道 EventBus。关键是保持接口简洁，避免过度设计。

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

大家都在看：

Go语言命令行工具的构建与可执行文件生成实践深入理解Go语言类型断言与Type Switch中的变量类型行为 Go语言App Engine任务队列：任务创建与事务集成 Go语言包导入失败：GOPATH设置正确但仍报错的解决方案深入理解Go语言不允许嵌套命名函数声明的原因