当生产者发送消息的速度超过了消费者处理消息的速度,就会导致队列中的消息堆积,直到队列存储消息达到上限。之后发送的消息就会成为死信,可能会被丢弃,这就是消息堆积问题。
解决消息堆积有两种思路:
-
增加更多消费者,提高消费速度。也就是我们之前说的work queue模式
-
扩大队列容积,提高堆积上限
要提升队列容积,把消息保存在内存中显然是不行的。
欢迎分享,转载请注明来源:内存溢出
当生产者发送消息的速度超过了消费者处理消息的速度,就会导致队列中的消息堆积,直到队列存储消息达到上限。之后发送的消息就会成为死信,可能会被丢弃,这就是消息堆积问题。
解决消息堆积有两种思路:
增加更多消费者,提高消费速度。也就是我们之前说的work queue模式
扩大队列容积,提高堆积上限
要提升队列容积,把消息保存在内存中显然是不行的。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)