RabbitMQ消息堆积问题解决

摘要

今日目标

本文旨在教会读者如何使用RabbitMQ中的惰性队列（lazy-queue）来解决消息堆积问题。

1. 消息堆积问题介绍

当生产者发送消息的速度超出消费者的处理能力，会导致队列消息堆积，进而可能导致超出上限后的消息丢失。解决方法包括：增加消费者数量、使用消费者内的线程池提速，以及扩大队列容量。

2. 惰性队列(Lazy Queues)

RabbitMQ 3.6.0版本引入了惰性队列，它的特点是消息直接存储于磁盘，消费时才读取到内存，适用于存储大量消息。

2.1. 基于RabbitMQ客户端创建设置

客户端创建队列时，可设置x-queue-mode属性为lazy，以创建惰性队列。

2.2. 基于命令行设置lazy-queue

可以通过rabbitmqctl命令行工具设置惰性队列策略，以将运行中的队列修改为惰性队列。

2.3. 基于@Bean声明lazy-queue

消费端可通过配置类和@Bean声明惰性队列。

2.4. 基于@RabbitListener声明LazyQueue

通过@RabbitListener注解和@Queue声明可实现消息监听，并指定队列为惰性队列。

2.5. 测试

测试通过发送接口，验证消息是否存储于磁盘而非内存，测试时仅启动消息发送端。

3. 总结

消息堆积可通过多消费者和使用惰性队列解决。惰性队列基于磁盘存储，具有高存储上限和稳定性能优势，但存在时效性降低和性能受磁盘IO限制的缺点。