Alibaba 充值返赠 10% 起

阿里云 ApsaraMQ 消息队列

阿里云 ApsaraMQ 是阿里自研的三合一消息队列家族——RocketMQ（金融级高可靠，双十一验证）、CKafka（100% 兼容开源 Kafka）和 MQTT（物联网千万级设备连接），三类引擎三种计费模型。通过 SevenColorYun 购买可享受充值返赠 10% 起的代理优惠。

产品规格

引擎家族: RocketMQ（高可靠金融级）+ CKafka（100% 兼容开源 Kafka）+ MQTT（物联网）
RocketMQ 特点: 双十一验证，最高 Exactly Once，事务消息，延迟消息，消息轨迹
CKafka 特点: 100% 兼容开源 Kafka，分区内有序，消息回放，百万 TPS
MQTT 特点: 物联网标准协议，千万级设备连接，遗嘱消息，保留消息
最大吞吐: RocketMQ: 万级 TPS / CKafka: 百万级 TPS / MQTT: 千万级连接

三合一

引擎家族

RocketMQ/Kafka/MQTT

双十一

压测验证

RocketMQ 金融级

百万

CKafka TPS

100% 兼容开源

千万

MQTT 连接

物联网标准协议

ApsaraMQ：阿里三合一消息家族 —— RocketMQ 双十一事务消息 + CKafka 百万 TPS 流处理 + MQTT 千万 IoT 连接，为什么阿里把三个引擎放一个品牌下？

阿里云 ApsaraMQ 是阿里云消息队列的统一品牌，包含三个独立的引擎产品：RocketMQ（阿里自研的金融级高可靠消息引擎——支撑每年双十一的交易消息峰值，提供事务消息/Exactly Once/延迟消息/消息轨迹）、CKafka（100% 兼容开源 Apache Kafka——社区版 Kafka 应用可以直接迁移，不修改一行代码）、MQTT（物联网标准协议——支持 QoS 0/1/2、遗嘱消息、保留消息，千万级设备同时在线连接）。三类引擎共享同一套阿里云控制台、VPC 网络、RAM 鉴权和 CloudMonitor 监控——不需要在三个独立的消息产品之间切换账号和运维工具。

三引擎的选型逻辑是基于消息的”可靠性等级”和”处理模式”划分的。RocketMQ 解决”不能丢失不能重复”的金融级消息——订单/支付/库存扣减的每一条消息必须有迹可循、必须 Exactly Once、必须支持事务回滚。CKafka 解决”海量数据流的实时处理”——游戏埋点/用户行为/服务器日志每秒百万条消息的持续写入和消费，支持消费者 Offset 重置和历史消息回放。MQTT 解决”海量设备轻量连接”——IoT 设备（智能音箱/车联网/工业传感器）的 MQTT 协议连接，每条消息几 KB、连接常年在线但消息频率低。

ApsaraMQ 三种引擎的技术差异和成本怎么理解？

RocketMQ（¥50/月标准版起）：

核心能力：事务消息（半消息→执行本地事务→Commit/Rollback）、Exactly Once 消费（基于消息 Key 去重 + 消费记录）、延迟消息（18 个延迟等级，预定义延迟时间）、消息轨迹（每条消息从生产到消费的完整时间线和状态）
适用场景：电商订单、金融交易、分布式事务——每一条消息都不能丢、不能重复
计费：按实例规格（TPS + 存储）计费，超出规格按 API 调用数加收

CKafka（¥138/月标准版起）：

核心能力：分区（Partition）内严格有序、消费者 Group Offset 管理、消息回放（Offset 重置到任意位置）、MirrorMaker 2 跨集群数据复制
适用场景：日志采集、用户行为埋点、实时流处理（Flink/Spark Streaming）、数据管道（CDC→Kafka→数据湖）
计费：按实例规格（带宽 + 磁盘）计费，与开源 Kafka 一样需要预置容量

MQTT（按连接数 + 消息数计费）：

核心能力：MQTT 3.1.1/5.0 标准协议、QoS 0（最多一次）/1（至少一次）/2（精确一次）、遗嘱消息（设备异常断开时自动触发）、保留消息（新订阅者立即接收最后一条消息）
适用场景：IoT 设备消息通道、车联网车辆遥测、智能家居设备控制指令
计费：按同时在线连接数（每万连接 ¥X/月）+ 消息数（每百万条 ¥X）

