go-zero通过内置eventbus实现领域事件驱动：需在.api文件声明事件类型，service层实现带context参数的handler并在init中调用bus.subscribe注册，业务逻辑中用bus.publish触发；事件结构须导出且含json tag，跨进程需对接kafka/rabbitmq，事务性消息须配合sqlx.transact确保一致性。
go-zero 里怎么注册和触发领域事件
go-zero 的事件驱动不是靠自己手写 channel 或 EventBus，而是通过框架内置的 eventbus 和配套的代码生成机制完成的。你得先在 API 定义（.api 文件）里声明事件类型，再在 service 层实现对应 handler，最后在业务逻辑中调用 bus.Publish —— 框架会自动把 handler 注册进总线。
常见错误是：handler 函数签名不匹配（比如漏了 ctx context.Context 参数），或没在 service.Init() 阶段调用 bus.Subscribe，导致事件发出去但没人收。
- 事件结构必须导出（首字母大写），且字段带 JSON tag，否则序列化失败
- 订阅必须发生在服务启动时，不能放在 handler 内部或 init() 函数里
- go-zero 默认使用内存总线，跨进程需显式接入 Kafka/RabbitMQ，配置项是
EventBus.Type - 事务性消息要搭配
sqlx.Transact使用，否则 DB 提交前就发事件，可能造成状态不一致
本地开发时用 channel 实现轻量 EventBus 容易踩哪些坑
直接用 chan interface{} 做总线看着简单，实际运行时极易出问题：channel 满了就阻塞发布者、handler panic 会导致整个 goroutine 退出、没缓冲的 channel 在并发高时直接丢事件。
真正能落地的最小可行封装，至少要包含三件事：带缓冲的 channel、类型安全的事件 struct、可取消的订阅管理。
RabbitMQ 4.2.3 是 2026 年初发布的重要稳定更新版本，重点修复了 Khepri 元数据存储相关问题，并改进了监控性能。对于使用 Docker、Kubernetes 或微服务架构的开发团队来说，该版本兼容性和稳定性表现较好。
- 别用
chan interface{}，定义具体事件类型如type UserDeletedEvent struct { UserID int64 } - 每个 subscriber channel 缓冲大小设为
16起步，避免慢 handler 拖垮全局 - Subscribe 方法必须返回
func()取消函数，内部用sync.Map存 channel 引用，注销时 close 并从 map 删除 - handler goroutine 里要用
for range ch+select { case 支持优雅退出
goroutine 处理事件时为什么超时控制比重试更重要
事件消费不是 HTTP 请求，没有“客户端等响应”这回事。一个 handler 卡住 5 秒，不会影响其他事件，但会持续占用 goroutine，积压多了直接 OOM。重试解决的是临时失败（如网络抖动），而超时解决的是逻辑缺陷或依赖僵死（比如调第三方 API 不回包）。
- 所有外部调用必须套
context.WithTimeout，建议默认 3s，最长不超过 10s - 不要在 handler 里做长耗时计算（如图像处理），应转成异步任务投递到 worker queue
- 日志里必须记录 handler 执行耗时，
log.Printf("handle %s took %v", event.Type, time.Since(start)) - 监控指标重点看
event_handler_duration_seconds的 P99 和 goroutine 数增长趋势
Kafka 消费端如何避免重复处理同一事件
go-zero 接 Kafka 时，默认开启自动提交 offset，但这是危险的——handler 还没执行完，offset 就提前提交了，宕机后会丢事件；反之，手动提交又容易卡在失败重试里不提交，导致无限重复。
正确做法是：只在 handler 成功且数据落库后，才调用 consumer.CommitMessages。失败时不做 commit，让 Kafka 重推。
- 确保 handler 是幂等的：用事件 ID 做 DB 唯一索引，或先查再 insert on conflict do nothing
- 不要依赖 Kafka 的 at-least-once 语义来兜底，业务层必须自己防重
- 消费组名要带环境后缀（如
score-service-prod），避免测试环境消费线上数据 - partition 数量要大于消费者实例数，否则有实例会空闲
