领域事件必须绑定业务语义、可追溯、可重放，其结构需含版本号和不可变载荷，发布须在db事务提交后异步执行，消费者须基于业务主键+事件类型实现幂等，生产环境应采用outbox模式+消息队列而非内存eventbus。
领域事件不是“发个消息就完事”，它必须绑定业务语义、可追溯、可重放，否则解耦只会变成甩锅。
领域事件结构必须带版本号和不可变载荷
很多人用 map[string]interface{} 或裸 struct 发事件，结果半年后加个字段就全挂——消费者反序列化失败、字段被忽略、甚至静默丢数据。Go 里定义领域事件，核心是三点：
- 每个事件 struct 必须导出全部字段，加
json:标签，禁用omitempty（除非明确允许缺失） - 强制包含
Version string `json:"version"`字段，初版设为"1.0"，后续兼容变更只增字段、不删不改名 - 载荷用嵌入 struct 封装，不传完整聚合对象；例如
OrderShippedEvent只含OrderID、ShippingTime、TrackingNumber，不传整个Order
错误示例：type OrderShipped struct { ID string; Items []Item } → Items 后续扩展易崩；正确写法：type OrderShipped struct { Version string; OrderID string; TrackingNumber string; ShippedAt time.Time }
发布侧不能在 DB 事务里直接调 Publish
常见错误：DB 提交前就调 kafka.Producer.Publish()，或把 tx.Commit() 和发事件包进同一个 if err != nil 分支。一旦 Kafka 不可用，事务卡住或回滚，但业务已部分生效，状态撕裂。
- 必须先
tx.Commit()成功，再异步触发事件发布（用go func() {...}()+context.WithTimeout控制超时） - 生产环境务必加本地 outbox 表：事务内插入一条
outbox_events记录，另起 goroutine 轮询发送并标记已投递 - 避免用内存 channel 做“假异步”：单机测试可行，但服务重启后未消费事件直接丢失
关键判断：如果 Publish() 失败，你不该 rollback DB，而应记日志+告警+进补偿队列——DB 状态已是事实，事件只是通知。
消费者必须用业务主键做幂等，而非 event_id
只靠 event.ID 去重会漏判：同一事件可能因重试被多次投递，但更危险的是——不同事件修改同一业务实体（比如两次 InventoryDeducted 针对同一 sku_id），这时仅校验 event_id 完全无效。
- 幂等键应组合业务主键 + 事件类型，例如
"inventory_deducted:sku_123"存 Redis，TTL 设为业务合理窗口（如 24h） - 优先用
UPSERT落库（PostgreSQL 的ON CONFLICT DO NOTHING，MySQL 的INSERT ... ON DUPLICATE KEY UPDATE），比先 SELECT 再 INSERT 更可靠 - 禁止在 handler 里同步调远程服务（如扣款、发短信）：先落库标记“已处理”，再通过另一轮事件或定时任务触发下游
典型坑：用 event.ID 当唯一索引建表，结果两个不同订单的 OrderPaid 事件撞了 ID（UUID 重复概率虽低，但用错场景就成必然）。
Kafka 事务 vs NATS JetStream 的语义取舍
选中间件不是看谁快，而是看你的业务能否容忍“重复”或“丢失”。Kafka 的 transactional.id + isolation.level=read_committed 能做到精确一次（EOS），但代价是吞吐下降 20%+、配置复杂；NATS JetStream 默认是 at-least-once，靠 consumer 自行去重。
- 金融类强一致场景（如支付成功后扣账）：用 Kafka + 事务 producer，配合 DB 事务 + outbox 补偿
- 运营类弱一致场景（如用户注册后发欢迎邮件）：用 NATS JetStream，省掉事务开销，靠幂等 + DLQ 拦住异常
- RabbitMQ 不推荐用于领域事件主干链路：AMQP 协议层无原生事务支持，
publisher confirms仅保证送达 broker，不保 consumer 端不重复
真正容易被忽略的点：所有中间件的 offset / stream position 必须与业务 DB 同步提交——否则重启后从旧位置重播，会把已处理事件再跑一遍。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
