526互联

如果有100万消息堆积在MQ , 如何解决 ?

发布时间 2023-09-21 16:07:25作者: 程序员_YHB

（1）消费者可以开启多线程消费，提高消费速率。

（2）一个工作队列可以绑定多个消费者，同时消费消息。

（3）扩大队列容积，提高堆积上限。比如集群搭建。

（4）采用RabbitMQ惰性队列：

①接收到消息后直接存入磁盘而非内存。

②消费者要消费消息时才会从磁盘中读取并加载到内存。

③支持数百万条的消息存储。