17370845950

Go中可用sync.Map、chan和接口实现线程安全的观察者与Pub/Sub模式：EventBus用sync.Map存topic-handler映射，支持订阅/取消订阅、同步或异步发布事件，并可扩展通配符匹配与事件过滤。

用 Go 实现观察者（Observer）和发布-订阅（Pub/Sub）模式，核心是解耦事件生产者与消费者，让组件通过事件通信而非直接调用。Go 本身没有内置的事件总线，但借助 sync.Map、chan 和接口抽象，可以写出轻量、线程安全、符合 Go 风格的实现。

定义事件总线：用 sync.Map 管理订阅者

事件总线是整个模式的中枢，负责存储主题（topic）与监听器（handler）的映射关系。推荐用 sync.Map 而非普通 map + mutex，避免高频读写下的锁竞争。

每个 topic 对应一个 handler 切片，handler 是一个接受事件参数的函数类型：

实现订阅/取消订阅：按 topic 注册回调

订阅操作需支持同一 topic 多个 handler，并保证并发安全；取消订阅则要能精准移除指定 handler（不能只清空整个 topic）。

• 用 sync.Map.LoadOrStore(topic, &sync.Map{}) 初始化 topic 的 handler 容器
• 为每个 topic 单独维护一个 *sync.Map 或 sync.RWMutex + []EventHandler，后者更易遍历和删除
• 取消订阅时传入原 handler 函数值（注意闭包或方法值可能导致不等价，建议用命名函数或 ID 标识）

发布事件：广播到所有匹配 topic 的 handler

发布时遍历对应 topic 下全部 handler，逐个异步或同步执行。是否异步取决于场景：

• 同步调用适合逻辑简单、要求强顺序或错误可传播的场景（如配置变更校验）
• 异步推荐用 goroutine + channel 控制并发，避免阻塞发布方；可用带缓冲 channel 做简单限流
• 建议在 handler 执行中 recover panic，防止单个 handler 崩溃影响其他监听者

进阶：支持通配符 topic 和事件过滤

基础版只支持精确 topic 匹配。若需类似 user.* 或 order.created 这样的层级语义，可引入简单模式匹配：

• 用 strings.Split(topic, ".") 拆分路径，支持 *（单层通配）和 **（多层递归）
• 将 handler 关联到 pattern 而非 raw topic，发布时遍历所有 pattern 并匹配
• 事件结构体可嵌入 metadata 字段（如 EventType string, Priority int），供 handler 自行过滤

不复杂但容易忽略：记得在 handler 中处理 nil 参数、超时控制、上下文传递（context.Context），以及测试时覆盖并发订阅/发布/取消的竞态路径。