赞
踩
消息积压出现的原因可能是线上故障(消费者故障)导致不能及时消费生产者的消息。
1、首先需要修复消费者,保证消费正常运作。(但是由于积压的消息太多,消费完这些积压的消息可能需要好几个小时)
2、临时扩容
比如一个消费者一秒消费1000条消息,假设这里有三个消费者,一秒钟就可以消费3000条消息,一分钟可以消费18万条。三个消费者一小时可以消费1080W条消息。
比如现在有800W消息积压,三个消费者就需要大概40~50分钟才能消费完。
如果业务不能够容忍我们花40~50分钟去处理这些积压消息,那我们就可以使用临时扩容的方式去处理。
假如这里扩容了30个queue和30个消费者,基本只需要4~5分钟,再加上重新生产消息的时间,10分钟左右就可完成积压消息的消费。完成后再把代码切回到之前的代码即可。
总结:出现消息积压,先修复消费者,然后临时扩容消费者,让扩容后的消费者去消费堆积的消息
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。