Message Queue for Apache RocketMQ is a distributed unified processing platform for messages, events, and streams. It is developed by Alibaba Cloud based on Apache RocketMQ. Message Queue for Apache RocketMQ provides low latency, high concurrency, high availability, and high reliability. Message Queue for Apache RocketMQ is suitable for distributed Internet applications and provides core capabilities, such as asynchronous communication, stream processing, and event-driven data processing.
Advantages
Message Queue for Apache RocketMQ is based on the high-quality infrastructure of Alibaba Cloud and is compatible with the core APIs and features of Apache RocketMQ.
Message Queue for Apache RocketMQ has the following advantages over self-managed RocketMQ clusters:
Advanced architecture
Message Queue for Apache RocketMQ adopts a decoupled architecture that allows separate scaling of storage and compute resources on demand. This makes O&M efficient and flexible and meets user requirements for high performance and good scalability.
High performance
Message Queue for Apache RocketMQ reliably supports a transactions per second (TPS) of one million for each instance. Users do not have to worry about system stability during traffic spikes, such as sales promotions.
Stability SLA
Message Queue for Apache RocketMQ provides industry-leading stability service level agreement (SLA) assurance, a service usability of up to 99.99%, and a data availability of up to 99.99999999% based on a replication mechanism.
Elasticity and cost efficiency
Message Queue for Apache RocketMQ allows users to flexibly scale out or scale in instances to handle surging traffic. Users do not need to reserve a large buffer for unexpected traffic surges and can save up to 50% of hardware resources. Elastic serverless storage supports pay-as-you-go usage and significantly reduces costs compared with cloud volumes that do not support elastic scaling.
Visualized monitoring
Message Queue for Apache RocketMQ supports convenient integration of visualized monitoring platforms such as OpenTelemetry, end-to-end tracing systems, and Prometheus. Message Queue for Apache RocketMQ also provides complete OpenAPI capabilities for integration of self-service O&M systems.
Financial-grade disaster recovery
Message Queue for Apache RocketMQ can route and replicate global messages and can synchronize messages for specific topics at latencies of milliseconds. Message Queue for Apache RocketMQ also supports active-active disaster recovery for regions in China.
Scenarios
Based on a unified message storage layer and a lightweight computing layer, Message Queue for Apache RocketMQ is used for microservices in scenarios such as asynchronous communication, stream processing, and event-driven data processing.Business messages
-
Asynchronous communication for business decoupling, and load shifting
Message Queue for Apache RocketMQ was first used to handle the traffic surges of the November 11 shopping festival of Alibaba. At present, Message Queue for Apache RocketMQ is widely used for asynchronous communication for business decoupling and load shifting in microservice business systems such as logistics systems, shopping cart systems, and credit point systems. Message Queue for Apache RocketMQ delivers the following benefits:- Shorter links thanks to asynchronous communication
Message Queue for Apache RocketMQ decouples upstream businesses from downstream systems and shortens the links for serverless calls. Shorter links result in faster responses and more efficient application development.
- Higher system stability as a result of load shifting
Conventional message middleware services support asynchronous communication, while Message Queue for Apache RocketMQ additionally supports load shifting as a basic messaging capability for Internet and transaction scenarios. Load shifting improves system stability while reducing business costs.
To be able to shift loads, a message middleware service must accommodate a large number of unprocessed messages and properly handle the traffic model in which hot and cold messages are intermixed. Message Queue for Apache RocketMQ allows hundreds of millions of messages to pile up. This way, it is able to accommodate traffic peaks and ensure that downstream systems can run stably within safety water levels.
- Shorter links thanks to asynchronous communication
-
Distributed transactions
Message Queue for Apache RocketMQ provides a distributed solution based on Transactional messages. This solution delivers the following benefits:- High system performance
The distributed transaction solution that is provided by Message Queue for Apache RocketMQ can ensure the final consistency of transactions. This solution provides higher throughput and scalability than the conventional eXtended Architecture (XA)-based solution.
- Low development cost.
The distributed solution uses the interfaces of only two phases to coordinate multiple transaction branches and does not require message retry subsequently. This allows developers to easily develop applications.
- High system performance
-
Distributed scheduled or delayed processing
Message Queue for Apache RocketMQ allows you to schedule the processing of distributed scheduled messages. You can specify a up to the seconds. This feature is suitable for scenarios such as timed out orders and distributed delayed scheduling systems.
The scheduled message feature of Message Queue for Apache RocketMQ provides the following benefits:- High schedule precision and easy development
Schedules are not based on increments. You can specify any point in time to trigger a schedule so your systems do not have to handle duplicate messages.
- High performance and scalability
In a traditional solution, scheduling message processing is complex and requires operations that can cause bottlenecks, such as database scanning. Message Queue for Apache RocketMQ supports event driving based on the scheduled message feature, which helps deliver a million-level TPS.
- High schedule precision and easy development
Stream processing
Message Queue for Apache RocketMQ supports large-throughput stream storage. Message Queue for Apache RocketMQ can be seamlessly integrated with log collection, data integration, and data analysis systems. You can use Message Queue for Apache RocketMQ to distribute upstream data to downstream systems, such as real-time computing and offline storage systems.
Event-driven processing
Message Queue for Apache RocketMQ can be used together with EventBridge to easily implement an event-driven processing model. Message data can be used by EventBridge to drive downstream events in applications such as Function Compute, HTTP interfaces, and third-party custom targets.
Quick guide to migrating businesses to Alibaba Cloud
Create an instance
Click the button below to jump to the page to create a Message Queue for Apache RocketMQ instance.