代码编织梦想

1、概念

默认情况下 RabbitMQ 退出或由于某种原因崩溃时,它忽视队列和消息,除非告知它不要这样做。确保消息不会丢失需要做两件事:我们需要将队列和消息都标记为持久化

2、队列持久化

也就是在声明队列的时候开启持久化就行

Queue.DeclareOk queueDeclare(String queue, 
							//这个就是开启持久化的参数
							boolean durable, 
							boolean exclusive, 
							boolean autoDelete,
                            Map<String, Object> arguments) throws IOException;

但是需要注意的就是如果之前声明的队列不是持久化的,需要把原先队列先删除,或者重新创建一个持久化的队列,不然就会出现错误如下

在这里插入图片描述
删除操作
在这里插入图片描述
重新创建后持久化和没持久化队列的区别

在这里插入图片描述
即使MQ重启队列不会消失

3、消息持久化

想让消息实现持久化需要在消息生产者推送消息的方法中修改参数,MessageProperties.PERSISTENT_TEXT_PLAIN 添加这个属性。

void basicPublish(
String exchange, 
String routingKey, 
//这里修改的就是这个参数
BasicProperties props, 
byte[] body) throws IOException;

//示例
channel.basicPublish("",TASK_QUEUE_NAME, MessageProperties.PERSISTENT_TEXT_PLAIN,msg.getBytes("UTF-8"));

将消息标记为持久化并不能完全保证不会丢失消息。尽管它告诉 RabbitMQ 将消息保存到磁盘,但是这里依然存在当消息刚准备存储在磁盘的时候 但是还没有存储完,消息还在缓存的一个间隔点。如果MQ宕机,那此时并没有真正写入磁盘。持久性保证并不强,但是对于我们的简单任务队列而言,这已经绰绰有余了。

4、不公平分发

在轮询分发的时候在某种场景下这种策略并不是很好,比方说有两个消费者在处理任务,其中有个消费者 1 处理任务的速度非常快,而另外一个消费者 2 处理速度却很慢,这个时候我们还是采用轮训分发的化就会到这处理速度快的这个消费者很大一部分时间处于空闲状态,而处理慢的那个消费者一直在干活,这种分配方式在这种情况下其实就不太好,但是RabbitMQ 并不知道这种情况它依然很公平的进行分发

为了避免这种情况,我们可以设置参数 channel.basicQos();

// prefetchCount : 服务器将传递的最大消息数量,如果不受限制则为0
int prefetchCount = 1;
channel.basicQos(prefetchCount);

这里相当于设置了消费者的信道的容量也就是分发给你的消息数量,0是无限大也就是平均分配所有队列,1个就是分发消息一个,2就是两个,分发方式其实还是轮询,不过如果看容量满了,他就会跳过不分发给他,在没有应答MQ后是不会再重新给你分发消息

在这里插入图片描述

5、预取值

概念:其实也就是上面 basicQos(prefetchCount);这个方法的参数。

文绉绉的概念解释:本身消息的发送就是异步发送的,所以在任何时候,channel 上肯定不止只有一个消息另外来自消费者的手动确认本质上也是异步的。因此这里就存在一个未确认的消息缓冲区,因此希望开发人员能限制此缓冲区的大小,以避免缓冲区里面无限制的未确认消息问题。这个时候就可以通过使用 basic.qos 方法设置“预取计数”值来完成的。该值定义通道上允许的未确认消息的最大数量。一旦数量达到配置的数量,RabbitMQ 将停止在通道上传递更多消息,除非至少有一个未处理的消息被确认,例如,假设在通道上有未确认的消息 5、6、7,8,并且通道的预取计数设置为 4,此时RabbitMQ 将不会在该通道上再传递任何消息,除非至少有一个未应答的消息被 ack。比方说 tag=6 这个消息刚刚被确认 ACK,RabbitMQ 将会感知这个情况到并再发送一条消息。消息应答和 QoS 预取值对用户吞吐量有重大影响。常增加预取将提高向消费者传递消息的速度。虽然自动应答传输消息速率是最佳的,但是,在这种情况下已传递但尚未处理的消息的数量也会增加,从而增加了消费者的 RAM 消耗(随机存取存储器)应该小心使用具有无限预处理的自动确认模式或手动确认模式,消费者消费了大量的消息如果没有确认的话,会导致消费者连接节点的内存消耗变大,所以找到合适的预取值是一个反复试验的过程,不同的负载该值取值也不同 100 到 300 范围内的值通常可提供最佳的吞吐量,并且不会给消费者带来太大的风险。预取值为 1 是最保守的。当然这将使吞吐量变得很低,特别是消费者连接延迟很严重的情况下,特别是在消费者连接等待时间较长的环境中。对于大多数应用来说,稍微高一点的值将是最佳

