1. 介绍
一般情况下,RabbitMQ会将接收到的信息保存在内存中以降低消息收发的延迟。
但在某些特殊情况下，这会导致消息积压，比如：
消费者宕机或出现网络故障
消息发送量激增，超过了消费者处理速度
消费者处理业务发生阻塞
一旦出现消息堆积问题，RabbitMQ的内存占用就会越来越高，直到触发内存预警上限
为了解决这个问题，从RabbitMQ的3.6.0版本开始，就增加了Lazy Queues的模式，也就是惰性队列。惰性队列的特征如下：
接收到消息后直接存入磁盘而非内存
消费者要消费消息时才会从磁盘中读取并加载到内存（也就是懒加载）
支持数百万条的消息存储
官方推荐升级MQ为3.12版本或者所有队列都设置为LazyQueue模式
2. 控制台配置Lazy模式
在添加队列的时候，添加x-queue-mod=lazy参数即可设置队列为Lazy模式：
测试看一下效果:
3. 代码配置Lazy模式
3.1 使用Bean声明
写一个配置类，使用QueueBuilder创建lazy.queue队列,并开启Lazy模式
代码如下:
package com.itheima.consumer.config;import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class LazyConfigUration {@Beanpublic Queue lazyQueue() {return QueueBuilder.durable("lazy.queue").lazy() // 开启Lazy模式.build();}
}
测试效果:
3.2 基于注解声明
代码如下:
@RabbitListener(queuesToDeclare = @Queue(name = "lazy.queue",durable = "true",arguments = @Argument(name = "x-queue-mode", value = "lazy")
))
public void listenLazyQueue(String msg){log.info("接收到 lazy.queue的消息：{}", msg);
}效果是一样的