一般情況下我們在實際生產中是不需要重試16次，這樣既浪費時間又浪費性能，理論上當嘗試重復次數達到我們想要的結果時如果還是消費失敗，那么我們需要將對應的消息進行記錄，并且結束重復嘗試

consumer.registerMessageListener((MessageListenerConcurrently) (list,? consumeOrderlyContext) -> {?for (MessageExt messageExt : list) {?if(messageExt.getReconsumeTimes()==3) {?//可以將對應的數據保存到數據庫，以便人工干預?System.out.println(messageExt.getMsgId()+","+messageExt.getBody());?return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;?}?}?return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;? });

?

總結

以上是生活随笔為你收集整理的重试消息的处理机制的全部內容，希望文章能夠幫你解決所遇到的問題。

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