分布式消息服务ROCKETMQ版-什么是分布式消息服务RocketMQ版:支持的高级特性

时间：2024-07-31 17:20:54

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

消息重试：消费者消费某条消息失败后，分布式消息服务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所示。

定时消息：生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。分布式消息服务RocketMQ版支持任意时间的定时消息，最大推迟时间可达到1年。同时也支持定时消息的取消。

2022年3月30日及以后购买的实例支持定时消息功能，在此之前购买的实例不支持此功能。