功能特性

SOFAStack 消息队列在阿里云多个地域(Region)提供了高可用消息云服务。单个地域内采用多机房部署,可用性极高,即使整个机房都不可用,仍然可以为应用提供消息发布服务。

消息队列提供 TCP 协议语言接入方式,方便应用快速接入消息队列消息云服务。在网络联通的情况下,您可以将应用部署在阿里云 ECS、企业自建云,与消息队列建立连接进行消息收发。

功能特性

TCP 协议接入

提供更为专业、可靠、稳定的 TCP 协议的 SDK 接入服务。支持 Java 语言。

管理工具

  • Web 控制台:支持 Topic 管理、Group 管理、消息查询、消息轨迹展示和查询。

  • OpenAPI:提供开放的 API 便于将消息队列管理工具集成到自己的控制台。

消息类型

  • 普通消息:消息队列中无特性的消息,区别于有特性的定时/延时消息、顺序消息和事务消息。

  • 事务消息:实现类似 X/Open XA 的分布事务功能,以达到事务最终一致性状态。

  • 定时和延时消息:允许消息生产者对指定消息进行定时(延时)投递。

  • 顺序消息:允许消息消费者按照消息发送的顺序对消息进行消费。

有关消息类型的详细信息,参见 消息类型

特性功能

  • 消息查询:消息队列提供了三种消息查询的方式,分别是按 Message ID、Message Key 以及 Topic 查询。

  • 查询消息轨迹:通过消息轨迹,能清晰定位消息从生产者发出,经由消息队列服务端,投递给消息消费者的完整链路,方便定位排查问题。

  • 集群消费和广播消费:当使用集群消费模式时,消息队列认为任意一条消息只需要被消费者集群内的任意一个消费者处理即可;当使用广播消费模式时,消息队列会将每条消息推送给消费者集群内所有注册过的消费者,保证消息至少被每台机器消费一次。

  • 重置消费位点:根据时间或位点重置消费进度,允许用户进行消息回溯或者丢弃堆积消息。