在使用mq消息队列的时候,如果消息队列出现消息积压怎么办?

提问者:帅平 问题分类:消息队列

在使用mq消息队列的时候,如果消息队列出现消息积压怎么办?

1 个回答
Rae
Rae 管理员

消息挤压最主要就是性能问题。

如果是线上突发问题,则需要进行应急处理,那么处理措施就是:

要临时扩容,增加消费端的数量,与此同时,降级一些非核心的业务。通过扩容和降级承担流量。

那么应急处理措施之后我们就要开始排查消费者为什么消费消息慢的问题,可以从如下情况入手:

1、通过监控,日志等手段分析是否消费端的业务逻辑代码出现了问题。
2、优化消费端的业务处理逻辑。

发布于:2个月前 (10-18)
Rae
Rae管理员

基于此问题,还需要额外注意下,如果需要进行水平扩容来提高消费者的处理能力的话,topic的分区数量也需要进行同步扩容,必须确保消费者的实例数量和分区数是相等的。如果消费者实例数量超过了分区数量,那么其实每个分区相当一是单线程消费,这样的消费者实例扩容毫无意义。

发布于:2个月前 (10-18)
我来回答