一个电商平台——RocketMQ 处理订单/支付/发货消息（标准版 ¥200/月）+ CKafka 采集用户行为埋点和服务器日志（标准版 ¥400/月）= ¥600/月。通过 SevenColorYun 充值返赠 10% = 实际 ¥540/月。

ApsaraMQ 常用产品组合怎么搭？

业务场景	MQ 配置	配套产品	月费估算
电商订单+交易	RocketMQ 标准版（事务消息/Exactly Once/延迟消息）	ECS（订单服务）+ RDS（订单数据库）+ OSS（消息归档）	¥200-800
游戏数据管道	CKafka Professional（百万 TPS + 消息回放）	ECS（游戏服务器）+ ACK（Flink 消费者）+ MaxCompute（数据分析）	¥500-2,000
IoT 设备管理	MQTT（千万连接 + QoS 1）	ECS（设备管理后端）+ Tair（设备状态缓存）+ OSS（设备日志）	¥300-1,500
混合消息架构	RocketMQ（交易消息）+ CKafka（数据管道）+ MQTT（IoT 设备）	ECS（业务后端）+ ACK（消费者）+ VPC（网络隔离）	¥600-3,000

5 步开通 Alibaba：从零到实例启动

联系客服

点击右下角 WhatsApp 或 Telegram，告知消息场景（事务消息/流处理/IoT）和预估吞吐量

提交信息

提供企业名称或个人信息用于账号注册

选择充值金额

¥6,800 起充，支持支付宝、微信、USDT、银行转账

获取凭证

即刻收到阿里云账号，立即可用

开始使用

核心特性

三合一消息引擎家族——一套平台覆盖消息队列/流处理/物联网消息全部场景
RocketMQ 事务消息 + Exactly Once + 延迟消息 + 消息轨迹（金融级高可靠）
CKafka 100% 兼容开源 Kafka——现有 Kafka 应用零修改迁移
MQTT 千万级设备连接——物联网/车联网/智能家居消息通道
与阿里云 ECS/ACK/OSS/PAI 原生 VPC 内网集成
所有引擎共享同一阿里云账号/同一网络/同一监控体系

常见问题

通过 SevenColorYun 购买 ApsaraMQ 有什么优势？

ApsaraMQ 是 RocketMQ/Kafka/MQTT 三合一消息家族，三种引擎各有不同的计费模型。通过我们购买可享充值返赠 10% 起（充 $1,000 送 $100，充 $5,000 送 $800），免国内实名开通，提供消息架构咨询（RocketMQ vs Kafka vs MQTT 引擎选型、双十一级消息架构设计、消息轨迹和排障），统一账单管理。

ApsaraMQ RocketMQ 和 CKafka 怎么选？

RocketMQ 的强项是事务消息（分布式事务的最终一致性——下单+扣库存+扣余额要么全成功要么全回滚）、延迟消息（指定 18 个延迟等级——'下单 30 分钟未支付自动取消'的经典实现）、消息轨迹（每条消息的生产/投递/消费时间线全记录——金融合规的硬需求）。CKafka 的强项是流处理（Kafka Streams/Flink 消费 + 大数据生态 + 消息回放——适合日志/埋点/实时数据分析管道）。选型原则：金融/电商/交易系统→RocketMQ；日志/流处理/数据分析→CKafka；IoT 设备连接→MQTT。

ApsaraMQ 三种引擎的计费模型有什么区别？

RocketMQ 按实例规格计费（标准版 ¥50/月起，含指定 TPS + 存储）+ 超出规格按 API 调用数计费。CKafka 按实例规格计费（标准版 ¥138/月起，含指定带宽 + 磁盘）——与开源 Kafka 一样，需要预置分区和磁盘，非纯 Serverless。MQTT 按同时在线连接数 + 消息数计费——适合 IoT 场景（设备常年在线但消息量少，按连接计费而非按消息计费更经济）。三种引擎的费用都在同一个阿里云账号余额中消费。