RabbitMQ常见问题之消息堆积

文章目录

• 一、介绍
• 二、使用惰性队列
• • • 1. 基于@Bean
    • 2. 基于@RabbitListener

一、介绍

当生产者发送消息的速度超过了消费者处理消息的速度,就会导致队列中的消息堆积,直到队列存储消息达到上限。最
早接收到的消息，可能就会成为死信，会被丢弃，这就是消息堆积问题。

解决消息堆积有三种种思路：

• 增加更多消费者，提高消费速度
• 在消费者内开启线程池加快消息处理速度
• 扩大队列容积，提高堆积上限

从RabbitMQ的3.6.0版本开始，就增加了Lazy Queues的概念，也就是惰性队列。惰性队列的特征如下：

• 接收到消息后直接存入磁盘而非內存
• 消费者要消费消息时才会从磁盘中读取并加载到内存
• 支持数百万条的消息存储
  

二、使用惰性队列

1. 基于@Bean

@Beanpublic Queue lazyQueue(){return QueueBuilder.durable("lazy.queue").lazy().build();}

2. 基于@RabbitListener

@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "lazy.queue", arguments = @Argument(name = "x-queue-mode", value = "lazy")),exchange = @Exchange(name = "simple.exchange"),key = "lazy"))public void listenLazyExchange(String msg){//log.info("消费者接收到lazy.queue的消息：【" + msg + "】");}