【天翼云】分布式消息服务

分布式消息服务是一项基于分布式集群技术的消息中间件服务，具有高可靠、高并发、低时延、海量消息堆积的能力特点，提供了有效的安全防护、完善的监控与审计、报警机制，为分布式应用系统提供灵活可靠的异步通信机制。

产品按队列占用时间和API调用次数收费。

产品优势
性能 | 支持堆积与高并发
支持亿级消息堆积，在海量堆积下不影响队列性能，单队列最高至10万TPS，并可通过队列数扩展提升整系统并发能力。

灵活 | 灵活及时
队列处理能力按需自动扩展，及时方便完成系统扩展，消息投递时间可至毫秒级，保证消息及时性。

可靠 | 高可靠
支持数据同步落盘与多副本冗余，数据可靠性高达 99.99999999%，采用集群化部署，保障服务可用性高达99.95%。

集成 | 集成方便
支持多种队列类型（普通、有序、Kafka）以及多协议（HTTP RESTful、TCP、Kafka）接入，轻松完成与其他系统的集成。

产品功能
访问接口

基于HTTPS请求的API
通过API调用使用DMS，创建队列、生产消息、消费消息。

管理控制台方式
管理控制台上进行的操作常用于测试目的，也可用于队列创建、查看等管理工作。

队列能力

多协议接入
支持HTTP Restful API、TCP SDK、Kafka SDK接入。

队列类型
支持普通队列（高并发场景）、FIFO有序队列（顺序信息场景）、Kafka队列（兼容开源）。

死信队列
将其无法成功处理的消息存放于死信队列，便于统一分析和处理。

队列共享和授权
支持租户间或租户内针对不同用户的队列共享和授权。

至少一次
提供“至少一次”的消息交付功能。

消息能力

消息过滤
根据消息标签对可消费的消息进行过滤。

消息复用
通过指定时间或位置，将一次消息被多种消费场景同时消费，进行多次复用。

定时/延时消息
在消息生产时间（当前时间）之后的指定时间点（72小时内）投递给消费组。

广播消息
在同一个消费组内对所有消费者投递相同消息。

消息重投
消费者可以决定将暂不消费的消息重新投递到队列中，延后消费。

安全防护

可追溯
提供云审计进行租户管理操作的记录和审计。

实时监控
提供队列消息数，消息大小，消息请求数的实时监控；支持用户自定义告警规则。

Token认证
使用API接口进行消息发送与消费，需Token认证。

消息加密
数据加密存储，防止消息被窃取。

应用场景

分布式系统异步通信

适用场景
在单体应用中，各服务耦合度紧，单个服务出现问题会导致系统对用户请求响应慢，可以进行系统解耦拆分，并用消息队列作为系统间的异步通信通道，提升整个系统的响应速度。

实现功能
加快系统响应
系统分布式解耦，并行处理，加快系统对用户请求的响应速度。

降低系统耦合
系统间通过消息队列通信，避免相互耦合和影响。

数据缓存
消息队列提供亿级消息堆积能力，帮助系统在峰值情况下从容应对。

数据同步和交换

适用场景
在大中型分布式系统中，各个子系统数据需最终保持一致，需要有可靠消息传递，能保证业务的连续性。分布式消息队列可用于子系统间的高可靠数据传递，实现两者之间数据同步和交换，降低实现难度和成本，并提供数据通道帮助触发其他的业务流程。

实现功能
丰富消息类型
广播消息、延时消息、消息重投等使得应用可灵活控制数据同步时间。

低时延
消息投递时间可至毫秒级，保证消息及时性。

高并发
单队列最高至10万TPS，并可通过队列数扩展提升整系统并发能力。

削峰填谷

适用场景
在电子商务系统或大型网站中，系统上下游处理能力存在差异，当处理能力高的系统上游突发请求超过系统下游处理能力时，系统对外呈现的服务能力为 0。此时可以通过队列服务堆积请求消息，对请求消息实现削峰填谷，错峰处理，避免下游因突发流量崩溃。

实现功能
海量消息堆积能力
确保下游业务在安全水位内平滑稳定的运行，避免超高流量的冲击；
通过削弱填谷可控制下游业务系统的集群规模。
确保系统可用性同时，因快速有效的请求响应而提升用户的体验。