消息队列(MQ)

消息队列(Message Queue,简称MQ)是企业级互联网架构的核心产品,服务于整个阿里巴巴集团已超过 10 年,经过阿里巴巴交易核心链路反复打磨与历年双十一购物狂欢节的严苛考验,是一个真正具备低延迟、高并发、高可用、高可靠,可支撑万亿级数据洪峰的分布式消息中间件。

立即开通 立即开通 购买套餐 购买套餐 消息产品选型 产品价格 帮助文档

  • 消息队列 RocketMQ

    阿里巴巴自研消息产品,13 年沉淀成就 Apache 开源顶级项目,可无缝迁移,无技术绑定

  • MQ for IoT(MQTT)

    Light MessageQueue(LMQ)连接端和云,实现双向通信,可支撑千万级设备与消息并发

  • 金融级消息服务

    阿里巴巴交易核心链路 13 年、天猫双十一 9 年,打造金融级消息服务

  • 丰富的消息类型

    普通消息、分布式事务消息、顺序消息、定时消息/延时消息

消息队列(MQ)新手礼券

阿里巴巴双11官方指定使用的消息中间件

精心打造的功能

  • 阿里巴巴双十一核心产品

    阿里巴巴官方指定消息中间件,成熟、稳定、先进的技术体系,感受双十一产品的完美体验

    交易核心链路反复打磨

    服务于阿里巴巴集团99%以上的消息业务,历时超过 10 年,是交易链路的核心产品;


    历年双十一严苛考验

    支撑历年双11、双12万亿级数据洪峰,2016年双十一零点 TPS 峰值高达几千万,活动当天消息总量超过万亿级,创造了国内乃至世界上最大的消息流转纪录;


    Apache 开源顶级项目

    2016 年阿里巴巴正式宣布将自研产品消息队列(MQ)的内核引擎 RocketMQ 捐赠给 Apache 软件基金会,正式成为 Apache 开源顶级项目;


    OpenMessaging(即将开放,敬请期待)

    分布式领域内,第一个由中国公司主导的业界标准,已在linux foundation完成落地;

  • MQ for IoT (MQTT)

    Light MessageQueue(LMQ)万物互联,可支撑千万级设备与消息并发,适用于物联网、车联网、移动 Apps、互动直播等领域

    大容量

    可支撑千万级设备同时在线与消息并发,毫秒级消息推送;


    多协议

    MQTT,WebSocket,国标808,电动汽车 GB/T 32960,定制协议;


    多语言

    JAVA、.NET、C++、PHP、iOS、Android、JavaScript、nodeJS、Go 等多种语言;


    可扩展

    可根据业务规模弹性扩展,对用户透明;

  • 丰富的消息类型

    多种消息类型,满足不同的业务需求

    普通消息

    普通的消息类型,解决系统间异步解耦,削峰填谷,日志服务,大规模机器的Cache同步,实时计算分析等;


    顺序消息

    按照消息的发布顺序进行顺序消费(FIFO),支持全局顺序与分区顺序;查看详情 >


    事务消息

    MQ 提供类似 X/Open XA 的分布事务功能,通过 MQ 事务消息能达到分布式事务的最终一致;查看详情 >


    定时消息

    将消息发送到 MQ 服务端,在消息发送时间(当前时间)之后的指定时间点进行投递,比如指定时间在 2016/01/01 15:00:00 进行消息投递;查看详情 >


    延时消息

    将消息发送到 MQ 服务端,在消息发送时间(当前时间)之后的指定延迟时间点进行投递,比如指定消息发送时间的 30 分钟之后进行投递;查看详情 >

  • 高性能 & 低延迟

    支持千万级的 QPS,万亿级的消息流转,可弹性扩展,无并发限制,无性能上限 高性能

    高性能

    支持千万级的 QPS(每秒钟消息收发条数),万亿级的消息流转,无并发限制,无性能上限;


    可扩展

    支持万级 Topic,队列数可弹性扩展;集群规模可自动扩缩,对用户完全透明;


    低延迟

    经过双十一反复打磨,攻克了慢请求的业界难题,在高并发高吞吐量情况下系统负载过高导致的响应时间抖动问题,在2016年双十一万亿消息流转中 99.6% 的消息写入延迟在 1ms 以内,99.996% 的消息写入延迟在 10ms 以内;


    海量堆积

    在海量堆积的情况下,始终保持高性能,不影响集群的正常服务,在削峰填谷(蓄洪)的场景下,显得尤其重要;


    实时推送

    消息到达服务器立刻投递,保证消息实时性;

  • 高可靠 & 高可用

    数据可靠性 99.99999999%,服务可用性 99.95%

    数据可靠性

    同步双写与三副本数据备份,数据可靠性高达 99.99999999%;


    服务可用性

    集群部署与主备自动切换技术,确保服务可用性高达 99.95%;

  • 安全访问控制

    提供鉴权与授权机制、主子账号等功能,提供企业级的安全防护

    权限控制

    以消息主题(Topic)、订阅组(ConsumerId)的粒度对用户访问权限进行控制,对每一条消息(Message)的收、发都进行严格的访问控制,确保消息的安全性;


    主子账号

    全面支持阿里云 RAM 主子账号、黑白名单、STS 等功能;


    授权

    支持跨账号授权与主子账号授权;


    安全

    支持 HTTPS,阿里云 VPC 访问等;

  • 一体化运维

    提供一整套完备的、金融级的产品运维体系

    消息查询

    用户可以通过 Topic/Message ID/Message Key 查询 MQ 服务器上的消息;查看详情 >


    全链路消息轨迹

    完整记录消息在消息的生产方、消息队列服务器、消息的消费方之间流动的全过程数据,并将这些数据汇聚分析,构成可视化的全链路消息轨迹;查看详情 >


    消息回溯

    通过指定时间的方式,对已经消费过的消息进行回放,是帮助用户进行故障处理的一柄利器;


    资源报表

    通过可以查看每个消息主题(Topic)、订阅组(ConsumerId)的历史数据与实时数据,帮助用户进行数据分析;查看详情 >


    监控告警

    每个订阅组都可以根据消息的消费延时间、消息堆积量等因素进行监控告警设置,帮助用户及时发现问题;查看详情 >


    Open API

    MQ 提供给用户的一整套完备的管控类 Open API,用于实现一系列资源管理和运维功能;查看详情 >

  • 多协议支持

    TCP、HTTP、WebSocket、MQTT、国标808协议、新能源电动汽车GB/T 32960协议

