RocketMQ消息积压,提升消费者数量能否缓解压力?
- 内容介绍
- 文章标签
- 相关推荐
本文共计2643个文字,预计阅读时间需要11分钟。
面试官:RocketMQ 消息积压了,增加消费者有用吗?我:这个需要看具体场景,不同场景下情况是不一样的。面试官:可以详细说一说吗?我:如果消费者数量小于 MessageQueue 的数量,那么增加消费者是有用的,可以提升消息的消费速度。
面试官:RocketMQ 消息积压了,增 加消费者有用吗?
我:这个要看具体的场景,不同的场景下情况是不一样的。
面试官:可以详细说一下吗?
我:如果消费者的数量小于 MessageQueue 的数量,增加消费者可以加快消 息消费速度,减少消 息积压。比如一个 Topic 有 4 个 MessageQueue,2 个消费者进行消费,如果增加一个消费者,明细可以加快拉取消息的频率。如下图:
如果消费者的数量大于等于 MessageQueue 的数量,增加消费者是没有用的。比如一个 Topic 有 4 个 MessageQueue,并且有 4 个消费者进行消费。如下图
面试官:你说的第一种情况,增加消费者一定能加快消 息 消 费的速度吗?
我:这...,一般情况下是可以的。
面试官:有特殊的情况吗?
我:当然有。消费者消息拉取的速度也取决于本地消息的消费速度,如果本地消息消费的慢,就会延迟一段时间后再去拉取。
本文共计2643个文字,预计阅读时间需要11分钟。
面试官:RocketMQ 消息积压了,增加消费者有用吗?我:这个需要看具体场景,不同场景下情况是不一样的。面试官:可以详细说一说吗?我:如果消费者数量小于 MessageQueue 的数量,那么增加消费者是有用的,可以提升消息的消费速度。
面试官:RocketMQ 消息积压了,增 加消费者有用吗?
我:这个要看具体的场景,不同的场景下情况是不一样的。
面试官:可以详细说一下吗?
我:如果消费者的数量小于 MessageQueue 的数量,增加消费者可以加快消 息消费速度,减少消 息积压。比如一个 Topic 有 4 个 MessageQueue,2 个消费者进行消费,如果增加一个消费者,明细可以加快拉取消息的频率。如下图:
如果消费者的数量大于等于 MessageQueue 的数量,增加消费者是没有用的。比如一个 Topic 有 4 个 MessageQueue,并且有 4 个消费者进行消费。如下图
面试官:你说的第一种情况,增加消费者一定能加快消 息 消 费的速度吗?
我:这...,一般情况下是可以的。
面试官:有特殊的情况吗?
我:当然有。消费者消息拉取的速度也取决于本地消息的消费速度,如果本地消息消费的慢,就会延迟一段时间后再去拉取。

