.NET Core 使用RabbitMQ 之 Worker模式

RabbitMQ的Worker模式

Worker模式其实就是一对多模式,我们定义两个消费者来看看效果

默认情况下，RabbitMQ会顺序的将message发给下一个消费者。每个消费者会得到平均数量的message。这种方式称之为round-robin（轮询)..
但是很多情况下并不希望消息平均分配,而是要消费快的多消费,消费少的少消费.还有很多情况下一旦其中一个宕机,那么另外接收者的无法接收原本这个接收者所要接收的数据。
我们修改其中一个消费者代码,让其等待3秒。在等待中停止运行 看看效果

consumer.Received += (model, ea) =>
{
    Thread.Sleep(3000);
    byte[] message = ea.Body;
    Console.WriteLine("接收到消息为:" + Encoding.UTF8.GetString(message));
};

当消费者宕机后消费者1并没有接受宕机后的数据。所以我们需要消息确认来解决这个问题。

RabbitMQ消息确认

Rabbit中存在两种消息确认模式

• 自动模式 - 只要消息从队列获取,无论消费者获取到消息后是否成功消费,都认为是消息成功消费.

• 手动模式 - 消费从队列中获取消息后,服务器会将该消息处于不可用状态,等待消费者反馈。如果消费者在消费过程中出现异常，断开连接切没有发送应答，那么RabbitMQ会将这个消息重新投递。

修改两个消费者代码,并在其中一个中延迟确认。

consumer.Received += (model, ea) =>
{
    byte[] message = ea.Body;
    Console.WriteLine("接收到消息为:" + Encoding.UTF8.GetString(message));
    Thread.Sleep(3000); //等待三秒手动确认
    channel.BasicAck(ea.DeliveryTag, true);//返回消息确认
};
////将autoAck设置false 关闭自动确认.
channel.BasicConsume(name, false, consumer);

如果在延迟中消费者断开连接,那么RabbitMQ会重新投递未确认的消息

‘能者多劳’模式

能者多劳是给消费速度快的消费更多的消息.少的责消费少的消息.能者多劳是建立在手动确认基础上实现。
在延迟确认的消费中添加BasicQos

channel.QueueDeclare(
    queue: name,//消息队列名称
    durable: false,//是否持久化,true持久化,队列会保存磁盘,服务器重启时可以保证不丢失相关信息。
    exclusive: false,//是否排他,true排他的,如果一个队列声明为排他队列,该队列仅对首次声明它的连接可见,并在连接断开时自动删除.
    autoDelete: false,//是否自动删除。true是自动删除。自动删除的前提是：致少有一个消费者连接到这个队列，之后所有与这个队列连接的消费者都断开时,才会自动删除.
    arguments: null ////设置队列的一些其它参数
    );
//每次只能向消费者发送一条信息,再消费者未确认之前,不再向他发送信息
channel.BasicQos(0,1,false);

可以看出消费快的消费者接受了更多的消息,这就是能者多劳模式的体现