为了解决这些痛点，我发起了 Unified MQ Broker for Go 项目。它就像是 MQ 领域的 "DBAL"（类似于 SQL 领域的 GORM 或数据库驱动层），让你通过一套 API 就能无缝切换多种消息中间件。
🚀 v0.2.0 重磅更新
经过一段时间的打磨，我们刚刚发布了 v0.2.0 版本。这次更新不只是增加了驱动，更是在“健壮性”和“性能”上做了深度优化：
1. 🛡️ 独创“选项追踪” (Option Tracking)
2. ⚡ 高性能“智能序列化” (Smart Serialization)
3. 🏗️ 延迟绑定 (Late Binding)
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
如果你也深受 MQ 适配之苦，或者想为你的分布式系统寻找一个更规范的通信抽象，欢迎来试用、吐槽或贡献代码！如果你觉得不错，给个 Star 就是最大的支持。 🌟
