php-amqplib循环，但只有消息

Question

有一个demo消费者：

只要通道注册了回调，它就会循环

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

例如，问题是我需要从队列中获取不超过100条消息。例如，如果只有80，它应该只返回80并退出循环。

谢谢

Answer 1

下面的代码对你有用吗？

$callbacks = count($ch->callbacks);

for ($i = 0, $count = $callbacks < 100 ? $callbacks : 100; $i < $count; $i++) {
    $ch->wait();
}