在上一篇文章中，我們對MQ中的消息丟失有了一定的了解，相信再次被面試官問到時心里也就有了底氣了。

文章的地址我放在下面，還沒有看的可以跳過去看一下。

面試官：對于MQ中的消息丟失你是如何理解的？

我們經(jīng)常說的消息堆積通俗點講就是消費者消費不了了，造成消息在MQ中堆著，然后越來越多，所以說消息堆積是在消費者階段的問題。

那么發(fā)生消息堆積的原因有哪些呢？

一、消息堆積的原因

1. 消費者掛掉。
2. 消費者與 MQ 之間網(wǎng)絡(luò)斷開。
3. 消費者代碼 BUG ，重復(fù)消費一條消息。
4. 消息路由 key 錯誤，造成個別分區(qū)消息堆積。
5. 消費者性能原因，例如業(yè)務(wù)邏輯單表數(shù)據(jù)量過大造成消費時間緩慢。

除了上述的5個原因外，如果在工作中你還遇到過其他造成消息堆積的原因，也歡迎你在評論區(qū)進行交流，一起進步。

當(dāng)發(fā)生了消息堆積時，優(yōu)先是解決消息堆積問題，然后是排查問題制定解決方案。畢竟保證系統(tǒng)的可用性是首先要解決的問題?？焖俳鉀Q積壓的方法就是通過水平擴容增加消費者的實例數(shù)量。

消息堆積的原因我們知道了，下面我就分享一下在工作中經(jīng)常用的解決消息堆積的幾種方式。

二、怎么解決消息堆積問題

1. 限制生產(chǎn)者消息生產(chǎn)速度。
2. 增加消費者數(shù)量，水平擴容。
3. 排查消費者代碼邏輯，保證沒有一直循環(huán)消費一條消息。
4. 優(yōu)化消費者消費邏輯，減少復(fù)雜計算邏輯。使用異步、多線程等手段提升消費速度。
5. 定期清理過期消息。

對于第二條增加消費者數(shù)量需要注意的是，消息的路由key，分區(qū)等概念。如果配置不正確，新增加的消費者并不會幫忙消費堆積的消息，相反只會對新增的消息進行消費。

三、總結(jié)

消息堆積發(fā)生的原因一般就是消費者出了問題，或者被一個異常一直錯誤的重試。那么解決方式也就是我們上面所說的，水平擴容消費者、消費者處理速度優(yōu)化、消費者異常重試等。

不過相對應(yīng)的，消息的重試也就會發(fā)生一條消息執(zhí)行多次的情況，那么你的接口做冪等了嗎，下一篇文章，我們就來看下MQ中的消息重復(fù)，如何處理消費過程中的重復(fù)消息。