[开源] 写一次代码，适配 6 种 MQ？ Go 统一消息中间件适配层 正式版发布

在 Go 业务开发中，我们经常遇到这样的场景：

• 环境切换：本地开发用 NATS 或 RabbitMQ 贪图轻快，线上却要接入 Kafka 或 AWS SQS 。
• 代码耦合：业务逻辑被底层 MQ 的 SDK 对象（如 *rocketmq.Producer）绑定，一旦想换驱动，几乎要重写整个消息发送逻辑。
• 配置坑多：每个 MQ 的参数设置五花八门，一不小心传错了参数，程序却静默运行，等到上线出事才发现配置没生效。

为了解决这些痛点，我发起了 Unified MQ Broker for Go 项目。它就像是 MQ 领域的 "DBAL"（类似于 SQL 领域的 GORM 或数据库驱动层），让你通过一套 API 就能无缝切换多种消息中间件。

v0.2.0 重磅更新

经过一段时间的打磨，我们刚刚发布了 v0.2.0 版本。这次更新不只是增加了驱动，更是在“健壮性”和“性能”上做了深度优化：

• 痛点：如果你给 Kafka 传了一个 SQS 的 DeduplicationID，大部分 SDK 会选择静默忽略。
• 方案：v0.2.0 引入了审计机制。如果底层适配器没有读取你传入的某个配置项，系统会在连接或发布时发出显式警告。彻底告别因拼写错误或参数误用导致的配置无效。

2. 高性能“智能序列化” (Smart Serialization)

• 优化：针对原始 []byte 和 string 数据实现了零拷贝路径，跳过冗余的 json.Marshal。
• 战果：压测显示，在高吞吐场景下，序列化性能提升了 5 倍以上（单次操作仅需 ~16ns ）。

3. 延迟绑定 (Late Binding)

• NewBroker 现在仅做静态配置。
• 真正的网络 IO 、TCP 建连和 SDK 初始化全部推迟到 Connect() 时执行，方便与依赖注入框架（如 Wire ）集成。

4. 全平台支持

目前已完美支持：RocketMQ, Kafka, RabbitMQ, NATS, AWS SQS, GCP Pub/Sub。

核心代码预览

无论底层是哪种 MQ ，你的业务代码只需要关心这一套统一逻辑：

import "github.com/qvcloud/broker" // 切换驱动只需要换一行初始化，业务代码 0 改动 b := rabbitmq.NewBroker(broker.Addrs("amqp://...")) b.Connect() // 注入统一的中间件（如 OpenTelemetry 链路追踪） b.Init(broker.Middleware(otel.Middleware)) // 统一的订阅 API b.Subscribe("orders.created", func(ctx context.Context, event broker.Event) error { fmt.Println("收到订单:", string(event.Message().Body)) return nil // 返回 nil 自动 Ack ，返回 error 自动 Nack/Retry }) // 统一的发布 API b.Publish(context.Background(), "orders.created", &broker.Message{ Body: []byte(`{"id": 1001}`), }) 

传送门

GitHub: https://github.com/qvcloud/broker

• 核心理念: 接口驱动、高性能、原生支持 OpenTelemetry 。

如果你也深受 MQ 适配之苦，或者想为你的分布式系统寻找一个更规范的通信抽象，欢迎来试用、吐槽或贡献代码！如果你觉得不错，给个 Star 就是最大的支持。