rocketMQ消费端设置重试次数java

RocketMQ的消费端重试次数可以通过设置MessageListenerConcurrently或MessageListenerOrderly的consumeConcurrentlyMaxRetry和consumeOrderlyMaxRetry属性来实现。

例如，使用MessageListenerConcurrently：

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group");
consumer.subscribe("topic", "*");

consumer.registerMessageListener((List<MessageExt> msgs, ConsumeConcurrentlyContext context) -> {
    int maxRetry = 3; // 最大重试次数
    for (MessageExt msg : msgs) {
        try {
            // 处理消息
            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
        } catch (Exception e) {
            int retryTimes = msg.getReconsumeTimes();
            if (retryTimes >= maxRetry) {
                // 重试次数已达上限，不再重试，记录日志或发送告警等
                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
            }
            // 稍后重新消费，重试次数+1
            return ConsumeConcurrentlyStatus.RECONSUME_LATER;
        }
    }
    return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
});

consumer.start();

使用MessageListenerOrderly同理，只需将consumeConcurrentlyMaxRetry改为consumeOrderlyMaxRetry即可。注意，如果使用顺序消费模式，需要保证同一队列中的消息按顺序消费，因此重试时需要将消息重新放回队列的头部，而不是末尾。