1

相关问题:使用 PhpAmqpLib 从 rabbitmq 消费者回调中获取队列大小

在上述问题中,消息计数由 获得queue_declare。但是,此消息计数仅计算队列中的消息,而不是预取的消息(这正是该问题的发布者所经历的)

如果我将prefetch_count(in basic_qos) 设置为 1 并为每条消息发送 ack,则消息计数完美,但如果我将 设置prefetch_count为 10 并为每 5 条消息发送 ack,则消息计数将类似于100, 100, 100, 100, 100, 95, 95, 95, 95, 95, ...处理每条消息时.

我想要的是获取预取消息的数量并将它们相加,以便在处理每条消息时我将获得正确的消息计数,包括预取但处理的消息。

有没有办法在 php-amqplib 中获取这个数量的缓存消息?

4

0 回答 0