順序消息的消費(fèi)重試
對(duì)于順序消息妆艘，當(dāng)Consumer消費(fèi)信息失敗后，為了保證消息的順序性看幼，其會(huì)自動(dòng)不斷地進(jìn)行消息重試批旺，知道消費(fèi)成功。消費(fèi)重試默認(rèn)間隔時(shí)間為1000毫秒诵姜。重試期間應(yīng)用會(huì)出現(xiàn)消息消費(fèi)被阻塞的情況汽煮。
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("cg");
// 順序消息消費(fèi)失敗的消費(fèi)重試時(shí)間間隔，單位毫秒棚唆，默認(rèn)為1000暇赤，其取值范圍為[10, 30000]
consumer.setSuspendCurrentQueueTimeMillis(100);
由于對(duì)順序消息的重試是無休止的，不間斷的宵凌，直至消費(fèi)成功鞋囊，所以，對(duì)于順序消息的消費(fèi)瞎惫，務(wù)必要保證應(yīng)用能夠及時(shí)監(jiān)控并處理消費(fèi)失敗的情況溜腐，避免消費(fèi)被永久性阻塞
注意：順序消息沒有發(fā)送失敗重試機(jī)制，但具有消費(fèi)失敗重試機(jī)制
無序消息的消費(fèi)重試
對(duì)于無序消息（普通消息瓜喇、延時(shí)消息挺益、事務(wù)消息），當(dāng)Consumer消費(fèi)消息失敗時(shí)乘寒，可以通過設(shè)置返回狀態(tài)達(dá)到消息重試的效果望众。不過需要注意，無序消息的重試只對(duì)集群消費(fèi)方式生效，廣播消費(fèi)方式不提供失敗重試機(jī)制黍檩。即對(duì)于廣播消費(fèi)叉袍，消費(fèi)失敗后，失敗消息不再重試刽酱，繼續(xù)消費(fèi)后續(xù)消息
消費(fèi)重試次數(shù)與間隔
對(duì)于無序消息集群消費(fèi)下的重試消費(fèi)喳逛，每條消息默認(rèn)最多重試16次，但每次重試的間隔時(shí)間時(shí)不同的棵里，會(huì)逐漸編程润文。每次重試的間隔時(shí)間如下：
若一條消息在一直消費(fèi)失敗的前提下，將會(huì)在正常消費(fèi)后的第4小時(shí)46分后進(jìn)行第16次重試殿怜。若仍然失敗典蝌，則將消息投遞到死信隊(duì)列
修改消費(fèi)重試次數(shù)
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("cg");
// 修改消費(fèi)重試次數(shù)
consumer.setMaxReconsumeTimes(10);對(duì)于修改過的重試次數(shù)，將按照一下策略執(zhí)行
- 若修改值小于16头谜，則按照指定間隔進(jìn)行充實(shí)
- 若修改值大于16骏掀，則超過16次的重試時(shí)間間隔均為2小時(shí)
對(duì)于Consumer Group，若僅修改了一個(gè)Consumer的消費(fèi)重試次數(shù)柱告，則會(huì)應(yīng)用到該Group中所有其他Consumer實(shí)例截驮。若出現(xiàn)多個(gè)Consumer均做了修改的情況，則采用覆蓋方式生效际度。即最后被修改的值會(huì)覆蓋前面設(shè)置的值
重試隊(duì)列
對(duì)于需要重試消費(fèi)的消息葵袭，并不是Consumer在等待了指定時(shí)長(zhǎng)后再去拉取原來的消息進(jìn)行消費(fèi)，而是將這些需要重試消費(fèi)的消息放入了一個(gè)特殊的Topic隊(duì)列中乖菱，而后進(jìn)行再次消費(fèi)坡锡。這個(gè)特殊的隊(duì)列就是重試隊(duì)列
當(dāng)出現(xiàn)需要進(jìn)行重試消費(fèi)的消息時(shí)，Broker會(huì)為每個(gè)消費(fèi)組都設(shè)置一個(gè)Topic名稱為%RETRY%consumerGroup@consumerGroup的重試隊(duì)列
1窒所、 這個(gè)重試隊(duì)列時(shí)針對(duì)消息才組的鹉勒，而不是針對(duì)每個(gè)Topic設(shè)置的（一個(gè)Topic的消息可以讓多個(gè)消費(fèi)者組進(jìn)行消費(fèi)，所以會(huì)為這些消費(fèi)者組各創(chuàng)建一個(gè)重試隊(duì)列）
2吵取、 只有當(dāng)出現(xiàn)需要進(jìn)行重試消費(fèi)的消息時(shí)禽额，才會(huì)為該消費(fèi)者組創(chuàng)建重試隊(duì)列
注意：消費(fèi)重試的時(shí)間間隔與延時(shí)消費(fèi)的延時(shí)等級(jí)十分相似，除了沒有延時(shí)等級(jí)的前兩個(gè)時(shí)間外海渊，其他的時(shí)間都是相同的
Broker對(duì)于重試消息的處理是通過延時(shí)消息實(shí)現(xiàn)的。先將消息保存到SCHEDULE_TOPIC_XXXX延遲隊(duì)列中哲鸳，延遲時(shí)間到后臣疑，會(huì)將消息投遞到%RETRY%consumerGroup@consumerGroup重試隊(duì)列中
消費(fèi)重試配置方式
集群消費(fèi)方式下，消息消費(fèi)失敗后若希望消費(fèi)重試徙菠，則需要在消息監(jiān)聽器接口中實(shí)現(xiàn)明確進(jìn)行如下三種方式之一的配置
- 返回ConsumeConcurrentlyStatus.RECONSUME_LATER（推薦）
- 返回null
- 拋出異常
消費(fèi)不重試配置方式
集群消費(fèi)方式下讯沈，消息消費(fèi)失敗后若不希望消費(fèi)重試，則在捕獲到異常后同樣也返回與消費(fèi)成功后的相同結(jié)果，即ConsumeConcurrentlyStatus.RECONSUME_SUCCESS缺狠，則不進(jìn)行消費(fèi)重試
