在上一篇文章中，我們對(duì)MQ中的消息丟失有了一定的了解，相信再次被面試官問(wèn)到時(shí)心里也就有了底氣了。emx28資訊網(wǎng)——每日最新資訊28at.com

文章的地址我放在下面，還沒(méi)有看的可以跳過(guò)去看一下。emx28資訊網(wǎng)——每日最新資訊28at.com

面試官：對(duì)于MQ中的消息丟失你是如何理解的？emx28資訊網(wǎng)——每日最新資訊28at.com

我們經(jīng)常說(shuō)的消息堆積通俗點(diǎn)講就是消費(fèi)者消費(fèi)不了了，造成消息在MQ中堆著，然后越來(lái)越多，所以說(shuō)消息堆積是在消費(fèi)者階段的問(wèn)題。emx28資訊網(wǎng)——每日最新資訊28at.com

那么發(fā)生消息堆積的原因有哪些呢？emx28資訊網(wǎng)——每日最新資訊28at.com

emx28資訊網(wǎng)——每日最新資訊28at.com

一、消息堆積的原因

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

除了上述的5個(gè)原因外，如果在工作中你還遇到過(guò)其他造成消息堆積的原因，也歡迎你在評(píng)論區(qū)進(jìn)行交流，一起進(jìn)步。emx28資訊網(wǎng)——每日最新資訊28at.com

當(dāng)發(fā)生了消息堆積時(shí)，優(yōu)先是解決消息堆積問(wèn)題，然后是排查問(wèn)題制定解決方案。畢竟保證系統(tǒng)的可用性是首先要解決的問(wèn)題。快速解決積壓的方法就是通過(guò)水平擴(kuò)容增加消費(fèi)者的實(shí)例數(shù)量。emx28資訊網(wǎng)——每日最新資訊28at.com

消息堆積的原因我們知道了，下面我就分享一下在工作中經(jīng)常用的解決消息堆積的幾種方式。emx28資訊網(wǎng)——每日最新資訊28at.com

二、怎么解決消息堆積問(wèn)題

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

對(duì)于第二條增加消費(fèi)者數(shù)量需要注意的是，消息的路由key，分區(qū)等概念。如果配置不正確，新增加的消費(fèi)者并不會(huì)幫忙消費(fèi)堆積的消息，相反只會(huì)對(duì)新增的消息進(jìn)行消費(fèi)。emx28資訊網(wǎng)——每日最新資訊28at.com

三、總結(jié)

消息堆積發(fā)生的原因一般就是消費(fèi)者出了問(wèn)題，或者被一個(gè)異常一直錯(cuò)誤的重試。那么解決方式也就是我們上面所說(shuō)的，水平擴(kuò)容消費(fèi)者、消費(fèi)者處理速度優(yōu)化、消費(fèi)者異常重試等。emx28資訊網(wǎng)——每日最新資訊28at.com

不過(guò)相對(duì)應(yīng)的，消息的重試也就會(huì)發(fā)生一條消息執(zhí)行多次的情況，那么你的接口做冪等了嗎，下一篇文章，我們就來(lái)看下MQ中的消息重復(fù)，如何處理消費(fèi)過(guò)程中的重復(fù)消息。emx28資訊網(wǎng)——每日最新資訊28at.com

本文鏈接：http://www.tebozhan.com/showinfo-26-92456-0.html面試官：對(duì)于MQ中的消息堆積你是怎么理解的？

聲明：本網(wǎng)頁(yè)內(nèi)容旨在傳播知識(shí)，若有侵權(quán)等問(wèn)題請(qǐng)及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com

上一篇： 代碼中預(yù)編譯常見(jiàn)指令用法

下一篇： 面試官：對(duì)于 MQ 中的消息丟失你是如何理解的？