1

我遇到了一个问题，设置basic.qos为1没有达到预期的效果 - 大量消息仍被推送给我的消费者。

我的代码看起来有点像这样： 

    Channel channel = getChannel("pollQueuePassive"); // from our own channel pool implementation

    try{
        channel.queueDeclarePassive(queue.name);
    } catch (IOException e){
        channel = getChannel("pollQueueActive");
        channel.queueDeclare(queue.name, true, false, false, null);
    }

    channel.basicQos(1);

    QueueingConsumer consumer = new QueueingConsumer(channel);
    channel.basicConsume(queue.name, autoAck, consumer);

    while (!stopPolling()) { 
        try{
              QueueingConsumer.Delivery delivery = consumer.nextDelivery();
              String message = new String(delivery.getBody());

              boolean workResult = doWork(message);
              if(!autoAck) {
                  if(workResult) 
                      channel.basicAck(delivery.getEnvelope().getDeliveryTag(), true);
                  else
                      channel.basicNack(delivery.getEnvelope().getDeliveryTag(), false, true);
              }

            } catch (InterruptedException e) {}
    }

    closeConnection();

一旦我开始以这种方式从队列中消费，队列中的所有消息（在某​​些情况下超过 20,000 条）几乎都会立即传递给消费者。由于我想将队列中的消息同时分发给几十个消费者，这种行为显然是不可取的。我一直在尝试移动我的basic.qos声明 - 包括在从我们的频道池中返回频道之前 - 无济于事。任何想法为什么不尊重预取大小？

谢谢！

4

1 回答 1

4

来自官方文档：

如果设置了 no-ack 选项，则忽略预取计数。

并且看起来您正在auto-ack为您的消费者使用标志。确保检查autoAck变量的值。

于 2013-08-16T06:01:53.377 回答