可能原因

消息堆積一般是由于消費(fèi)者的消費(fèi)能力受限或者配置不合理導(dǎo)致的。在堆積出現(xiàn)時(shí)，可能是由如下原因?qū)е碌模?/p>

• 消費(fèi)能力不足。這種情況一般出現(xiàn)在發(fā)送量較大，而消費(fèi)者消費(fèi)耗時(shí)較長的時(shí)候。在該情況下，消費(fèi)者的消費(fèi)速率跟不上發(fā)送速率，則隊(duì)列中便會(huì)出現(xiàn)消息堆積。

• 突發(fā)流量。突然的發(fā)送流量會(huì)導(dǎo)致隊(duì)列中產(chǎn)生堆積。如果消費(fèi)者能力足夠，這種堆積往往能夠慢慢消解。

• QoS/Prefetch參數(shù)設(shè)置不合理。這種情況不一定是消費(fèi)者能力不足，通過擴(kuò)容消費(fèi)者不一定能夠解決。例如一個(gè)消費(fèi)者的Prefetch Count參數(shù)為100條，每條消息需要30秒，則處理完這一批消息需要3000秒，而最長消費(fèi)時(shí)間只有300秒，這樣每個(gè)消費(fèi)者只有前10條消息能夠被正常消費(fèi)，后續(xù)所有消息都將消費(fèi)失敗，消息將出現(xiàn)堆積。

解決辦法

1. 通過如下方法確認(rèn)消費(fèi)者是否連接，并正常工作。

   1. 開啟消息日志服務(wù)，查看堆積隊(duì)列的PushMessage事件量是否符合預(yù)期。具體操作，請參見配置消息日志。

   2. 控制臺(tái)進(jìn)入堆積隊(duì)列的界面，查看消費(fèi)者IP數(shù)量是否符合預(yù)期。

      

   3. 進(jìn)入堆積隊(duì)列的Dashboard，查看各個(gè)消費(fèi)者的消費(fèi)時(shí)長是否符合預(yù)期。

      

      如上圖所示，各個(gè)消費(fèi)者的消費(fèi)時(shí)長是符合預(yù)期的，但是如果出現(xiàn)下面這種情況，則代表該消費(fèi)的所有消息消費(fèi)均超時(shí)。

      

2. 針對(duì)QoS/Prefetch等參數(shù)設(shè)置，請參見消費(fèi)消息時(shí)需要注意什么？。

   此外，可以根據(jù)該公式計(jì)算最佳QoS值：QoS = 最長消費(fèi)時(shí)長/單條消息的最長處理時(shí)長。

3. 可以觀察消費(fèi)進(jìn)程負(fù)載情況，并嘗試擴(kuò)容消費(fèi)者，一般情況下，堆積能夠通過擴(kuò)容消費(fèi)者緩解。