All Products
Document Center

ApsaraMQ for RocketMQ:What is ApsaraMQ for RocketMQ?

Last Updated:Mar 13, 2024

ApsaraMQ for RocketMQ is a distributed and unified processing platform for messages, events, and streams. Developed by Alibaba Cloud based on Apache RocketMQ, ApsaraMQ for RocketMQ provides low latency, high concurrency, high availability, and high reliability. ApsaraMQ for RocketMQ is suitable for distributed Internet applications and provides core capabilities such as asynchronous communication, stream processing, and event-driven data processing.


ApsaraMQ for RocketMQ is developed based on the cloud-native infrastructure of Alibaba Cloud and is compatible with the core API operations and features of Apache RocketMQ.

Compared with self-managed Apache RocketMQ clusters, ApsaraMQ for RocketMQ provides the following benefits.

Advanced architecture

ApsaraMQ for RocketMQ uses a messaging architecture that decouples computing from storage. This way, you can perform separate scaling operations on storage and computing resources to ensure flexible O&M, high scalability, and high performance.

High performance

ApsaraMQ for RocketMQ can provide up to one million messaging transactions per second (TPS) for each instance. You do not need to worry about system stability in scenarios in which traffic spikes occur, such as sales promotion.

High security and reliability

  • Zone redundancy: High availability across multiple zones is provided for brokers. Data is stored in three replicas. If a zone fails, the service can still be accessed as expected.

  • Data replication: Cross-region data replication and intra-region data replication are supported. You can route messages from a source instance to a destination instance.

Stability SLA

ApsaraMQ for RocketMQ provides a service availability of up to 99.99%, a high-availability architecture that stores data in multiple replicas, and a data reliability of up to 99.99999999%.

Scalability and cost efficiency

ApsaraMQ for RocketMQ allows you to reserve messaging TPS and supports elastic TPS. You do not need to reserve a large specification if a small amount of bursty traffic is required for your business. This way, you can save up to half of the broker resources. ApsaraMQ for RocketMQ also provides elastic serverless storage on a pay-as-you-go basis. Compared with mounted cloud disks, serverless storage is scalable and more cost-efficient.

Visualized O&M

ApsaraMQ for RocketMQ can be integrated with observability systems such as Managed Service for OpenTelemetry, end-to-end tracing systems, and Managed Service for Prometheus. ApsaraMQ for RocketMQ also provides a comprehensive set of API operations for the integration of self-service O&M systems.

Finance-grade disaster recovery

ApsaraMQ for RocketMQ allows you to route and replicate messages across regions. It supports topic data synchronization at a latency within milliseconds.

Use scenarios

Based on unified message storage and a lightweight computing layer, ApsaraMQ for RocketMQ can be used in scenarios such as the asynchronous decoupling of microservices, streaming data processing, and event-driven data processing.

Business messages

  • Asynchronous decoupling and peak-load shifting

    ApsaraMQ for RocketMQ is developed as a core system for the Double 11 Shopping Festival and is widely used for asynchronous decoupling and peak-load shifting in microservices systems such as logistics, shopping cart, and credit point systems. ApsaraMQ for RocketMQ provides the following benefits:

    • Optimized data processing

      ApsaraMQ for RocketMQ decouples upstream business from downstream systems and accelerates the processing of serverless calls. After decoupling is performed, the system can respond faster and the development efficiency is higher.


    • High system stability

      ApsaraMQ for RocketMQ is developed for online business and e-commerce transactions. Compared with traditional message-oriented middleware, ApsaraMQ for RocketMQ provides not only the asynchronization capability, but also the peak-load shifting capability. Peak-load shifting improves system stability and reduces business costs.

      The peak-load shifting feature requires message-oriented middleware to support a large number of accumulated messages and a traffic model in which hot messages and cold messages are mixed. ApsaraMQ for RocketMQ supports the accumulation of hundreds of millions of messages. It can accommodate traffic spikes in scenarios such as big sales promotions and ensure the stable and secure running of downstream services.


  • Distributed transaction solution

    ApsaraMQ for RocketMQ provides a distributed transaction solution that is known as the transactional message feature. For more information, see Transactional messages. The solution provides the following benefits:

    • High system performance

      Developed based on the concept of result consistency, the distributed transaction solution provides higher throughput and scalability than the traditional eXtended Architecture (XA)-based transaction solution.

    • Low development costs

      The development logic of transactional messages is simple. You can coordinate multiple transactions by calling API operations that are based on the two-phase commit protocol without performing additional processing.

    The following figure provides an example of order creation to compare the traditional transaction solution and the distributed transaction solution provided by ApsaraMQ for RocketMQ.分布式业务

  • Scheduled or delayed scheduling

    ApsaraMQ for RocketMQ provides the scheduled message feature that is accurate to seconds. For more information, see Scheduled and delayed messages. Scheduled messages can be used in scenarios such as time-out order processing and delayed scheduling.

    Scheduled messages provided by ApsaraMQ for RocketMQ provide the following benefits:

    • High schedule precision and easy development

      Schedules are not based on increments. You can specify a point in time to trigger a schedule. This way, the system does not need to handle duplicate messages.

    • High performance and scalability

      Traditional schedule solutions are complex and require database scanning. This causes performance bottleneck issues. ApsaraMQ for RocketMQ can perform event-driven processing and provide TPS that can be used to process millions of messages based on the scheduled message feature.


Streaming data processing

ApsaraMQ for RocketMQ supports large-throughput stream storage and can be seamlessly integrated with log collection systems, data integration systems, and data analysis systems. You can use ApsaraMQ for RocketMQ to distribute upstream data to downstream systems, such as real-time computing and offline storage systems.


Event-driven processing

ApsaraMQ for RocketMQ can be integrated with EventBridge to perform event-driven processing. Based on the event rules in EventBridge, message data can be used to drive events in downstream applications such as Function Compute, HTTP API operations, and third-party applications.


Quick guide for migrating business to Alibaba Cloud


Create an instance

Click the button below to go to the buy page to create an ApsaraMQ for RocketMQ instance.

Create an ApsaraMQ for RocketMQ instance