RabbitMq消息堆积问题及惰性队列

这篇具有很好参考价值的文章主要介绍了RabbitMq消息堆积问题及惰性队列。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

消息堆积问题

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

查看rabbitmq消息堆积,rabbitmq,rabbitmq

解决消费对接问题

1.增加更多的消费者,提高消费者速度
2.在消费则内开启线程池加快消息处理速度
3.使用惰性队列,扩大队列容积,提高堆积上限

惰性队列

rabbitmq3.6.0 版本开始,新增了Lazy Queues概念,也就是惰性队列。

惰性队列的特征如下:

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

普通的队列会设置一个预警值默认40% 当队列到了40%时,mqBroker 会阻止生产者发送消息。并将队列中消息持久化到磁盘。等腾出空间了再接收消息。所以mq的性能是一个不稳定,波浪形的。 而惰性队列呢在接收消息后会直接写到磁盘,所以不会触发队列的存储预警,性能具有稳定性,延迟性。

正因为惰性队列支持百万的消息存储,所以用它来解决消息堆积问题再好不过了。

惰性队列的实现
1.运行中队列变为惰性队列
查看rabbitmq消息堆积,rabbitmq,rabbitmq

2.直接声明队列为惰性队列

查看rabbitmq消息堆积,rabbitmq,rabbitmq文章来源地址https://www.toymoban.com/news/detail-594451.html

惰性队列的优点有哪些?

  • 基于磁盘存储,消息上限高
  • 米有间歇性的page-out,性能比较稳定

惰性队列的缺点有哪些

  • 基于磁盘存储,消息时效性会降低
  • 性能受限于磁盘的IO

到了这里,关于RabbitMq消息堆积问题及惰性队列的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • rabbitmq基础7——队列和消息过期时间设置、死信队列、延迟队列、优先级队列、回调队列、惰性队列

    这里过一个知识点——过期时间,即对消息或队列设置过期时间(TTL)。一旦消息过期,消费就无法接收到这条消息,这种情况是绝不允许存在的,所以官方就出了一个对策——死信队列,死信队列最初出现的意义就是为了应对消息过期丢失情况的手段之一。 那么过期时间具

    2024年02月03日
    浏览(51)
  • RabbitMQ常见问题之消息堆积

    当生产者发送消息的速度超过了消费者处理消息的速度,就会导致队列中的消息堆积,直到队列存储消息达到上限。最 早接收到的消息,可能就会成为死信,会被丢弃,这就是消息堆积问题。 解决消息堆积有三种种思路: 增加 更多消费者 ,提高消费速度 在消费者内开启 线程

    2024年01月18日
    浏览(32)
  • 【学习日记2023.6.19】 之 RabbitMQ服务异步通信_消息可靠性_死信交换机_惰性队列_MQ集群

    消息队列在使用过程中,面临着很多实际问题需要思考: 消息从发送,到消费者接收,会经历多个过程: 其中的每一步都可能导致消息丢失,常见的丢失原因包括: 发送时丢失: 生产者发送的消息未送达exchange 消息到达exchange后未到达queue MQ宕机,queue将消息丢失 consumer接收

    2024年02月11日
    浏览(35)
  • RabbitMQ系列(23)--RabbitMQ惰性队列

    1、概念:RabbitMQ从 3.6.0版本开始引入了惰性队列的概念。惰性队列会尽可能的将消息存入磁盘中(持久化队列若想持久化消息还需要看消息设置了持久化没),而在消费者消费到相应的消息时才会被加载到内存中,它的一个重要的设计目标是能够支持更长的队列,即支持更多

    2024年02月16日
    浏览(33)
  • rabbitMq怎么查看队列消息-Tracing日志

    Trace 是Rabbitmq用于记录每一次发送的消息,方便使用Rabbitmq的开发者调试、排错。 1、启动Tracing插件 在RabbitMQ中默认是关闭的,需手动开启。此处rabbitMQ是使用docker部署的 开启了插件后,无需重启,rabbitMq管理界面就会出现Tracing项,可新建追踪。 2、新建trace 新建trace时,JSON模

    2024年02月12日
    浏览(28)
  • RabbitMQ惰性队列使用

    说明:惰性队列是为了解决消息堆积问题,当生产者生产消息的速度远高于消费者消费消息的速度时,消息会大量的堆积在队列中,而队列中存放的消息数量是有限的,当超出数量时,会造成消息的丢失。而扩容队列,实际上不太现实,因为队列的消息是存在内存中的,内存

    2024年02月16日
    浏览(31)
  • RabbitMQ --- 惰性队列、MQ集群

    当生产者发送消息的速度超过了消费者处理消息的速度,就会导致队列中的消息堆积,直到队列存储消息达到上限。之后发送的消息就会成为死信,可能会被丢弃,这就是消息堆积问题。 解决消息堆积有三种思路: 增加更多消费者,提高消费速度。也就是我们之前说的work

    2024年02月03日
    浏览(39)
  • RabbitMQ消息堆积方案处理

    在消息队列中,消息堆积是生产环境中的需要考虑的问题,一旦消息产生积压,来不及消费,可能会导致MQ服务器宕机,而解决消息积压有这样一些方案解决: 1.增加消费者数量 可以根据业务情况适当添加多台服务器部署消费者服务实例,消费者数量增加,可以有效提高消息

    2024年02月11日
    浏览(46)
  • Rabbitmq消息大量堆积

    记得有次公司搞促销活动,流量增加,但是系统一直很平稳( 我们开发的系统真牛 ),大家很开心的去聚餐,谈笑风声,气氛融洽,突然电话响起.... 运维:小李,你们系统使用的rabbitmq的消息大量堆积,导致服务器cpu飙升,赶紧回来看看,服务器要顶不住了小李:好的 我们

    2024年01月15日
    浏览(33)
  • Rabbitmq消息大量堆积,我慌了!

    记得有次公司搞促销活动,流量增加,但是系统一直很平稳( 我们开发的系统真牛 ),大家很开心的去聚餐,谈笑风声,气氛融洽,突然电话响起… 运维:小李,你们系统使用的rabbitmq的消息大量堆积,导致服务器cpu飙升,赶紧回来看看,服务器要顶不住了 小李:好的 我们

    2024年01月18日
    浏览(102)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包