在最開始的時候我們學習到RabbitMQ.分發(fā)消息采用的輪訓分發(fā)，但是在某種場景下這種策略并不是很好，比方說有兩個消費者在處理任務，其中有個消費者1處理任務的速度非常快，而另外一個消費者2處理速度卻很慢，這個時候我們還是采用輪訓分發(fā)的化就會到這處理速度快的這個消費者很大一部分時間處于空閑狀態(tài)，而處理慢的那個消費者一直在干活，這種分配方式在這種情況下其實就不太好，但是RabbitMQ并不知道這種情況，它依然很公平的進行分發(fā)。

為了避免這種情況，我們可以設置參數(shù)channel.basicQos(1)

// 設置不公平分發(fā) int prefetchCount = 1; channel.basicQos(prefetchCount);

總結(jié)

以上是生活随笔為你收集整理的RabbitMQ不公平分发的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。