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

消息队列RocketMQ 是一款高吞吐量、高可扩展性的分布式消息服务。在开源RocketMQ基础上进行优化，具有高可靠、低时延、海量堆积能力，提供监控运维功能。用于系统间解耦，用户只需专注业务，无需部署运维，低成本、更弹性和可靠。

产品优势
堆积并发
支持亿级消息堆积，在海量堆积下队列性能影响很小，并可通过队列数扩展提升整系统并发能力

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

高可靠
集群节点采用主备模式，且具有主备故障自动切换功能；提供对消息的持久化能力，多副本冗余；提供消息数据自动删除功能

运维管理
提供多维度指标监控（队列级别）；消息查询;消息回溯；消息数据过期自动删除

产品功能
访问接口
支持通过API调用，创建队列、查询消息监控指标、查询消息内容等。
管理控制台上进行的操作用于主题的创建、查看、运维监控等管理工作。

队列能力
队列类型
支持普通队列（高并发场景）、FIFO有序队列（顺序信息场景）、严格有序队列。

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

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

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

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

消息重试
消费者可以决定将暂不消费的消息重新投递到队列中，延迟消费，最大支持16个延时级别

事务消息
支持事务消息，可用于分布式应用

消息回溯
支持根据时间重置消费进度

消息数据自动删除功能
在磁盘满后，在保护期外的数据，能自动删除，保证服务可用性

自动主备切换功能
集群节点采用主备模式，且具有主备故障自动切换功能，自动主备切换保证服务高可用

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

运维监控
提供主题、订阅组、生产者、消费者、队列的管理；集群、主题、队列多维度指标监控

应用场景

分布式系统异步通信

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

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

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

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

数据同步和交换

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

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

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

高并发
可通过队列数扩展提升整系统并发能力。

削峰填谷

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

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