不能用 channel 直接实现观察者模式，因为单个 channel 是点对点通信，无法保证多个观察者同时收到同一事件；必须通过中心事件 channel + 分发 goroutine + 每观察者独立带缓冲 channel 才能正确广播。
为什么不用 channel 做观察者模式的事件广播
channel 本身不是为一对多广播设计的，select + range 无法让多个 goroutine 同时收到同一份消息。直接把一个 chan interface{} 给所有观察者共用，会导致消息被某一个接收者取走后其他观察者收不到——这违背观察者模式“通知所有订阅者”的语义。
用 channel 实现观察者必须引入中间调度 goroutine
核心思路是：维护一个注册表（比如 map[*observer]chan interface{}），所有事件先发到一个中心 chan event，再由单独的分发 goroutine 拷贝并广播到每个观察者的专属 channel 中。否则无法保证送达和解耦。
实操建议：
- 观察者注册时应返回一个取消函数，用于从 map 中安全删除对应
chan，避免内存泄漏 - 每个观察者 channel 建议带缓冲（如
make(chan interface{}, 16)），防止分发 goroutine 因某个观察者阻塞而拖垮全局 - 分发逻辑里要加
select+default，跳过已满或已关闭的观察者 channel，避免死锁
type Event struct{ Topic string; Data interface{} }
type Observer struct{ ch chan interface{} }
<p>func NewObserver() *Observer {
return &Observer{ch: make(chan interface{}, 16)}
}</p><p>func (o *Observer) Chan() <-chan interface{} { return o.ch }</p><p><span>立即学习</span>“<a href="https://pan.quark.cn/s/00968c3c2c15" style="text-decoration: underline !important; color: blue; font-weight: bolder;" rel="nofollow" target="_blank">go语言免费学习笔记（深入）</a>”；</p><div class="aritcle_card flexRow">
<div class="artcardd flexRow">
<a class="aritcle_card_img" href="/xiazai/code/11013" title="商易多用户商城"><img
src="https://img.php.cn/upload/webcode/000/000/013/176465880844685.jpg" alt="商易多用户商城" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a href="/xiazai/code/11013" title="商易多用户商城">商易多用户商城</a>
<p>功能介绍：1. 商品出售包含拍卖模式，一口价模式。2. 全套系统采用淘宝网风格，成熟，简洁大方3. 每个商品支持多张图片上传，可自由设定，满足广大网民的迫切要求4. 商品信息支持 ubb,图文并茂5. 注册用户可参与竞拍，或者拍卖自己的商品6. 拥有会员注册，交易提醒，成交商品确认等邮件发送功能7. 拥有交易双方信用评价的功能，使得交易安全可*，可信度高8. 拥有安全稳定的用户虚拟币平台，可实现商</p>
</div>
<a href="/xiazai/code/11013" title="商易多用户商城" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span> </a>
</div>
</div><p>type EventBus struct {
mu sync.RWMutex
obs map[*Observer]struct{}
events chan Event
}</p><p>func NewEventBus() <em>EventBus {
eb := &EventBus{
obs: make(map[</em>Observer]struct{}),
events: make(chan Event, 128),
}
go eb.dispatch()
return eb
}</p><p>func (eb <em>EventBus) Subscribe(o </em>Observer) func() {
eb.mu.Lock()
eb.obs[o] = struct{}{}
eb.mu.Unlock()</p><pre class='brush:php;toolbar:false;'>return func() {
eb.mu.Lock()
delete(eb.obs, o)
eb.mu.Unlock()
close(o.ch)
}}
func (eb *EventBus) Publish(e Event) { select { case eb.events
func (eb *EventBus) dispatch() { for e := range eb.events { eb.mu.RLock() for o := range eb.obs { select { case o.ch
注意 channel 关闭与观察者退出的竞态
观察者 goroutine 如果在读取 o.Chan() 时未做 ok 判断，一旦被取消且 channel 关闭，就会 panic。常见错误写法：for e := range o.Chan() —— 这里 o.Chan() 返回的是只读 channel，但底层仍可能被关闭；必须配合 for { select { case e, ok := 。
另一个坑是：如果观察者处理太慢，缓冲区满后 select 的 default 分支会让消息丢失。业务上是否允许丢弃、是否需要背压（如用 semaphore 控制并发消费），得根据场景定。
替代方案：考虑用第三方库或更轻量结构
标准库没有内置观察者抽象，但像 github.com/robfig/pat 或 go.uber.org/zap 的 logger hook 其实都用了类似机制。如果你只是想做日志监听、配置变更通知等，用 sync.Map + chan struct{} 配合 atomic 标记状态，比全量复制 event 到每个 channel 更省资源。
真正复杂的状态广播（如带优先级、过滤、重试）不建议硬啃 channel 调度逻辑——容易写出难以测试的 goroutine 网状依赖。这时候该上消息队列或用 golang.org/x/exp/slices 做切片遍历 + context 控制超时。
