均衡调度是针对Consumer来说的。现在有两个Consumer请求同一个队列的消息。RabbitMQ会将序号为奇数的消息发给第一个Consumer,会将序号为偶数的消息发送给第二个Consumer。如果第一个Consumer处理消息的时间需要很久,而第二个Consumer很快就处理完已经收到的消息,这样看来,第一个Consumer很忙,第二个Consumer很空闲,这就白白的浪费了系统资源。要是每个Consumer处理完一个消息后再去获取下一个消息,这是多么理想呀!针对这种情况,RabbitMQ也想到了。解决方法如下:
设置当前Consumer的预取数量为1个就行啦!
channel.BasicQos(0, //设置0 1, //预取数量设置为1个 false); //设置false
Consumer端整个代码如下:
var factory = new ConnectionFactory() { HostName = "localhost", UserName = "ty2017", Password = "123456",VirtualHost="log" }; using (var connection = factory.CreateConnection()) { using (var channel = connection.CreateModel()) { channel.QueueDeclare(queue: "q.log.info", durable: false, exclusive: false, autoDelete: false, arguments: null); //设置预取消息的数量为1个,消费完当前的消息后再去获取下一个消息 channel.BasicQos(0, 1, false); var consumer = new EventingBasicConsumer(channel); consumer.Received += (model, ea) => { var body = ea.Body; var message = Encoding.UTF8.GetString(body); Console.WriteLine(" {0}", message); channel.BasicAck(ea.DeliveryTag, false); }; channel.BasicConsume(queue: "q.log.info", noAck: false, consumer: consumer); Console.ReadLine(); } }