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 是一个接受事件参数的函数类型：
type EventHandler func(interface{})type EventBus struct { handlers sync.Map }
实现订阅/取消订阅：按 topic 注册回调
订阅操作需支持同一 topic 多个 handler，并保证并发安全；取消订阅则要能精准移除指定 handler（不能只清空整个 topic）。
立即学习“go语言免费学习笔记（深入）”；
- 用
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），以及测试时覆盖并发订阅/发布/取消的竞态路径。
