RabbitMq之不公平分发预取值

Posted 2023-01-29 微微笑再加油

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

 //设置不公平分发
channel.basicQos(1);
//接收消息
channel.basicConsume(TASK_QUEUE_NAME,true,deliverCallback,cancelCallback);

在mq可视化界面的channel中显示如下

2.预取值
预取值：限定信道缓冲区的大小，以避免缓冲区里面无限制的未确认消息问题。图示如下
消费者C1中的信道存在两条消息，C2存在5条，等C1消费至少一条之后才会继续分发消息

 //设置预取值=2
channel.basicQos(2);
//接收消息
channel.basicConsume(TASK_QUEUE_NAME,true,deliverCallback,cancelCallback);