Go 主动拒绝多级异步嵌套回调，主张用 channel + goroutine + struct 构建单向流水线；嵌套 go 调用会导致资源提前释放、panic 静默、超时失控和错误不透传；应定义 OrderEvent 等结构体，通过 orderCh 等 channel 传递数据。
Go 里没有“优雅的多级异步嵌套回调”——这不是设计缺陷，而是语言哲学的主动拒绝。真正该做的，是把“嵌套回调”这个念头从脑子里删掉，换成 channel + goroutine + struct 的组合拳。
为什么不能写 go fn() 然后在里面再 go callback()
很多人在 handler 里写 go processOrder(event)，接着在 processOrder 里又 go notifyWebhook(result)，最后再 go updateCache()……这看起来是“分层异步”，实际是灾难链：
-
r.Body在 handler 返回后立刻被关闭，子 goroutine 读它会 panic 或返回空 - 每一层都可能 panic，但没人 recover，整个 goroutine 静默死亡
- 无法统一控制超时：上层设了 5s context，下层却用自己 new 的 timer
- 错误无法向上透传，
notifyWebhook失败了，updateCache还照常跑，数据不一致
用 channel 流水线替代嵌套回调
把“多级处理”变成“单向流水线”，每级只关心输入和输出 channel，不耦合调用关系：
- 定义清晰的事件结构体：
type OrderEvent { ID string; Payload []byte } - 第一级：从 HTTP 接收 → 写入
orderCh - 第二级：消费
orderCh→ 校验/转换 → 发到validatedCh - 第三级：消费
validatedCh→ 调第三方 → 发到resultCh - 所有 channel 都带缓冲（比如
make(chan OrderEvent, 100)），避免生产者阻塞
结果回传必须用 struct + channel，别传回调函数
传 func(*Result, error) 是反模式，尤其在多层之间。换成显式 channel：
立即学习“go语言免费学习笔记（深入）”；
- 启动任务时传入
resultCh chan，不是 <code>callback func(...) - goroutine 执行完后只做一件事：
resultCh - 主流程用
select等待，可加case 实现取消 - 别忘了
defer close(resultCh)，否则接收方永远不知道“任务结束了还是卡住了”
订阅/退订必须异步，否则拖垮发布逻辑
如果每次 Subscribe("orders", ch) 都去锁 map 更新，高并发下 Publish 就会排队等写锁。正确做法：
- 定义命令结构：
type subCmd { topic string; ch chan - 启动单独 goroutine 消费管理 channel：
mgmtCh := make(chan interface{}, 100) -
Publish只读 map（用sync.RWMutex），完全不碰写路径 - 缓冲大小要压测：
mgmtCh容量太小会导致注册失败；太大则内存浪费
最难的部分从来不是“怎么让代码动起来”，而是“怎么让每条消息不丢、不错、不重复、能监控”。缓冲大小、worker 数量、超时阈值、重试间隔——这些没有默认值，得靠真实流量打出来。
