SOFAStack Message Queue is a highly available cloud messaging service offered in multiple Alibaba Cloud regions. It is deployed across multiple data centers in each region to ensure high availability. This allows your applications to publish messages even if an entire data center is unavailable.
Message Queue supports connections over the TCP protocol, allowing applications to connect to the service quickly. You can deploy applications on Alibaba Cloud ECS or in a self-managed cloud. Your applications can connect to Message Queue to send and receive messages over any available network connection.
TCP protocol connection
Connect to the service using a reliable and stable software development kit (SDK) based on the TCP protocol. A Java SDK is provided.
Management tools
Web console: Manage topics and groups, query messages, and view message traces.
OpenAPI: Use the OpenAPI to integrate Message Queue management features into your own console.
Message types
Normal messages: Standard messages that do not have special attributes, such as scheduled and delayed messages, ordered messages, or transactional messages.
Transactional messages: Provide eventual consistency for transactions. This feature is similar to the distributed transaction capability of X/Open XA.
Scheduled and delayed messages: Allow producers to deliver messages at a specific time in the future or after a specified delay.
Ordered messages: Ensure that consumers process messages in the same order that the messages were sent.
For more information about message types, see Message types.
Specific features
Message query: Query messages by Message ID, Message Key, or Topic.
Query message trace: A message trace displays the complete path of a message from the producer, through the Message Queue server, to the consumer. This helps you easily locate and troubleshoot problems.
Clustering and broadcasting consumption: In the clustering consumption pattern, each message is processed by only one consumer in a consumer group. In the broadcasting consumption pattern, Message Queue pushes each message to all registered consumers in the group, which ensures that each consumer processes the message at least once.
Reset consumer offset: Allows you to reset the consumption progress based on a specific time or an offset. This feature enables you to reprocess messages or discard stacked messages.