相关问题:使用 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 中获取这个数量的缓存消息?