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.
Benefits
ApsaraMQ for RocketMQ is developed based on the cloud-native infrastructure of Alibaba Cloud and is compatible with the core APIs 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 use routing rules to route messages from source instances to destination instances.
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-level data synchronization at a latency within milliseconds.
Scenarios
Based on unified message storage and a lightweight computing layer, ApsaraMQ for RocketMQ can be used in scenarios such as asynchronous decoupling of microservices, streaming data processing, and event-driven data processing.
Business messages
ApsaraMQ for RocketMQ was first developed as a core system for the Double 11 Shopping Festival. ApsaraMQ for RocketMQ 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 was first 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.
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 using APIs 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.
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 APIs, 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.