一、介绍
当生产者发送消息的速度超过了消费者处理消息的速度,就会导致队列中的消息堆积,直到队列存储消息达到上限。最
早接收到的消息，可能就会成为死信，会被丢弃，这就是消息堆积问题。
解决消息堆积有三种种思路：文章来源：https://www.toymoban.com/news/detail-801075.html
- 增加
更多消费者，提高消费速度 - 在消费者内开启
线程池加快消息处理速度 - 扩大
队列容积，提高堆积上限
从RabbitMQ的3.6.0版本开始，就增加了Lazy Queues的概念，也就是惰性队列。惰性队列的特征如下：文章来源地址https://www.toymoban.com/news/detail-801075.html
- 接收到消息后直接存入
磁盘而非內存 - 消费者要消费消息时才会从磁盘中读取并加载到内存
- 支持数
百万条的消息存储
二、使用惰性队列
1. 基于@Bean
@Bean
public 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 + "】");
}
到了这里，关于RabbitMQ常见问题之消息堆积的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