MQ 产品系列说明

  • 付费方式
  • 实例类型
  • 专家尊享通道 & 保价护航
  • SQL 属性过滤
  • 数据传输加密
  • 多路访问方式
  • VPC SingleTunnel 访问
  • 消息存储时间
  • Open API
  • 消息轨迹
  • 顺序消息
  • 定时消息
  • 分布式事务消息
  • MQ 铂金版
  • 包年/包月(预付费)

  • 专享实例,独占物理节点

  • MQ 铂金版在 2017 全年 0 故障,做到 100% 可用性
    产品 & 研发团队核心成员直接提供技术支持,提供 MQ 相关的技术架构梳理、业务场景分析、Coding Review 以及关键时期的保驾护航

  • 以 SQL 表达式的方式对消息属性内容进行精确过滤,从而使得消息的订阅处理更加高效

  • 支持数据传输加密,确保数据安全

  • 可根据用户需求,支持 VPC、经典网络、公网、弹内等多路访问配置

  • 支持 SingleTunnel 访问方式,混合云场景下最为适用

  • 可支持更长消息保留时间,按实例存储规格存储

  • 基础 API:Topic 查询、Consumer ID 查询等
    高级 API:资源创建、消息堆积、消费者状态、消息轨迹等

  • 全实例默认支持消息轨迹

  • 铂金版特惠,与普通消息计费方式一致

  • 铂金版特惠,与普通消息计费方式一致

  • 铂金版特惠,与普通消息计费方式一致

  • ¥ 24980 /月起
    立即购买
  • MQ 按量付费
  • 按量计费(后付费)

  • 共享实例,虚拟隔离

  • 不支持

  • 不支持

  • 不支持

  • 不支持

  • 不支持

  • 3 天

  • 只支持部分基础 API

  • 默认不支持,需按 Topic / Consumer 申请

  • 成本较高,以普通消息的 25 倍计费

  • 成本较高,以普通消息的 25 倍计费

  • 成本较高,以普通消息的 50 倍计费

