天天看点

RabbitMQ3/4---持久化机制、内存磁盘控制

1.RabbitMQ持久化机制

RabbitMQ持久化机制分为队列持久化、消息持久化、交换器持久化。不管是持久化的消息还是非持久化的消息都可以被写入到磁盘。

RabbitMQ3/4---持久化机制、内存磁盘控制

(1)RabbitMQ队列持久化

队列持久化是定义在队列的durable参数来实现的,durable为true时,队列才会持久化。

Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel();


//第二个参数设置为true,即durable =  true
channel.queueDeclare("queuel",true,false,false,null);      

持久化的队列在管理页面可以看到有个“D”的标识。

RabbitMQ3/4---持久化机制、内存磁盘控制

(2)RabbitMQ消息持久化

消息持久化可以通过消息属性deliveryMode来设置是否持久化,在发送消息时通过basicPublish的参数传入。

//通过传入MessageProperties.PERSISTENT_TEXT_PLAIN就可以实现消息持久化
channel.basicPublish("","queuel",MessageProperties.PERSISTENT_TEXT_PLAIN,"persistent_test_message".getBytes());      

(3)RabbitMQ交换器持久化

同队列一样,交换器也需要在定义时设置持久化标识,否则在Broker重启后将丢失。

//duration 为true则开启持久化
Exchange.DeclareOK exchangeDeclare(String exchange,String type,boolean durable) throws IOException      

2.RabbitMQ内存控制

(1)RabbitMQ内存告警

当内存使用超过配置的阈值或者磁盘剩余空间低于配置的阈值时,RabbitMQ会暂时阻塞客户端的连接,并停止接收从客户端发来的消息,以此避免服务崩溃,客户端与服务端的心跳检测也会失效。

RabbitMQ3/4---持久化机制、内存磁盘控制

当出现内存告警时,可以通过管理命令临时调整内存大小

rabbitmqctl set_vm_memory_high_watermark <fraction>      

fraction为内存阈值,RabbitMQ默认值为0.4,表示当RabbitMQ使用的内存超过40%时,就会产生警告并阻塞所有生产者连接。

通过此命令修改的阈值在Broker重启后将会失效,通过修改配置文件的方式设置的阈值则不会在重启后消失,但需要重启Broker才会生效、

当配置文件地址:​

​/etc/rabbitmq/rabbitmq.conf​

vm_memory_high_watermark.relative = 0.4
#vm_memory_high_watermark.absoult= 1G      

RabbitMQ提供relative或absoult两种配置方式:

relative相对值,即前面的fraction,建议取值在​​

​0.4~0.66​

​​之间,不建议超过0.7

absoult绝对值,单位为KB、MB、GB,对应的命令是

rabbitmqctl set_vm_memory_high_watermark absoult <value>      

(2)RabbitMQ内存换页

当某个Broker节点触及内存并阻塞生产者之前,它会先尝试将队列中的消息换页到磁盘以释放内存空降。

持久化和非持久化的消息都会被转出到磁盘中,其中持久化的消息本身就在磁盘中有一份副本,这里会将持久化的消息从内存中消除掉。

默认情况下,在内存到达内存阈值的50%时才会进行换页动作。

也就是说,在默认的内存阈值为0.4的情况下,当内存超过0.4 x 0.5 =0.2时才会进行换页动作。

可以通过在配置文件中配置​

​vm_memory_high_watermark_paging_ratio​

​项来修改此值

vm_memory_high_watermark_relative = 0.4
vm_memory_high_watermark_paging_ration = 0.75      

以上配置将会在RabbitMQ内存使用率达到30%时进行换页动作,并在40%时阻塞生产者。当vm_memory_high_watermark_paging_ratio的值大于1时,相当于禁用了换页功能。

3.RabbitMQ磁盘控制

RabbitMQ3/4---持久化机制、内存磁盘控制

RabbitMQ磁盘告警

当磁盘剩余空间低于确定的阈值时,RabbitMQ同样会阻塞生产者,这样可以避免因非持久化的消息持续换页而耗尽磁盘空间导致服务崩溃。

默认情况下,磁盘阈值为50MB,表示当磁盘剩余空间低于50MB时会阻塞生产者并停止内存中消息的换页动作。

这个阈值的设置可以减小,但不能完全消除因磁盘耗尽而导致崩溃的可能性。比如在两次磁盘空间检测期间内,磁盘空间从大于50MB被耗尽到0MB。

  • 一个相对谨慎的做法是将磁盘阈值设置为与操作系统所显示的内存大小一致。

通过命令可以临时调整磁盘阈值

rabbitmqctl set_disk_free_limit <disk_limit>
rabbitmqctl set_disk_free_limit mem_relative <fraction>      

disk_limit为固定大小,单位为KB 、MB 、GB 、

fraction为相对比值,建议的取值为(相对于内存)1.0~2.0之间

对应配置如下:

disk_free_limit.relative = 2.0

#disk_free_limit.absoult= 50mb

【测试】

磁盘大小调整到1024GB(剩余1024GB开始预警):出现了磁盘预警

磁盘大小调整到1GB:磁盘预警消失

RabbitMQ3/4---持久化机制、内存磁盘控制