Go微服务消息总线首选NATS JetStream，因其轻量、生产就绪、与Go生态天然契合；相比RabbitMQ和Kafka更少踩坑，具备默认持久化、清晰错误反馈、自动流创建、消费者组幂等、NakWithDelay重试及版本化事件契约等核心能力。
用 Go 构建微服务消息总线，核心不是“搭个中间件”，而是让服务之间能可靠、可演进、可观测地交换事件。NATS JetStream 是当前 Go 生态中最轻量又不失生产级能力的选择——它不用 ZooKeeper、不依赖 JVM、单二进制启动即用，且 nats.go 客户端与 Go 的 context / goroutine 天然契合。
为什么选 NATS JetStream 而不是 RabbitMQ 或 Kafka？
不是“谁更好”，而是“谁更少踩坑”：
-
RabbitMQ的 Exchange/Binding 模型对初学者容易绕晕，streadway/amqp库里autoAck=false忘设或msg.Ack()漏调，消息就静默丢失； -
Kafka的sarama库配置项多（如Net.DialTimeout、Metadata.Retry.Max），一个UnknownTopicOrPartition错误常因 topic 未提前创建或 broker 地址写错，排查耗时； -
NATS JetStream默认开启流式持久化，js.Publish("order.created", data)成功即代表已落盘，失败会直接返回 error，没有“看似成功实则未持久”的灰色地带。
如果你的团队没有专职 MQ 运维，且服务规模在 5–50 个之间，NATS JetStream 是收敛复杂度的最优解。
如何封装一个可复用的 EventBus 接口？
别让每个服务都重复写 nats.Connect 和 js.PullSubscribe。用接口抽象，把连接、重连、错误日志收口：
立即学习“go语言免费学习笔记（深入）”；
type EventBus interface {
Publish(subject string, event interface{}) error
Subscribe(subject string, group string, handler func(msg *nats.Msg)) error
}
// 实现体里统一处理：
// - 连接断开时自动重连（用 backoff.Retry）
// - 所有 Publish 自动加 trace_id 字段（从 context.Value 获取）
// - Subscribe 启动时检查 stream 是否存在，不存在则自动创建（js.AddStream）
关键点：Subscribe 必须传 group 名——JetStream 的消费者组是幂等保障的基础，同一 group 内多个实例自动负载分摊，且每条消息只被组内一个实例处理一次。
消费失败时，msg.NakWithDelay() 和死信队列怎么配？
JetStream 不提供传统意义上的 DLQ，但通过 NakWithDelay + MaxDeliver 可等效实现：
- 订阅时设置
nats.MaxDeliver(3)：同一条消息最多投递 3 次； - 业务处理失败时，调用
msg.NakWithDelay(10 * time.Second)，延迟 10 秒再重试； - 第 3 次失败后，JetStream 自动将该消息移入
$JS.API.CONSUMER.MSG.NAK流（需提前声明），这就是你的“人工干预区”。
别跳过这步：很多团队直接 msg.Nak() 不带 delay，结果瞬时重试压垮下游；也别依赖“重试 3 次后自动丢弃”，必须明确把超限消息导出到可观测系统（比如写入 Redis + 推送告警）。
事件结构体必须带版本字段，且永不删除旧字段
这是上线后最容易引发雪崩的地方。看这个反例：
type OrderCreatedEvent struct {
ID string `json:"id"`
UserID int64 `json:"user_id"`
Timestamp int64 `json:"timestamp"`
}
// v2 版本想加 status 字段，直接改成：
type OrderCreatedEvent struct {
ID string `json:"id"`
UserID int64 `json:"user_id"`
Status string `json:"status"` // ⚠️ 旧消费者反序列化会 panic！
Timestamp int64 `json:"timestamp"`
}
正确做法：
- 所有事件 struct 加
Version string `json:"version"`字段，值为"v1"； - 新增字段设默认值并标记
omitempty，例如Status string `json:"status,omitempty"`； - 重大变更（如字段语义改变）就新建
OrderCreatedV2Event，subject 改成order.created.v2，双轨运行直到旧消费者下线。
消息总线的脆弱性不在连接或吞吐，而在事件契约的悄然腐化——只要有一个服务悄悄改了 JSON 字段名，整个链路就可能静默错乱。