这里假设5个消息 1,2,3,4,5,给消费者1和消费者2 ,消费者1设置预取值2,消费者2设置预取值3,这个时候还是轮询分发不过如果消费者没有应答就不会分发新消息也就是消费者1拿到消息1,3,消费者拿到消息2,4,5,这里注意如果消息进行了应答,那么就会可以再分发消息也就是消费者1比较快可以 1,3,5,而消费者2比较慢只有2,4

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/m0_51295655/article/details/128018059

rabbitmq持久化相关配置_chnwjian的博客-爱代码爱编程_rabbitmq持久化配置

http://previous.rabbitmq.com/v3_6_x/persistence-conf.html RabbitMQ持久化层的目的是在大多数没有配置的情况下提供良好的结果。然而,某些配置有时是有用的。本页面解释如何配置它。建议你在采取任何行动之前把它全部读完。 持久化工作原理 持久化消息和非持久化消息均可被写入磁盘。持久化消息一到达队

rabbitmq持久化_iiaythi的博客-爱代码爱编程_rabbitmq持久化

rabbitmq持久化 持久化是为提高rabbitmq消息的可靠性,防止在异常情况(重启,关闭,宕机)下数据的丢失 rabbitmq持久化分为三个部分: 交换器的持久化、队列的持久化和消息的持久化 交换器的持

rabbitmq持久化-爱代码爱编程

       持久化可以提高Rabbitmq的可靠性,以防止在异常情况(重启、关闭、宕机等)下的数据丢失。Rabbitmq的持久化分为三个部分:交换机的持久化、队列的持久化和消息的持久化。        交换机的持久化是通过在声明队列是将durable参数置为true实现的。如果交换机不设置持久化,那么在RabbitMQ服务重启之后,相关的交换机元数据会

rabbitmq持久化mysql_rabbitmq持久化问题-爱代码爱编程

MQ的持久化分为三个部分: 一、Exchange(交换机持久化) MQ做为消息中间件,主要用在程序间通信。使用spring集成rabbitmq后,在xml配置文件,可以很方便的设置是否持久化,代码如下: 其中 durable=true表示持久化,默认就是true,不配置这个参数也一样。 二、queue(队列持久化) ----2017.11.1

RabbitMq持久化-爱代码爱编程

持久化就是防止异常情况下的数据丢失,提高rabbitmq的可靠性。这里的异常主要说的就是重启,关闭,宕机等。根据我们近期学习的rabbitmq中有关消息的概念来说,消息要经过交换器、队列。因此我们的持久化就是针对交换器、队列和消息本身的。 1.交换器的持久化 对于经常使用的交换器来说,我们可以将交换器声明为durable参数为true,如果不声明

RabbitMQ 持久化-爱代码爱编程

RabbitMQ的持久化分为:交换器的持久化。队列的持久化和消息的持久化。 交换器的持久化 通过在声明队列是将durable参数配置为true实现的。如果交换器不设置持久化,那么RabbitMQ服务重启之后,相关的交换器元数据会丢失,不过消息不会丢失,只是不能将消息发送到这个交换器中了。对于一个长期使用的交换器来说,建议将其置为持久化。 队列的持久化