经典应用场景

  • MQ for IoT

  • 分布式事务

  • 实时计算

  • 大规模缓存同步

  • MQ for IoT

    MQ for IoT

    物联网设备通过微消息队列(LMQ)连接云端,双向通信,数据传输;设备数据通过消息队列(MQ)连接计算引擎,分析数据或者源数据实时高效写入到 HiTSDB / HiStore / ODPS 等。

    能够解决

    • 双向通信

      物联网设备与云端连接,双向通信,数据传输

    • 实时监控

      实现物联网设备实时监控分析系统

  • 分布式事务

    再不会因为冗长的『大事务』而烦恼

    在传统的事务处理中,多个系统之间的交互耦合到一个大事务中,响应时间长,更降低了系统的整体可用性。引入 MQ 分布式事务消息,将大事务进行了上、下游拆分,上游核心交易系统和 MQ 之间组成一个小事务;下游业务系统(购物车、积分、其他)相互异步化并完成解耦,从而实现最佳的架构设计,处理效率高,可用性强。

    能够解决

    • 数据最终一致

      同时成功,同时失败,达到数据最终一致

    • 下游业务系统隔离

      下游业务系统(购物车、积分、其他)相互隔离,并行处理

  • 实时计算

    数据在流动中产生价值

    通过消息队列(MQ),将源端不停产生的数据实时流入到计算引擎。可采用如下计算引擎:Spark / Storm / EMR / ARMS / BeamRunner

    能够解决

    • 数据实时流入计算引擎

      通过MQ,可将源端数据实时流入计算引擎

  • 大规模缓存同步

    大规分布式模缓存同步

    如天猫双11大促,各个分会场琳琅满目的商品,每件商品的价格都会实时变化,实时通知;传统方式大量并发访问商品数据库导致会场页面响应时间长,集中式缓存导致带宽成瓶颈,从而限制了商品变更的访问流量,通过 MQ 可以轻松构建分布式缓存,实时通知商品数据的变化;

    能够解决

    • 实时数据更新

      通过消息实时推送的方式,让数据实时得以更新;

    • 降低页面响应时间

      大量并发访问商品数据库,减少页面响应时间

    • 满足大规模访问需求

      大促众多分会场,多缓存的架构设计,可以满足对商品变更的大量访问需求;

多种消息类型,适用于不同场景

消息队列 RocketMQ 按量付费

通用消息场景,支持多种消息类型,性能优越

特性:

支持多种消息类型、多种协议、多语言SDK 具备消息全链路轨迹查询、监控报警机制 百万级堆积能力、毫秒级投递延迟

使用场景:

¥2/每百万次API调用 详细定价 >

微消息队列 LMQ 购买3个月立享75折

适用于移动互联网以及物联网等场景

特性:

完整支持标准的 MQTT 协议,应用场景丰富 支持国标 808、电动汽车 GB/T 32960 等协议

使用场景:

优惠价¥65.25/3个月 立即购买 >

消息队列 RocketMQ 铂金版

优质的私人定制消息队列服务

特性:

专享实例(物理隔离) 提供更有隔离性、更稳定、更优质的服务 7*24 小时 on-call

使用场景:

¥24980/月起 立即购买 >

消息队列 Kafka

全面解决 Kafka 开源产品的痛点,更安全、更可靠

特性:

支持全链路消息轨迹、消息堆积查询 提供更有隔离性、更稳定、更优质的服务完备的账号体系,访问权限隔离 万级 Topic 情况,始终保证高吞吐能力 海量消息堆积情况下,始终保证高吞吐能力

使用场景:

正在公测 接入说明 >

微消息队列 LMQ 铂金版

提供更有隔离性、更稳定、更优质的微消息队列服务

特性:

专享实例(物理隔离) 更有隔离性、最稳定、更优质的服务 7*24 小时 on-call

使用场景:

¥47000/月起 立即购买 >