consumer端重試

消費者端的失敗，分為2種情況，一個是exception，一個是timeout。

exception

消息正常的到了消費者，結果消費者發生異常，處理失敗了。例如反序列化失敗，消息數據本身無法處理（例如話費充值，當前消息的手機號被注銷，無法充值）等。

消息的狀態：

// // Source code recreated from a .class file by IntelliJ IDEA // (powered by Fernflower decompiler) //package org.apache.rocketmq.client.consumer.listener;public enum ConsumeConcurrentlyStatus {CONSUME_SUCCESS,RECONSUME_LATER;private ConsumeConcurrentlyStatus() {} }

可以看到，消息的狀態分為成功或者失敗。如果返回的狀態為失敗會怎么樣呢？

在啟動broker的日志中可以看到這樣的信息：

INFO main - messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h

這個表示了，如果消息消費失敗，那么消息將會在1s、5s、10s后重試，一直到2h后不再重試。

其實，有些時候并不需要重試這么多次，一般重試3~5次即可。這個時候就可以通過msg.getReconsumeTimes()獲取重試次數進行控制。

package cn.learn.rocketmq.error;import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext; import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus; import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently; import org.apache.rocketmq.common.message.MessageExt;import java.io.UnsupportedEncodingException; import java.util.List;public class ConsumerDemo {public static void main(String[] args) throws Exception {DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("LEARN_IM");consumer.setNamesrvAddr("localhost:9876");// 訂閱topic，接收此Topic下的所有消息consumer.subscribe("my-test-topic", "*");consumer.registerMessageListener(new MessageListenerConcurrently() {@Overridepublic ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,ConsumeConcurrentlyContext context) {for (MessageExt msg : msgs) {try {System.out.println(new String(msg.getBody(), "UTF-8"));} catch (UnsupportedEncodingException e) {e.printStackTrace();}}System.out.println("收到消息->" + msgs);if(msgs.get(0).getReconsumeTimes() >= 3){// 重試3次后，不再進行重試return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;}return ConsumeConcurrentlyStatus.RECONSUME_LATER;}});consumer.start();}}

?

總結

以上是生活随笔為你收集整理的RocketMQ错误消息重试策略之Consumer的重试机制（Exception情况）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。