RabbitMQ—持久化-爱代码爱编程

RabbitMQ—持久化 引言 如何保障当 RabbitMQ 服务停掉以后消息生产者发送过来的消息不丢失?默认情况下 RabbitMQ 退出或由于某种原因崩溃时,它丢失队列和消息,除非告知它不要这样做。确保消息不会丢失需要做两件事:我们需要将队列和消息都标记为持久化。队列持久化 如何实现队列持久化? 在声明队列的时候把 durable 参数设置为tr

RabbitMQ笔记(三)RabbitMQ持久化的几个姿势(Spring Boot版本)-爱代码爱编程

目录 一、简介二、交换机持久化(Exchange)三、队列持久化(Queue)四、消息持久化(Message)结语 一、简介   RabbitMq的持久化操作包含有交换机持久化、队列持久化和消息持久化三类。关于本文的测试大家可以参考我前两篇文章:Spring Boot整合RabbitMQ实现分布式服务的模式。   链接: RabbitMQ笔

RabbitMQ的持久化 面试-爱代码爱编程

交换机的持久化: 交换机的持久化其实就是相当于将交换机的属性在服务器内部保存。当MQ的服务器发生意外或关闭之后,重启RabbitMQ时不需要重新手动或执行代码去建立交换机,交换机会自动建立,相当于一直存在。 其是在声明交换器的时候,将 durable 属性设置为 true。如果交换器不设置持久化,那么在 RabbitMQ 服务重启之后,相关的交换器就会

5.rabbitmq持久化_machoul的博客-爱代码爱编程

rabbitmq持久化 队列的持久化 队列的持久化需要我们在声明的时候指定其持久化 使用durable=true来持久化队列/** * 队列的持久化 */ public class QueuePersistence { public static void main(String[] args) throws IOException {

rabbitmq【直连、主题、扇形交换机实战】_joneclassmate的博客-爱代码爱编程

目录 1. 直连交换机(Direct实战)      provider生产者(publisher)      consumer消费者 2. 主题交换机(Topic实战)       provider生产者(publisher)       consumer消费者 3. 扇形交换机(Fanout实战)       provider生产者(

(九)rabbitmq交换机(exchange)_小怪吖的博客-爱代码爱编程

交换机Exchange 1、交换机1.1. Exchanges 概念1.2. Exchanges 的类型1.3. 无名exchange(默认交换机) 2、临时队列3、绑定(bindings)4、Fanout(发布

rabbitmq顺序性、可靠性、重复消费、消息堆积解决方案_andycuigo的博客-爱代码爱编程

RabbitMQ顺序性、可靠性(消息丢失)、重复消费、消息堆积解决方案 顺序性 RabbitMQ使用过程中,有些业务场景需要我们保证顺序消费,例如:业务上产生三条消息,分别是对数据的增加、修改、删除操作,如果没有保证顺序

rabbitmq持久化_rabbitmq持久化目录-爱代码爱编程

概念 我们已经看到了如何处理任务不丢失的情况(手动应答),但是如何保障当RabbitMQ服务停掉以后消息生产者发送过来的消息不丢失。默认情况下RabbitMQ退出或由于某种原因崩溃时,它忽视队列和消息,除非告知它不要这样做。确保消息不会丢失需要做两件事:我们需要将队列和消息都标记为持久化。  队列如何实现持久化 之前我们创建的队列都是非持久化的,ra

(六)rabbitmq第二种模型:工作模型(work queues)_rabbitmq怎么设置工作模型-爱代码爱编程

工作模型(Work Queues) 一、轮询发送消息二、消息应答2.1、概念2.2、自动应答2.3、手动应答2.4、消息的重新入队2.5、手动应答代码 概念:工作队列(又称任务队列)的主要思想是