ApsaraMQ for RocketMQ

Features

• 

  High-performance and Low Latency

  ApsaraMQ for RocketMQ ensures high-performance even in the case of a massive message stack and without affecting cluster service. This is particularly important during load shifting (flood storage).

  
  

  From years of experience servicing Alibaba’s annual 11-11 e-commerce event, the technical team at Alibaba Cloud have developed methods to resolve slow request response time jitter problems caused by system overload due to super-high concurrency. Among the flow of the trillion messages sent during the 11-11 event held in 2017, the recorded latency of 99.6% of message write requests was less than 1ms, and less than 10ms for the recorded latency of 99.996% message write requests.

  
  

  The message is sent immediately after it arrives at the server, ensuring timely message delivery.

• 

  High Availability, Reliability, and Scalability

  ApsaraMQ for RocketMQ provides highly available message cloud services in multiple regions worldwide. The server rooms and hardware facilities are built according to high standards in accordance with the IDC of Alibaba. Each region is deployed with multiple server rooms. Message Queue can still effectively release messages to applications even if an entire server is out of service.

  
  

  ApsaraMQ for RocketMQ supports same-city multi-active deployment solutions in multiple financial regions including China East 1 (Hangzhou), China East 2 (Shanghai), China South 1 (Shenzhen) and other regions, protecting core financial transaction systems.

• 

  Secure Access Control

  ApsaraMQ for RocketMQ supports primary account and sub-account creation, blacklist and whitelist functionality, and Alibaba Cloud RAM’s STS functions.

  
  

  ApsaraMQ for RocketMQ supports cross-account authorization and authorization through primary accounts and sub-accounts.

  
  

  The ordered messages are consumed in the order of release (first-in-first-out). Message Queue supports global order and segmented order of messages.

• 

  Topic Model (Topic)

  ApsaraMQ for RocketMQ supports Pub/Sub mode. In this mode, the creator sends the message to the specified topic. One or multiple consumers can subscribe to the message.

  
  

  ApsaraMQ for RocketMQ supports cluster consumption and broadcast consumption. Subscribers that use the same consumer ID belong to the same cluster. In cluster consumption mode, each message only needs to be processed by any one of the subscribers in the cluster. In broadcast consumption mode, each message is pushed to all subscribers in the cluster, ensuring that the message is consumed by each subscriber in the cluster at least once.

• 

  Diversified Types of Messages

  Common message is used for asynchronous business decoupling between systems, load shifting, logging, large-scale cache synchronization between hosts, and real-time computing and analysis.

  
  

  Ordered messages are both published and consumed in order, and divided into globally and partitionally ordered messages.

  
  

  ApsaraMQ for RocketMQ provides a distributed transaction function known as X/Open XA to ensure transaction consistency.

  
  

  After a message is sent to the Message Queue server, the Message Queue server sends the message at the specified time point (for example, at 15:00:00 on January 1, 2016) after the message sending time (the current time).

  
  

  After a message is sent to the Message Queue server, the Message Queue server sends the message at the specified delay time point (for example, 30 minutes later) after the message sending time (the current time).

• 

  Systematic Maintenance Tools

  ApsaraMQ for RocketMQ provides a comprehensive set of maintenance tools to help you quickly detect and process system problems.

  
  

  Query messages by topic, message ID or message key on the Message Queue server.

  
  

  ApsaraMQ for RocketMQ records complete data about the entire process including the message flow from the creator to the Message Queue server and then to the end-user, aggregates and analyzes the data, and constructs a visual full-link message track.

  
  

  ApsaraMQ for RocketMQ can play back consumed messages at the specified time and thereby acts as a powerful troubleshooting tool.

  
  

  You can set monitoring and alert rules for each customer ID based on the consumption delay time and stack quantity of messages, so as to detect timely problems.

  
  

  ApsaraMQ for RocketMQ provides a complete set of standard HTTP RESTful Open APIs of control type, which can implement a series of resource management and maintenance functions, as well as facilitate access.