在上一篇文章中,我们对MQ中的消息丢失有了一定的了解,相信再次被面试官问到时心里也就有了底气了。
文章的地址我放在下面,还没有看的可以跳过去看一下。
面试官:对于MQ中的消息丢失你是如何理解的?
我们经常说的消息堆积通俗点讲就是消费者消费不了了,造成消息在MQ中堆着,然后越来越多,所以说消息堆积是在消费者阶段的问题。
那么发生消息堆积的原因有哪些呢?
一、消息堆积的原因
除了上述的5个原因外,如果在工作中你还遇到过其他造成消息堆积的原因,也欢迎你在评论区进行交流,一起进步。
当发生了消息堆积时,优先是解决消息堆积问题,然后是排查问题制定解决方案。毕竟保证系统的可用性是首先要解决的问题。快速解决积压的方法就是通过水平扩容增加消费者的实例数量。
消息堆积的原因我们知道了,下面我就分享一下在工作中经常用的解决消息堆积的几种方式。
二、怎么解决消息堆积问题
对于第二条增加消费者数量需要注意的是,消息的路由key,分区等概念。如果配置不正确,新增加的消费者并不会帮忙消费堆积的消息,相反只会对新增的消息进行消费。
三、总结
消息堆积发生的原因一般就是消费者出了问题,或者被一个异常一直错误的重试。那么解决方式也就是我们上面所说的,水平扩容消费者、消费者处理速度优化、消费者异常重试等。
不过相对应的,消息的重试也就会发生一条消息执行多次的情况,那么你的接口做幂等了吗,下一篇文章,我们就来看下MQ中的消息重复,如何处理消费过程中的重复消息。