What is ApsaraMQ for RocketMQ?
ApsaraMQ for RocketMQ is a distributed messaging platform built on Apache RocketMQ. It unifies message, event, and stream processing with low latency, high concurrency,high availability, and high reliability. Core capabilities include asynchronous decoupling, stream data processing, and event-driven processing for distributed applications.
Why choose ApsaraMQ for RocketMQ
ApsaraMQ for RocketMQ is built on Alibaba Cloud's cloud-native infrastructure and is compatible with core Apache RocketMQ APIs and features.
Compared to self-managed clusters, ApsaraMQ for RocketMQ offers these benefits:
Advanced architecture
ApsaraMQ for RocketMQ decouples computing from storage. Storage and computing scale horizontally and independently, enabling elastic operations and maintenance (O&M) and high-performance messaging at scale.
High performance
A single-instance cluster sustains up to 1 million transactions per second (TPS) for sending and receiving messages, ensuring stability during peak traffic such as major promotions.
Security and reliability
-
Zone-redundant storage: Deployed across multiple zones with triple-redundant data storage. If a zone becomes unavailable, the service remains accessible.
-
Data replication: Supports cross-region and intra-region data replication. Routing rules synchronize data between source and destination instances.
Stability SLA
Multi-zone deployment delivers an industry-leading SLA: 99.99% service availability and 99.99999999% data reliability through multi-replica storage.
Elasticity and cost-effectiveness
Message computing combines reserved and burst capacity, eliminating the need to reserve large buffers for traffic spikes and saving up to half the machine resources. Storage is serverless and pay-as-you-go, offering greater elasticity and lower costs than attached cloud disks.
O&M and observability
Provides O&M and observability features: one-click integration with OpenTelemetry and Prometheus, end-to-end tracing, and OpenAPI support for self-service O&M integration.
Finance-grade disaster recovery
Supports global cross-region message routing and replication with millisecond-level latency and topic-level data backup and synchronization.
Use cases
Built on unified message storage and a lightweight computing layer, ApsaraMQ for RocketMQ supports three core scenarios: asynchronous decoupling, stream data processing, and event-driven processing.
Business messages
-
ApsaraMQ for RocketMQ was originally built for Alibaba's Double 11 and is widely used in microservice systems for logistics, shopping carts, and credit points. ApsaraMQ for RocketMQ provides these benefits:
-
Asynchronous decoupling to shorten processing links
ApsaraMQ for RocketMQ decouples upstream from downstream services, shortening the invocation chain. This yields faster response times, looser coupling, and higher developer efficiency.
-
Peak-load shifting to improve stability
Unlike traditional middleware that only provides asynchronous operations, ApsaraMQ for RocketMQ was built for online transaction scenarios and includes peak-load shifting as a core feature, improving stability and reducing costs.
ApsaraMQ for RocketMQ accumulates hundreds of millions of messages and handles mixed hot and cold traffic models. It absorbs traffic surges during peak scenarios such as major promotions, keeping downstream services within safe operational limits.
-
-
The ApsaraMQ for RocketMQ distributed transactional message solution offers these benefits:
-
High-performance system
Based on eventual consistency, transactional messages deliver higher throughput and greater scalability than traditional XA transactions.
-
Reduced development cost
A two-phase interface coordinates multiple transaction branches, eliminating the need for business compensation logic.
The following figure compares a traditional transaction with the ApsaraMQ for RocketMQ transactional message solution:
-
-
ApsaraMQ for RocketMQ provides distributed scheduled messages with second-level precision, widely used for order timeout processing and distributed delayed scheduling.
ApsaraMQ for RocketMQ scheduled messages provide these benefits:
-
High scheduling precision and low development overhead
No stepped intervals for scheduling times. Trigger events with arbitrary precision without business-side deduplication.
-
High performance and scalability
Traditional scheduling solutions require database scans that create performance bottlenecks. ApsaraMQ for RocketMQ uses event-driven processing to achieve millions of TPS.
-
Stream processing
ApsaraMQ for RocketMQ provides high-throughput stream storage that connects log collection, data integration, and analytics systems. Use ApsaraMQ for RocketMQ to distribute upstream data to downstream systems such as real-time computing and offline storage.
Event-driven processing
Combine ApsaraMQ for RocketMQ with EventBridge to implement event-driven architectures. Visual event rules in EventBridge process message data and trigger downstream targets such as Function Compute, HTTP endpoints, or third-party services.
Migration guide
Get started
Create an ApsaraMQ for RocketMQ instance: