php - php-amqplib 循环，而只有消息

Question

有一个演示消费者：

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

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();
}