RocketMQ_高级特性之消息重试_1-【官方】百战程序员_IT在线教育培训机构

由于消息本身的原因，例如反序列化失败，消息数据本身无法处理（例如话费充值，当前消息的手机号被注销，无法充值）等。这种错误通常需要跳过这条消息，再消费其它消息，而这条失败的消息即使立刻重试消费，99%也不成功，所以最好提供一种定时重试机制，即过10秒后再重试。
由于依赖的下游应用服务不可用，例如db连接不可用，外系统网络不可达等。遇到这种错误，即使跳过当前失败的消息，消费其他消息同样也会报错。这种情况建议应用sleep 30s，再消费下一条消息，这样可以减轻Broker重试消息的压力。

消息队列RocketMQ消息收发过程中，若Consumer消费某条消息失败，则消息队列RocketMQ会在重试间隔时间后，将消息重新投递给Consumer消费，若达到最大重试次数后消息还没有成功被消费，则消息将被投递至死信队列。

重试间隔：消息消费失败后再次被消息队列RocketMQ投递给Consumer消费的间隔时间。

最大重试次数：消息消费失败后，可被消息队列RocketMQ重复投递的最大次数。

在RocketMQ中，顺序消息和无序消息（包括普通消息、延时消息、定时消息和事务消息）的重试机制如下：

协议	消息类型	重试间隔	最大重试次数	配置方式
TCP协议	顺序消息	间隔时间可通过自定义参数suspendTimeMillis取值进行配置。参数取值范围：10～30000，单位：毫秒，默认值：1000毫秒，即1秒。	最大重试次数可通过自定义参数MaxReconsumeTimes取值进行配置。该参数取值无最大限制。若未设置参数值，默认最大重试次数为Integer.MAX。	请参见配置方式（TCP协议）。
TCP协议	无序消息	间隔时间根据重试次数阶梯变化，取值范围：1秒～2小时。不支持自定义配置。若最大重试次数小于等于16次，则每次重试的间隔时间会阶梯变化，具体时间，请参见无序消息重试间隔。若最大重试次数大于16次，则超过16次的间隔时间均为2小时。	最大重试次数可通过自定义参数MaxReconsumeTimes取值进行配置。默认值为16次，该参数取值无最大限制，建议使用默认值。
HTTP协议	顺序消息	1分钟	288次	系统预设，不支持修改。
HTTP协议	无序消息	5分钟	288次	系统预设，不支持修改。

TCP协议无序消息重试时间间隔：

第几次重试	与上次重试的间隔时间	第几次重试	与上次重试的间隔时间
1	10秒	9	7分钟
2	30秒	10	8分钟
3	1分钟	11	9分钟
4	2分钟	12	10分钟
5	3分钟	13	20分钟
6	4分钟	14	30分钟
7	5分钟	15	1小时
8	6分钟	16	2小时

实时效果反馈

1.下列不属于消息重试的配置方式是哪个？

A CONSUME_SUCCESS

B RECONSUME_LATER

C null

D throw new Exception("Consumer Message exceotion")

答案

1=>A

北京市昌平区回龙观镇南店村综合商业楼2楼226室