使用 Amazon MQ 运维消息代理 - ActiveMQ 与 RabbitMQ 的选型与迁移
整理 ActiveMQ 与 RabbitMQ 的选型标准，介绍从本地环境的迁移模式和高可用性配置。同时解析与 SQS/SNS 的使用场景区分。
Amazon MQ 的定位与 SQS/SNS 的使用场景区分
Amazon MQ 是 ActiveMQ 和 RabbitMQ 的全托管代理服务。与 SQS 和 SNS 作为 AWS 原生消息服务不同，MQ 以托管方式运维行业标准消息代理。SQS 具有无限吞吐量、自动扩展、与无服务器架构的出色集成，是新开发云原生应用的首选。但现有应用依赖 JMS API、AMQP 协议或复杂路由规则 (主题选择器、消息过滤器) 时，改写为 SQS/SNS 成本巨大。消息优先级控制、事务管理、复杂路由模式等标准协议高级功能需要时也适合 MQ。迁移后逐步向 SQS 或 SNS 重构的策略也是有效的。
- 1. 是否为全新的云原生开发如果是，SQS 与 SNS 是首选：吞吐量无上限、自动扩展，并与 Serverless 架构紧密集成。
- 2. 现有应用是否依赖标准协议若依赖 JMS API、AMQP 协议，或主题选择器、消息过滤器这类复杂路由规则，改写为 SQS/SNS 的成本很高。这正是 Amazon MQ 的用武之地。
- 3. 是否需要标准协议的高级功能需要消息优先级控制、事务管理、复杂路由模式时，Amazon MQ 更合适。
- 4. 先想清楚迁移后的形态先原样跑在 Amazon MQ 上，之后再逐步重构到 SQS 与 SNS，也是可行的策略。
ActiveMQ 与 RabbitMQ 的选型
ActiveMQ 与 Java 生态系统亲和性高，完全兼容 JMS 1.1，每代理最多处理 1,000 连接。支持队列、主题、虚拟主题、复合目标等 ActiveMQ 全功能。网络代理 (Network of Brokers) 配置可连接多个代理构建可扩展的消息拓扑。同时支持 STOMP、MQTT、OpenWire 等多种协议，可桥接 IoT 设备和企业应用。RabbitMQ 原生支持 AMQP 0-9-1，通过 Exchange (Direct、Topic、Fanout、Headers) 和 Binding 实现灵活路由。集群部署可配置仲裁队列 (Quorum Queue)，确保高可用性和数据持久性。Python、Ruby、Go、.NET 等多语言客户端库丰富，适合多语言环境。管理 UI 标准提供，可从浏览器监控队列状态和消息速率。
| 观察点 | ActiveMQ | RabbitMQ |
|---|---|---|
| 标准协议 | 完全遵循 JMS 1.1，并可同时支持 STOMP、MQTT、OpenWire | 原生支持 AMQP 0-9-1 |
| 消息模型的搭建 | 队列、主题、虚拟主题、组合目的地等全部功能都可使用 | 通过 Exchange（Direct、Topic、Fanout、Headers）与 Binding 实现灵活路由 |
| 可用性与拓扑 | 用 network of brokers 连接多个代理，构建可扩展的消息拓扑 | 以集群部署构成 quorum 队列，确保高可用与数据持久性 |
| 连接与客户端 | 单个代理最多 1,000 个连接，与 Java 生态契合度高 | Python、Ruby、Go、.NET 等多语言客户端库齐全 |
| 适合场景 | 以 Java 为中心的企业环境，以及连接 IoT 设备与企业应用 | 多语言混用的环境；标准附带管理界面，可在浏览器查看队列状态与消息速率 |
高可用性配置与安全性
ActiveMQ 的主备配置中，两个代理实例部署在不同可用区，通过 EFS 共享存储持久化消息。主节点故障时备用节点自动接管，故障转移在数十秒内完成。RabbitMQ 的集群部署配置 3 节点集群，通过队列镜像确保消息持久性。两种引擎均标准提供多可用区部署自动故障转移、EBS 卷消息持久化和 KMS 静态加密。CloudWatch 指标监控代理健康状态，CloudTrail 提供 API 操作审计日志。以下是使用 AWS CLI 创建 RabbitMQ 代理的示例：
aws mq create-broker \
--broker-name my-rabbitmq-broker \
--engine-type RABBITMQ \
--engine-version 3.11.20 \
--host-instance-type mq.m5.large \
--deployment-mode CLUSTER_MULTI_AZ \
--users Username=admin,Password=MySecurePass123从本地环境的迁移策略
从本地 ActiveMQ 到 Amazon MQ 的迁移分代理设置迁移、客户端连接变更、网络配置调整三步进行。Amazon MQ 支持与本地 ActiveMQ 相同的配置文件格式 (activemq.xml)，现有配置几乎可直接应用。通过 VPN 或 Direct Connect 确保本地连接，推荐蓝绿迁移逐步切换客户端。RabbitMQ 可利用 Shovel 插件或 Federation 插件在本地与云之间设置消息转发，最小化停机时间。迁移后的性能调优方面，实例类型选定 (mq.m5.large 约 1,000 msg/sec、mq.m5.4xlarge 约 10,000 msg/sec)、存储类型选择、预取大小调整都很重要。
Amazon MQ 的费用
Amazon MQ 的费用由代理实例小时计费和存储构成。ActiveMQ 的 mq.m5.large 每小时约 0.288 美元 (月约 207 美元)，RabbitMQ 的 mq.m5.large 约 0.302 美元 (月约 217 美元)（截至 2026 年 8 月）。主备配置下实例费用翻倍。存储每 GB 月费约 0.10 美元。与 SQS (每百万请求约 0.40 美元) 相比成本较高，因此除现有消息代理迁移外应优先考虑 SQS/SNS。
总结
Amazon MQ 是将现有消息代理直接迁移到 AWS 的全托管服务。支持 ActiveMQ 和 RabbitMQ 的行业标准协议 (JMS、AMQP、STOMP、MQTT)，实现无代码修改的迁移。标准配备多可用区自动故障转移、KMS 加密、CloudWatch 监控，最小化基础设施运维负担的同时提高消息应用的可靠性。新开发选择 SQS/SNS、现有应用迁移选择 MQ 的判断标准非常重要。
参考资料（AWS 官方）
本页的第一手信息来源是 AWS 官方网站及官方文档。最新的规格与价格请以下列官方页面为准。
如本页内容与官方文档不一致，请以官方文档为准。