网站模板中文,惠州做百度网站多少,免费seo快速排名系统,邢台千度网络科技有限公司文章目录 前言一、数据持久化交换机持久化队列持久化消息持久化 二、LazyQueue控制台配置Lazy模式代码配置Lazy模式更新已有队列为lazy模式 总结 前言
消息到达MQ以后#xff0c;如果MQ不能及时保存#xff0c;也会导致消息丢失#xff0c;所以MQ的可靠性也非常重要。 一、… 文章目录 前言一、数据持久化交换机持久化队列持久化消息持久化 二、LazyQueue控制台配置Lazy模式代码配置Lazy模式更新已有队列为lazy模式 总结 前言
消息到达MQ以后如果MQ不能及时保存也会导致消息丢失所以MQ的可靠性也非常重要。 一、数据持久化 为了提升性能默认情况下MQ的数据都是在内存存储的临时数据重启后就会消失。为了保证数据的可靠性必须配置数据持久化包括 交换机持久化队列持久化消息持久化 交换机持久化
在控制台的Exchanges页面添加交换机时可以配置交换机的Durability参数 设置为Durable就是持久化模式Transient就是临时模式。
队列持久化
在控制台的Queues页面添加队列时同样可以配置队列的Durability参数
消息持久化
在控制台发送消息的时候可以添加很多参数而消息的持久化是要配置一个properties 在开启持久化机制以后如果同时还开启了生产者确认那么MQ会在消息持久化以后才发送ACK回执进一步确保消息的可靠性。 不过出于性能考虑为了减少IO次数发送到MQ的消息并不是逐条持久化到数据库的而是每隔一段时间批量持久化。一般间隔在100毫秒左右这就会导致ACK有一定的延迟因此建议生产者确认全部采用异步方式。 二、LazyQueue 在默认情况下RabbitMQ会将接收到的信息保存在内存中以降低消息收发的延迟。但在某些特殊情况下这会导致消息积压比如 消费者宕机或出现网络故障消息发送量激增超过了消费者处理速度消费者处理业务发生阻塞 一旦出现消息堆积问题RabbitMQ的内存占用就会越来越高直到触发内存预警上限。此时RabbitMQ会将内存消息刷到磁盘上这个行为称为PageOut。 PageOut会耗费一段时间并且会阻塞队列进程。因此在这个过程中RabbitMQ不会再处理新的消息生产者的所有请求都会被阻塞。 为了解决这个问题从RabbitMQ的3.6.0版本开始就增加了Lazy Queues的模式也就是惰性队列。惰性队列的特征如下 接收到消息后直接存入磁盘而非内存消费者要消费消息时才会从磁盘中读取并加载到内存也就是懒加载支持数百万条的消息存储 而在3.12版本之后LazyQueue已经成为所有队列的默认格式。因此官方推荐升级MQ为3.12版本或者所有队列都设置为LazyQueue模式。 控制台配置Lazy模式
在添加队列的时候添加x-queue-modlazy参数即可设置队列为Lazy模式
代码配置Lazy模式
在利用SpringAMQP声明队列的时候添加x-queue-modlazy参数也可设置队列为Lazy模式
Bean
public Queue lazyQueue(){return QueueBuilder.durable(lazy.queue).lazy() // 开启Lazy模式.build();
}当然我们也可以基于注解来声明队列并设置为Lazy模式
RabbitListener(queuesToDeclare Queue(name lazy.queue,durable true,arguments Argument(name x-queue-mode, value lazy)
))
public void listenLazyQueue(String msg){log.info(接收到 lazy.queue的消息{}, msg);
}更新已有队列为lazy模式
对于已经存在的队列也可以配置为lazy模式但是要通过设置policy实现。 可以基于命令行设置policy
rabbitmqctl set_policy Lazy ^lazy-queue$ {queue-mode:lazy} --apply-to queues 命令解读
rabbitmqctl RabbitMQ的命令行工具set_policy 添加一个策略Lazy 策略名称可以自定义“^lazy-queue$” 用正则表达式匹配队列的名字‘{“queue-mode”:“lazy”}’ 设置队列模式为lazy模式–apply-to queues策略的作用对象是所有的队列
当然也可以在控制台配置policy进入在控制台的Admin页面点击Policies即可添加配置 总结
以上就是全部讲解。
