文档首页> 分布式消息服务RocketMQ版> 产品介绍> 什么是分布式消息服务RocketMQ版
更新时间:2021/09/16 GMT+08:00
分享

什么是分布式消息服务RocketMQ版

分布式消息服务RocketMQ版是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。

分布式消息服务RocketMQ版具体如下特点:

  • 兼容开源RocketMQ客户端。
  • 提供顺序、延迟、定时、重投、死信、事务消息、会话消息等功能,更好的适配电商、金融等多样的业务场景。
  • 提供消息追踪、消息溯源、链路诊断、死信导出、监控告警等能力,帮助您全方面的了解服务状况,保证业务正常运行。

支持的消息类型

分布式消息服务RocketMQ版支持4种消息类型。

  • 普通消息:没有特殊功能的消息,区别于延迟消息、顺序消息和事务消息。
  • 延迟消息:生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到特定时间后才会发送给消费者进行消费。
  • 顺序消息:消费者按照消息发送的顺序来消费消息。
  • 事务消息:提供类似X/Open XA的分布事务功能,通过事务消息能达到分布式事务的最终一致。

支持的高级特性

分布式消息服务RocketMQ版支持2种高级特性。

  • 消息过滤:消费者根据分布式消息服务RocketMQ版设置的标签对已订阅Topic中的消息进行过滤,达到只消费需要的消息的目的。
  • 消息重试:消费者消费某条消息失败后,分布式消息服务RocketMQ版根据重试机制将消息重新发送给消费者进行消费。如果重试次数到达设定的最大值时,消息尚未被成功消费,此消息将被发送到死信队列。

    分布式消息服务RocketMQ版的重试机制如表1所示。

    表1 消息重试机制

    消息类型

    重试时间间隔

    最大重试次数

    顺序消息

    通过“suspendTimeMillis”设置重试时间间隔。

    默认值为1000ms,即1s。

    创建消费组时设置。

    取值范围:1-16。

    普通消息/延迟消息/事务消息

    重试时间间隔根据重试次数阶梯变化,如表2所示。

    创建消费组时设置。

    取值范围:1-16。

    表2 普通消息/延迟消息/事务消息重试时间间隔

    重试次数

    与上次的间隔时间

    重试次数

    与上次的间隔时间

    1

    10s

    9

    7min

    2

    30s

    10

    8min

    3

    1min

    11

    9min

    4

    2min

    12

    10min

    5

    3min

    13

    20min

    6

    4min

    14

    30min

    7

    5min

    15

    1h

    8

    6min

    16

    2h

分享:

    相关文档

    相关产品