RocketMQ消费重试

消费重试 | RocketMQ

消费者出现异常，消费某条消息失败时， Apache RocketMQ 会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试机制的原理、版本兼容性和使用建议。

https://rocketmq.apache.org/zh/docs/featureBehavior/10consumerretrypolicy

重试状态机

• Ready：已就绪状态。消息在Apache RocketMQ服务端已就绪，可以被消费者消费。

• Inflight：处理中状态。消息被消费者客户端获取，处于消费中还未返回消费结果的状态。

• WaitingRetry：待重试状态，PushConsumer独有的状态。当消费者消息处理失败或消费超时，会触发消费重试逻辑判断。如果当前重试次数未达到最大次数，则该消息变为待重试状态，经过重试间隔后，消息将重新变为已就绪状态可被重新消费。多次重试之间，可通过重试间隔进行延长，防止无效高频的失败。

• Commit：提交状态。消费成功的状态，消费者返回成功响应即可结束消息的状态机。

• DLQ：死信状态。消费逻辑的最终兜底机制，若消息一直处理失败并不断进行重试，直到超过最大重试次数还未成功，此时消息不会再重试，会被投递至死信队列。您可以通过消费死信队列的消息进行业务恢复。

重试间隔