RabbitMQ的輪詢模式和公平分發
阿新 • • 發佈：2020-05-09
### 一、常用的訊息模式
我們在工作的使用中，經常會遇到多個消費者監聽同一個佇列的情況，模型如下圖所示：
當有多個消費者時，我們的訊息會被哪個消費者消費呢，我們又該如何均衡消費者消費資訊的多少呢；
主要有兩種模式：
1、輪詢模式的分發：一個消費者一條，按均分配；
2、公平分發：根據消費者的消費能力進行公平分發，處理快的處理的多，處理慢的處理的少；按勞分配；
### 二、輪詢模式（Round-Robin）
該模式接收訊息是當有多個消費者接入時，訊息的分配模式是一個消費者分配一條，直至訊息消費完成；
#### 2.1 生產者發訊息到佇列
```
public static void SendRoundRobinMessage()
{
try
{
var conn = GetConnection();
var channel = conn.CreateModel();
channel.QueueDeclare(QUEUE_NAME, false, false, false, null);
for(var i = 0; i < 50; i++)
{
var body = Encoding.UTF8.GetBytes(i.ToString());
channel.BasicPublish("", QUEUE_NAME, null, body);
}
Console.WriteLine("訊息傳送完成！");
channel.Close();
conn.Close();
}
catch (Exception ex)
{
throw ex;
}
}
```
#### 2.2 消費者1程式碼
消費者1每處理完一次訊息，執行緒休息1秒；
```
///
/// 輪詢分發消費者1
///
static void SimpleConsumer1()
{
//new rabbitMqTest.RabbitMQ.MQUtils().GetMessage();
//建立連線工廠
ConnectionFactory factory = new ConnectionFactory
{
UserName = "admin",//使用者名稱
Password = "admin",//密碼
HostName = "127.0.0.1"//rabbitmq ip
};
//建立連線
var connection = factory.CreateConnection();
//建立通道
var channel = connection.CreateModel();
//事件基本消費者
EventingBasicConsumer consumer = new EventingBasicConsumer(channel);
//接收到訊息事件
consumer.Received += (ch, ea) =>
{
var message = Encoding.UTF8.GetString(ea.Body);
Console.WriteLine($"Simple Consumer1 收到訊息： {message}，時間{DateTime.Now}");
Thread.Sleep(1000);
//確認該訊息已被消費
//channel.BasicAck(ea.DeliveryTag, false);
};
//啟動消費者 設定為手動應答訊息
channel.BasicConsume("queue_test", true, consumer);
Console.WriteLine("Simple Consumer1 消費者已啟動");
Console.ReadKey();
channel.Dispose();
connection.Close();
}
```
消費者接收訊息如圖：
#### 2.3 消費者2程式碼
消費者2每處理完一次訊息，執行緒休息3秒；
```
///
/// 輪詢分發消費者2
///