beego 不能直接集成 rocketmq 因其仅为 mvc 框架，不提供消息队列抽象层或默认客户端；对接需手动初始化 rocketmq-client-go/v2 生产者/消费者实例，并严格遵循阿里云 acl、预建资源、http 接入等管控约束。
Beego 本身不内置 RocketMQ 客户端支持，必须通过 Go 原生 SDK 或第三方封装桥接；直接用 github.com/apache/rocketmq-client-go/v2 是目前最稳妥的选择，但要注意版本兼容性和阿里云 RocketMQ 实例的网络/鉴权配置。
为什么 Beego 不能直接“集成”RocketMQ？
Beego 是一个 MVC 框架，它不提供消息队列抽象层或默认客户端。所谓“对接”，本质是：在 Beego 应用中初始化并复用 RocketMQ 的 Go SDK 生产者/消费者实例。没有自动配置、没有注解驱动、也没有 bee run 自动加载机制。
使用 rocketmq-client-go/v2 初始化生产者（含阿里云 ACL）
阿里云 RocketMQ（专业版/企业版）强制开启 ACL，必须传 accessKey 和 secretKey，且 endpoint 格式为 http://$instanceId.mq-internet-access.mq.aliyuncs.com:8080（公网）或内网 VPC 地址。
- 确保 GOPROXY 可拉取 v2.4.x+（v2.3.x 开始支持阿里云 HTTP 接入协议）
- 初始化时需显式设置
WithCredentials，否则报错UNAUTHORIZED - 生产者 Group ID 必须在阿里云控制台提前创建，且与代码中完全一致（大小写敏感）
- Topic 也必须在控制台预创建，
Beego启动时不会自动建 Topic
示例片段：
import (
"github.com/apache/rocketmq-client-go/v2"
"github.com/apache/rocketmq-client-go/v2/primitive"
"github.com/apache/rocketmq-client-go/v2/producer"
)
p, _ := rocketmq.NewProducer(
producer.WithNsResolver(primitive.NewPassthroughResolver([]string{
"http://MQ_INST_1234567890abcdef.mq-internet-access.mq.aliyuncs.com:8080",
})),
producer.WithCredentials(primitive.Credentials{
AccessKey: "yourAccessKey",
SecretKey: "yourSecretKey",
}),
)
_ = p.Start()
defer p.Shutdown()
在 Beego 中安全复用 Producer 实例
不要在每次 HTTP 请求里 new Producer，会触发连接泄漏和频繁重连。应作为全局单例，在 main.go 初始化后挂到 beego.AppConfig 或自定义包变量中。
- 推荐方式：在
models/init.go中定义var MqProducer rocketmq.Producer，init()函数里完成 Start - 避免在 Controller 的
Prepare()方法中调用SendSync前才检查 producer 是否启动——它可能正在重连，导致超时 - 若需按业务分组（如订单/通知），建议每个 Group 单独一个 Producer 实例，不要共用
- 注意
SendSync默认超时 3s，阿里云公网链路波动时易失败，建议设为5000并捕获errors.Is(err, primitive.ErrSendMsgTimeout)
消费者接入要绕过 Beego 的生命周期管理
rocketmq-client-go 的消费者是长运行后台 goroutine，不能绑定到 Beego 的 HTTP 生命周期（比如随请求启停）。它必须在应用启动早期就 Start()，并持续运行。
- 务必在
main()中启动消费者，而非某个 Controller 内部 - 订阅的 Topic + Tag 表达式（如
"order-tag-A || order-tag-B"）需与阿里云控制台配置一致，否则收不到消息 - 消费失败时，SDK 默认重试 16 次（间隔指数增长），若业务需自定义重试逻辑，应实现
consumer.WithConsumeOrderly(false)+ 手动Ack控制 - 阿里云 RocketMQ 不支持广播模式（
BROADCASTING），只支持集群消费（CLUSTERING），别在代码里设错
SendSync 前确认清楚。
