RabbitMQ新消费者挂起

Question

我使用的是rabbitmq 3.6.6，使用的是对接者图像"rabbitmq:3“

每当我向我的RabbitMQ队列中添加一个新的使用者时，它就会挂起10秒到10秒，10小时。

下面是用于获取错误的代码示例。我在Go中也会出现这个错误。所以不是依赖图书馆的人。

<?php

include(__DIR__."/vendor/autoload.php");
print "Start" . PHP_EOL;
$connection = new \PhpAmqpLib\Connection\AMQPStreamConnection('xxxx', 5697, 'guest', 'guest');
$channel = $connection->channel();

$callback = function($msg) {
  echo " [x] Received ", $msg->body, "\n";
};

$channel->basic_consume('repositories', '', false, false, false, false, $callback);

while(count($channel->callbacks)) {
    $channel->wait();
}

当我看到原木时

=INFO REPORT==== 31-Jan-2017::21:14:33 ===
accepting AMQP connection <0.891.0> (10.32.0.1:54216 -> 10.44.0.3:5672)
=INFO REPORT==== 31-Jan-2017::21:14:34 ===
accepting AMQP connection <0.902.0> (10.32.0.1:54247 -> 10.44.0.3:5672)

当我在通过rabbitmqctl执行list_consumer时，我在列表中看到了消费者，但是它没有处理任何消息。

Answer 1

结果，我需要设置Qos设置。

更多信息可在以下网址查阅：

• http://www.rabbitmq.com/consumer-prefetch.html
• https://github.com/streadway/amqp/blob/master/channel.go#L576