zoukankan      html  css  js  c++  java
  • RabbitMQ 均衡调度(公平分发机制)

    均衡调度是针对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();
         }
    }
  • 相关阅读:
    v-cloak
    MVVM
    初识ajax
    装瓶学习法
    回调函数(call back)
    如何让学习变得纯粹?
    异步
    grep用法
    Shell中的&&与||的区别
    shell中使用>/dev/null 2>&1 丢弃信息
  • 原文地址:https://www.cnblogs.com/williamwsj/p/8109808.html
Copyright © 2011-2022 走看看