RocketMQ的重试机制

RocketMQ的重试机制是指:当消费者消费消息失败时,RocketMQ会在一定时间后重新将消息发送给消费者进行消费,以确保消息的可靠消费。

RocketMQ的重试机制主要体现在:

1.自动重试:Consumer在消费失败后,会在一定重试策略下定期重试消费失败的消息,直到成功或达到最大重试次数。

2.消息重发:如果Consumer在最大重试次数内仍然消费失败,Broker会定期扫描被标记为消费失败的消息,并将其重发给其他Consumer。

3.灵活的重试策略:RocketMQ提供多种重试策略来控制重试时机和频率,主要有:

• 固定时间间隔重试:每次重试之间固定睡眠一段时间。
• 递增时间间隔重试:每次重试之间的睡眠时间逐渐增加,可以避免消息积压。
• 随机时间间隔重试:每次重试之间的睡眠时间随机,可以提高重试效率。
• 重试次数达到阈值重试:到达阈值重试次数时重试,且后续重试次数按照一定策略递增。
  举例:

自动重试

// 设置Consumer自动重试,最大10次,重试策略为固定间隔
consumer.setRetryTimesWhenSendFailed(10);
consumer.setRetryAnotherBrokerWhenNotStoreOK(false);
1
2
3

递增时间间隔重试策略:

// 重试策略,初试1s,最大重试时间为2min,重试10次
public NoRetryStrategy implements IRetryStrategy {
    @Override
    public long computeNextRetryInterval(int times) {
        if (times < 0)
            return -1;
        int pow = times > 5 ? 5 : times;
        return (long)Math.pow(2, pow) * 1000; 
    } 
}
consumer.setRetryStrategy(new NoRetryStrategy());  
1
2
3
4
5
6
7
8
9
10
11