消息队列RocketMQ版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台,面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。

为什么选择消息队列RocketMQ版

消息队列RocketMQ版基于阿里云云原生优质的基础设施实现,兼容Apache RocketMQ的核心API和功能。

相对于自建RocketMQ集群,消息队列RocketMQ版具有如下优势:

架构先进性

全面采用存储和计算分离的消息架构,存储和计算可以独立按需水平扩展,满足高效弹性运维和高性能大规格能力的诉求。

高性能

可提供单实例集群最高100万TPS稳定消息收发的能力,无需担心大促等峰值流量场景的系统稳定性。

稳定性SLA

提供业内领先的稳定性SLA保障,消息服务可用性最高99.99%;高可用三副本起步,数据可靠性最高99.99999999%。

弹性低成本

消息计算处理提供预留+突发弹性的组合能力,业务无需再为突发流量预留大量Buffer资源,最高可节省一半机器资源;存储实现Serverless弹性化,按量付费使用,相比挂载云盘无法缩容的情况,具备极大的弹性优势,成本更低。

运维可观测

提供丰富的运维可观测能力,可以一键集成OpenTelemetry、全链路Trace、Prometheus等可观测系统;提供完善的OpenAPI能力,支持集成自助运维系统。

金融级容灾

提供全球跨地域消息路由复制能力,支持毫秒级低延迟、自定义Topic级别数据备份同步能力;提供异地双活容灾能力,支持国内地域组建双活应用系统。

应用场景

消息队列RocketMQ版基于统一消息存储和轻量计算层,主要应用于微服务异步解耦、流式数据处理、事件驱动等场景。

业务消息

  • 异步解耦、削峰填谷

    消息队列RocketMQ版初始于阿里巴巴双十一核心链路,广泛应用于物流、购物车、积分等微服务业务系统,有效承载系统间异步解耦和流量削峰填谷的作用。通过使用消息队列RocketMQ版,可有效实现如下作用:
    • 异步解耦缩短链路

      通过消息队列RocketMQ版将上游业务和下游系统进行解耦,缩短了无服务调用的链路。系统异步化后响应时间更短、上下游轻松耦合,开发效率更高。

      异步解耦
    • 削峰填谷提高稳定性

      传统消息中间件仅满足业务的异步化需求,而消息队列RocketMQ版诞生于在线互联网和交易业务场景,除了满足异步能力,还将削峰填谷作为消息的基础能力。通过削峰填谷不仅能够提高系统稳定性,还能大幅降低业务成本。

      实现削峰填谷的功能,消息中间件需要支持海量的消息堆积能力以及处理好冷热消息混合情况下的流量模型。消息队列RocketMQ版能够提供亿级消息堆积能力,可以在大促等流量峰值场景下抗住流量洪峰,保证下游业务能够在安全水位内平滑稳定的运行。

      削峰填谷
  • 分布式事务

    消息队列RocketMQ版分布式事务消息的方案具备如下优势:
    • 系统性能高

      基于最终一致性的事务消息方案,相比传统XA事务,吞吐性能更高,可扩展性更强。

    • 开发成本低

      基于事务消息开发逻辑简单,仅需两阶段接口即可完成多个事务分支的协调,无需业务做补偿处理。

    下图以创建订单为例对比传统事务和消息队列RocketMQ版事务消息的方案:分布式业务
  • 分布式定时/延时调度

    消息队列RocketMQ版提供精确度到秒级的分布式定时消息能力,可广泛应用于订单超时中心处理、分布式延时调度系统等场景。

    使用消息队列RocketMQ版定时消息有如下优势:
    • 定时精度高、开发门槛低

      消息定时时间不存在阶梯间隔,可以轻松实现任意精度事件触发,无需业务去重。

    • 高性能、可扩展

      传统的定时实现方案较为复杂,需要进行数据库扫描,容易遇到性能瓶颈的问题,消息队列RocketMQ版可以基于定时消息特性完成事件驱动,实现百万级消息TPS能力。

    分布式调度

流式处理

消息队列RocketMQ版具备海量吞吐的流式存储能力,可以有效对接日志收集、数据集成和数据分析等系统。通过消息队列RocketMQ版可以将上游数据分发到下游的实时计算、离线存储等系统。

流式处理

事件驱动

消息队列RocketMQ版可以结合事件总线EventBridge轻松实现事件驱动新模式,消息数据经过事件总线EventBridge的可视化事件规则,驱动下游函数计算、HTTP接口、第三方自定义等数据目标。

事件驱动

上云指引

使用MQ

创建实例

单击下方按钮可立即前往售卖页创建消息队列RocketMQ版实例。

立即创建消息队列RocketMQ版实例