分布式消息服务RocketMQ是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。
分布式消息服务RocketMQ具有如下特点：
- 兼容开源RocketMQ客户端。
- 提供顺序、延迟、定时、重投、死信、事务消息等功能，更好的适配电商、金融等多样的业务场景。
- 提供消息追踪、消息溯源、链路诊断、死信导出、监控告警等能力，帮助您全方面的了解服务状况，保证业务正常运行。
产品架构
图1 产品架构示意图
示意图说明：
- Broker：负责接收和存储Producer发送的消息，或者转发消息到Consumer。一个Broker由一个主节点和两个备节点组成。
- NameServer：负责接收和存储Broker中的元数据。
- Producer：从NameServer获取元数据，然后将消息发送到Broker。
- Consumer：从NameServer获取元数据，然后从Broker拉取消息。
支持的消息类型
分布式消息服务RocketMQ支持4种消息类型。
- 普通消息：没有特殊功能的消息，区别于延迟消息、顺序消息和事务消息。
- 延迟消息/定时消息：生产者生产消息到分布式消息服务RocketMQ后，消息不会立即被消费，而是延迟到特定时间后才会发送给消费者进行消费。
- 顺序消息：消费者按照消息发送的顺序来消费消息。
- 事务消息：提供类似X/Open XA的分布事务功能，通过事务消息能达到分布式事务的最终一致。
支持的高级特性
分布式消息服务RocketMQ支持4种高级特性。
- 消息过滤：消费者根据分布式消息服务RocketMQ设置的标签对已订阅Topic中的消息进行过滤，达到只消费需要的消息的目的。
- 消息重试：消费者消费某条消息失败后，分布式消息服务RocketMQ根据重试机制将消息重新发送给消费者进行消费。如果重试次数到达设定的最大值时，消息尚未被成功消费，此消息将被发送到死信队列。
分布式消息服务RocketMQ的重试机制如表1所示。
表1 消息重试机制
消费类型 重试时间间隔 最大重试次数 顺序消费 通过suspendTimeMillis设置重试时间间隔。
默认值为1000ms，即1s。
通过消费者的setMaxReconsumeTimes函数配置最大重试次数。若未设置参数值，默认为无限重试。 普通消费 重试时间间隔根据重试次数阶梯变化，如表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
- 延时消息：生产者生产消息到分布式消息服务RocketMQ后，消息不会立即被消费，而是延迟固定时间后才会发送给消费者进行消费。生产者可以指定18个延时等级，每个延时等级对应的时间如表3所示。
表3 延时等级
延时等级 延时时间 延时等级 延时时间 1 1s 10 6min 2 5s 11 7min 3 10s 12 8min 4 30s 13 9min 5 1min 14 10min 6 2min 15 20min 7 3min 16 30min 8 4min 17 1h 9 5min 18 2h
- 定时消息：生产者生产消息到分布式消息服务RocketMQ后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。分布式消息服务RocketMQ支持任意时间的定时消息，最大推迟时间可达到1年。同时也支持定时消息的取消。
