应用程序集成

使用 Amazon MQ 运维消息代理 - ActiveMQ 与 RabbitMQ 的选型与迁移

整理 ActiveMQ 与 RabbitMQ 的选型标准，介绍从本地环境的迁移模式和高可用性配置。同时解析与 SQS/SNS 的使用场景区分。

約 2 分で読めます

Amazon MQ 的定位与 SQS/SNS 的使用场景区分

Amazon MQ 是 ActiveMQ 和 RabbitMQ 的全托管代理服务。与 SQS 和 SNS 作为 AWS 原生消息服务不同，MQ 以托管方式运维行业标准消息代理。SQS 具有无限吞吐量、自动扩展、与无服务器架构的出色集成，是新开发云原生应用的首选。但现有应用依赖 JMS API、AMQP 协议或复杂路由规则 (主题选择器、消息过滤器) 时，改写为 SQS/SNS 成本巨大。消息优先级控制、事务管理、复杂路由模式等标准协议高级功能需要时也适合 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 的主备配置中，两个代理实例部署在不同可用区，通过 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 的相关书籍。

Amazon MQ 的费用

Amazon MQ 的费用由代理实例小时计费和存储构成。ActiveMQ 的 mq.m5.large 每小时约 0.288 美元 (月约 207 美元)，RabbitMQ 的 mq.m5.large 约 0.302 美元 (月约 217 美元)。主备配置下实例费用翻倍。存储每 GB 月费约 0.10 美元。与 SQS (每百万请求约 0.40 美元) 相比成本较高，因此除现有消息代理迁移外应优先考虑 SQS/SNS。

总结

Amazon MQ 是将现有消息代理直接迁移到 AWS 的全托管服务。支持 ActiveMQ 和 RabbitMQ 的行业标准协议 (JMS、AMQP、STOMP、MQTT)，实现无代码修改的迁移。标准配备多可用区自动故障转移、KMS 加密、CloudWatch 监控，最小化基础设施运维负担的同时提高消息应用的可靠性。新开发选择 SQS/SNS、现有应用迁移选择 MQ 的判断标准非常重要。

相关服务

Amazon MQ支持 Apache ActiveMQ 和 RabbitMQ 的全托管消息代理服务Amazon SQS全托管的消息队列服务，实现应用组件间的解耦Amazon SNS全托管的发布/订阅消息传递和移动通知服务

相关文章

使用 Amazon MSK 构建 Apache Kafka 流处理基础设施 - 集群设计与运维设计 Apache Kafka 托管集群，介绍与 MSK Serverless 的使用场景区分及 MSK Connect 的数据集成模式。Amazon SNS 通知设计 - 扇出模式与消息过滤的最佳实践SNS 的发布/订阅模型、消息过滤策略、FIFO 主题的严格排序、跨账户订阅的设计模式。与 SQS 组合的扇出架构也一并解析。

本主题的更多内容

使用 Amazon AppFlow 实现 SaaS 数据集成 - 与 Salesforce、Slack、Google Analytics 的整合将 Salesforce 和 Slack 的数据以零代码方式同步到 S3 和 Redshift。介绍事件驱动触发器、PII 脱敏以及通过 PrivateLink 实现的安全传输。数据集成 - 使用 Amazon AppFlow 实现 SaaS 与 AWS 之间的无代码数据连接使用 Amazon AppFlow 在 SaaS 应用程序和 AWS 服务之间构建无代码的数据流。详解与 Salesforce、Slack、Google Analytics 等的连接器设置和数据转换。事件驱动架构 - 通过 Amazon EventBridge 实现松耦合系统设计介绍利用 Amazon EventBridge 构建事件驱动架构的方法。EventBridge Pipes 设计最佳实践 - 过滤与批处理的优化介绍 EventBridge Pipes 的过滤设计、批处理大小优化、错误处理策略以及提高成本效率的实践最佳实践。通过 Amazon EventBridge Pipes 实现事件集成 - 源与目标的连接模式介绍将 SQS、DynamoDB Streams、Kinesis 等事件源与目标直接连接，并在中间插入过滤和丰富处理的设计模式。IoT 事件检测 - 通过 AWS IoT Events 自动检测和响应设备状态变化解析如何使用 AWS IoT Events 进行 IoT 设备状态监控和自动响应。介绍检测器模型的状态转换定义、告警功能、与 SNS/Lambda 的联动。工作流管理 - 使用 Amazon MWAA 托管运维 Apache Airflow解析 Amazon MWAA（Managed Workflows for Apache Airflow）的数据管道编排。从设置、DAG 管理到与 Step Functions 的选型进行实践介绍。使用 Amazon MWAA 托管运维 Apache Airflow - DAG 设计与工作流自动化解析通过 MWAA 构建 Airflow 环境、DAG 设计、S3 集成及 Operator 的活用。

相似的文章与服务

Amazon MQ全托管提供 Apache ActiveMQ 和 RabbitMQ，以最小代码变更将现有消息应用迁移到云端的消息代理服务使用 Amazon SQS 构建异步消息传递 - Standard 与 FIFO 队列的设计介绍 Standard 与 FIFO 队列的选择、DLQ 对处理失败消息的转移以及 Lambda 事件源映射的自动处理。Amazon SNS 通知设计 - 扇出模式与消息过滤的最佳实践SNS 的发布/订阅模型、消息过滤策略、FIFO 主题的严格排序、跨账户订阅的设计模式。与 SQS 组合的扇出架构也一并解析。使用 Amazon SNS 构建 Pub/Sub 消息传递 - 扇出模式与过滤讲解 SNS 基于主题的消息传递、订阅过滤器以及 SQS 扇出模式。