0

0

Golang中的观察者模式与异步事件总线 Go语言内存消息分发实战

P粉602998670

P粉602998670

发布时间:2026-03-04 13:23:06

|

281人浏览过

|

来源于php中文网

原创

用 sync.map + 函数类型实现轻量事件总线:type eventhandler func(interface{}),每个 topic 对应 []eventhandler,注册时 load-append-store,notify 时 goroutine 异步调用并 recover,注销靠显式 id 而非接口值比较。

golang中的观察者模式与异步事件总线 go语言内存消息分发实战

sync.Map + 函数类型实现轻量事件总线,别写接口套娃

Go 里硬套 Java 风格的 Observer 接口+结构体继承,只会让代码变重、解耦失败。真实项目中,90% 的事件通知场景只需要“某事发生后调用几个函数”,不需要生命周期管理或泛型约束。

直接用函数当观察者最自然:type EventHandler func(interface{}),注册时传个闭包就行,没抽象成本,也无类型擦除风险。

  • 避免定义 Update(event interface{}) 接口再包装一层——多一次接口值拷贝,还容易因方法值不等导致 Detach 失效
  • sync.Mapmap + sync.RWMutex 更适合高频读写场景(比如配置热更新监听),但注意它不支持遍历,得为每个 topic 单独配一个 []EventHandler
  • 注册时别用 append 原地修改切片——并发下会 panic;应先 Load 出原切片,appendStore 回去

Notify 必须异步,且每个 handler 要单独 recover

同步调用 obs.Update(event) 是最大陷阱:一个 handler 执行慢、卡死或 panic,整个通知就阻塞或崩掉,其余观察者收不到事件。

正确做法是为每个 handler 启一个 goroutine,并在内部 recover

Pixelfox AI
Pixelfox AI

多功能AI图像编辑工具

下载

立即学习go语言免费学习笔记(深入)”;

go func(h EventHandler) {
    defer func() {
        if r := recover(); r != nil {
            log.Printf("handler panic: %v", r)
        }
    }()
    h(event)
}(handler)
  • 不推荐全局 goroutine 池——小项目没必要,反而引入调度复杂度
  • 高频事件(如每秒千级)慎用无缓冲 channel 中转,容易压垮;带缓冲 channel(如 make(chan Event, 1024))更稳
  • 如果某个 handler 需要上下文(如超时控制),别往 event interface{} 里塞 context.Context——改用独立参数或封装成结构体字段

动态注销必须带唯一 ID,别依赖接口值相等

Go 没有对象身份语义,o1 == o2 对接口值比较不可靠——尤其是方法值、闭包,哪怕逻辑相同,地址也不同。直接传 Observer 接口去 Unregister,大概率删不掉。

  • 注册时显式传 id string,用 map[string]EventHandler 存储,注销只删 key
  • HTTP handler 或临时 goroutine 类观察者,建议绑定 context.Context:在 OnEvent 里检查 ctx.Err() != nil,触发后主动调用 Detach(id)
  • 别用 uintptr(unsafe.Pointer(...)) 做 ID——反射取地址不稳定,GC 可能移动对象,生产环境已出过 case

什么时候该放弃自研,改用 chan 直连

不是所有场景都需要“可订阅/可注销”的总线。如果你只有 1–3 个固定消费者,且事件种类单一(比如仅日志、指标、审计),chan 是更 Go 的选择。

  • select { case logCh 控制背压,比总线里的 map 查找+切片遍历更快
  • channel 天然支持 select 超时、取消、多路复用,和 context 集成更干净
  • 一旦需要按 topic 分类、通配符匹配(如 user.*)、或运行时插拔 handler,就该切回 sync.Map 版本,别硬撑

真正难的不是实现 Notify,而是想清楚:这个事件到底要不要被多个模块监听?监听者生命周期谁管?丢事件能不能接受?把这三个问题答清了,选 chan 还是 EventBus 就不会错。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

209

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

243

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

353

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

214

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

407

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

428

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

200

2025.06.10

golang数组使用方法
golang数组使用方法

本专题整合了golang数组用法,想了解更多的相关内容,请阅读专题下面的文章。

1274

2025.06.17

AI安装教程大全
AI安装教程大全

2026最全AI工具安装教程专题:包含各版本AI绘图、AI视频、智能办公软件的本地化部署手册。全篇零基础友好,附带最新模型下载地址、一键安装脚本及常见报错修复方案。每日更新,收藏这一篇就够了,让AI安装不再报错!

0

2026.03.04

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go 教程
Go 教程

共32课时 | 5.8万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.9万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号