RabbitMQ流控-磁盘控制

2024-01-23 08:18
文章标签 控制 rabbitmq 磁盘 流控

本文主要是介绍RabbitMQ流控-磁盘控制,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

当磁盘空间低于配置(disk_free_limit)的限制时(默认disk_free_limit.absolute=50MB),将触发警报,并阻塞所有生产者。目的是避免填充整个磁盘,否则将导致节点上的所有写操作失败,并可能导致RabbitMQ终止。为了减少磁盘被填满的风险,所有正在传入的消息都将被阻塞。在内存压力下,非持久化的暂态消息仍将page到磁盘,并将耗尽已经有限的磁盘空间。如果磁盘警报阈值设置得太低,并且消息被快速换出(到磁盘),则可能在磁盘空间检查期间耗尽磁盘空间并崩溃RabbitMQ(间隔至少10秒)。更保守的方法是将磁盘限制阈值设置为与系统上安装的内存数量相同(参见下面的配置)。

如果空闲磁盘空间低于配置的阈值,将触发警报。将至少每10秒监视代理数据库使用的驱动器或分区的空闲空间,以确定是否应该发出或清除磁盘警报。一旦代理启动,将立即启动监控,导致代理日志文件中出现一个条目:

=INFO REPORT==== 23-Jun-2012::14:52:41 ===
Disk free limit set to 953MB

在不被认可的平台上,监控功能将会被禁用,从而导致以下输入:

=WARNING REPORT==== 23-Jun-2012::15:45:29 ===
Disabling disk free space monitoring

在集群中运行RabbitMQ时,磁盘报警是集群范围的;如果一个节点低于限制,那么所有节点都将阻塞传入的消息。

RabbitMQ定期检查空闲磁盘空间的数量。检查磁盘空间的频率与最后一次检查时的空间数量有关(以确保在磁盘空间耗尽时及时发出磁盘警报)。通常每10秒检查一次磁盘空间,但是随着限制的接近,频率会增加。当非常接近极限时,RabbitMQ将每秒检查10次。这可能会对系统负载产生一些影响。

当空闲磁盘空间低于配置的限制时,RabbitMQ将阻塞消息生产者并阻止基于内存的消息page到磁盘。这将减少磁盘空间耗尽导致崩溃的可能性,但不会完全消除它。特别是,如果正在快速换出(page)消息,可能会耗尽磁盘空间并在两次运行磁盘空间检测之间崩溃。更保守的方法是将限制设置为与系统上安装的内存数量相同(参见下面的配置部分)。

Configuring the Disk Free Space Limit

磁盘空闲空间限制使用参数disk_free_limit设置。默认情况下,数据库分区上需要50MB的空闲空间(关于默认数据库位置,请参阅http://www.rabbitmq.com/relocate.html的描述,默认地址:/var/lib/rabbitmq/mnesia/rabbit@localhost)。此配置文件将磁盘空闲空间限制设置为1GB:

disk_free_limit.absolute = 1GB
或
[{rabbit, [{disk_free_limit, 1000000000}]}]

也可以相对于机器中的RAM设置一个空闲空间限制。此配置文件将磁盘空闲空间限制设置为与机器上RAM数量相同:

disk_free_limit.relative = 1.0
或
[{rabbit, [{disk_free_limit, {mem_relative, 1.0}}]}]

当代理使用rabbitmqctl set_disk_free_limit disk_limit命令或rabbitmqctl set_disk_free_limit mem_relative fraction命令运行时,可以更改该限制。此命令将一直生效,直到代理关闭。在代理重新启动之后,还应该更改相应的配置设置。

这篇关于RabbitMQ流控-磁盘控制的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/635779

相关文章

Python异步编程中asyncio.gather的并发控制详解

《Python异步编程中asyncio.gather的并发控制详解》在Python异步编程生态中,asyncio.gather是并发任务调度的核心工具,本文将通过实际场景和代码示例,展示如何结合信号量... 目录一、asyncio.gather的原始行为解析二、信号量控制法:给并发装上"节流阀"三、进阶控制

使用DrissionPage控制360浏览器的完美解决方案

《使用DrissionPage控制360浏览器的完美解决方案》在网页自动化领域,经常遇到需要保持登录状态、保留Cookie等场景,今天要分享的方案可以完美解决这个问题:使用DrissionPage直接... 目录完整代码引言为什么要使用已有用户数据?核心代码实现1. 导入必要模块2. 关键配置(重点!)3.

SpringSecurity 认证、注销、权限控制功能(注销、记住密码、自定义登入页)

《SpringSecurity认证、注销、权限控制功能(注销、记住密码、自定义登入页)》SpringSecurity是一个强大的Java框架,用于保护应用程序的安全性,它提供了一套全面的安全解决方案... 目录简介认识Spring Security“认证”(Authentication)“授权” (Auth

python之流程控制语句match-case详解

《python之流程控制语句match-case详解》:本文主要介绍python之流程控制语句match-case使用,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录match-case 语法详解与实战一、基础值匹配(类似 switch-case)二、数据结构解构匹

Spring Security注解方式权限控制过程

《SpringSecurity注解方式权限控制过程》:本文主要介绍SpringSecurity注解方式权限控制过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、摘要二、实现步骤2.1 在配置类中添加权限注解的支持2.2 创建Controller类2.3 Us

Python中如何控制小数点精度与对齐方式

《Python中如何控制小数点精度与对齐方式》在Python编程中,数据输出格式化是一个常见的需求,尤其是在涉及到小数点精度和对齐方式时,下面小编就来为大家介绍一下如何在Python中实现这些功能吧... 目录一、控制小数点精度1. 使用 round() 函数2. 使用字符串格式化二、控制对齐方式1. 使用

Springboot控制反转与Bean对象的方法

《Springboot控制反转与Bean对象的方法》文章介绍了SpringBoot中的控制反转(IoC)概念,描述了IoC容器如何管理Bean的生命周期和依赖关系,它详细讲解了Bean的注册过程,包括... 目录1 控制反转1.1 什么是控制反转1.2 SpringBoot中的控制反转2 Ioc容器对Bea

Spring Boot整合消息队列RabbitMQ的实现示例

《SpringBoot整合消息队列RabbitMQ的实现示例》本文主要介绍了SpringBoot整合消息队列RabbitMQ的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的... 目录RabbitMQ 简介与安装1. RabbitMQ 简介2. RabbitMQ 安装Spring

SpringBoot中整合RabbitMQ(测试+部署上线最新完整)的过程

《SpringBoot中整合RabbitMQ(测试+部署上线最新完整)的过程》本文详细介绍了如何在虚拟机和宝塔面板中安装RabbitMQ,并使用Java代码实现消息的发送和接收,通过异步通讯,可以优化... 目录一、RabbitMQ安装二、启动RabbitMQ三、javascript编写Java代码1、引入

浅析如何使用Swagger生成带权限控制的API文档

《浅析如何使用Swagger生成带权限控制的API文档》当涉及到权限控制时,如何生成既安全又详细的API文档就成了一个关键问题,所以这篇文章小编就来和大家好好聊聊如何用Swagger来生成带有... 目录准备工作配置 Swagger权限控制给 API 加上权限注解查看文档注意事项在咱们的开发工作里,API