面试官:对于MQ中的消息堆积你是怎么理解的?

2024年 6月 6日 79.8k 0

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

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

面试官:对于MQ中的消息丢失你是如何理解的?

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

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

面试官:对于MQ中的消息堆积你是怎么理解的?-1

一、消息堆积的原因

  • 消费者挂掉。
  • 消费者与 MQ 之间网络断开。
  • 消费者代码 BUG ,重复消费一条消息。
  • 消息路由 key 错误,造成个别分区消息堆积。
  • 消费者性能原因,例如业务逻辑单表数据量过大造成消费时间缓慢。
  • 除了上述的5个原因外,如果在工作中你还遇到过其他造成消息堆积的原因,也欢迎你在评论区进行交流,一起进步。

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

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

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

  • 限制生产者消息生产速度。
  • 增加消费者数量,水平扩容。
  • 排查消费者代码逻辑,保证没有一直循环消费一条消息。
  • 优化消费者消费逻辑,减少复杂计算逻辑。使用异步、多线程等手段提升消费速度。
  • 定期清理过期消息。
  • 对于第二条增加消费者数量需要注意的是,消息的路由key,分区等概念。如果配置不正确,新增加的消费者并不会帮忙消费堆积的消息,相反只会对新增的消息进行消费。

    三、总结

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

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

    相关文章

    JavaScript2024新功能:Object.groupBy、正则表达式v标志
    PHP trim 函数对多字节字符的使用和限制
    新函数 json_validate() 、randomizer 类扩展…20 个PHP 8.3 新特性全面解析
    使用HTMX为WordPress增效:如何在不使用复杂框架的情况下增强平台功能
    为React 19做准备:WordPress 6.6用户指南
    如何删除WordPress中的所有评论

    发布评论