大家好，我是醉鱼，一个7年老Java。

致力于技术分享，用最通俗易懂的语言做知识的分享。本号致力于技术分享，后面也会分享一些职场经历让这个号变得更有感情。

在上一篇文章中，我们对MQ中的消息丢失有了一定的了解，相信再次被面试官问到时心里也就有了底气了。

文章的地址我放在下面，还没有看的可以跳过去看一下。

https://mp.weixin.qq.com/s/Vot6MW6K1nYGct7I0S2S-A

我们经常说的消息堆积通俗点讲就是消费者消费不了了，造成消息在MQ中堆着，然后越来越多，所以说消息堆积是在消费者阶段的问题。

那么发生消息堆积的原因有哪些呢？

一、消息堆积的原因

1、消费者挂掉。

2、消费者与 MQ 之间网络断开。

3、消费者代码 BUG ，重复消费一条消息。

4、消息路由 key 错误，造成个别分区消息堆积。

5、消费者性能原因，例如业务逻辑单表数据量过大造成消费时间缓慢。

除了上述的5个原因外，如果在工作中你还遇到过其他造成消息堆积的原因，也欢迎你在评论区进行交流，一起进步。

当发生了消息堆积时，优先是解决消息堆积问题，然后是排查问题制定解决方案。毕竟保证系统的可用性是首先要解决的问题。快速解决积压的方法就是通过水平扩容增加消费者的实例数量。

消息堆积的原因我们知道了，下面我就分享一下在工作中经常用的解决消息堆积的几种方式。

二、怎么解决消息堆积问题

1、限制生产者消息生产速度。

2、增加消费者数量，水平扩容。

3、排查消费者代码逻辑，保证没有一直循环消费一条消息。

4、优化消费者消费逻辑，减少复杂计算逻辑。使用异步、多线程等手段提升消费速度。

5、定期清理过期消息。

对于第二条增加消费者数量需要注意的是，消息的路由key，分区等概念。如果配置不正确，新增加的消费者并不会帮忙消费堆积的消息，相反只会对新增的消息进行消费。

消息堆积发生的原因一般就是消费者出了问题，或者被一个异常一直错误的重试。那么解决方式也就是我们上面所说的，水平扩容消费者、消费者处理速度优化、消费者异常重试等。

不过相对应的，消息的重试也就会发生一条消息执行多次的情况，那么你的接口做幂等了吗，下一篇文章，我们就来看下MQ中的消息重复，如何处理消费过程中的重复消息。

?推荐：