在RabbitMQ中，有办法查看队列内容而不执行出队操作吗？

Question

为了学习RabbitMQ和Python，我正在做一个项目，目的是在多台电脑之间分发h264编码。基本的功能已经完成，我在Linux或Mac上运行了一个守护进程，它会连接到队列，接受任务，然后使用HandBrakeCLI进行编码，编码完成后会确认消息。我还制作了一个简单的工具，可以将项目推送到队列中。

现在我想扩展这个推送工具的功能，让我能够查看队列中的内容。我知道可以看到队列里有多少个项目，但我想获取实际的消息，以便显示哪些电影或电视节目还在等待编码。我的想法是，队列管理器会在编码客户端完成任务后接收消息，然后刷新队列列表。

我知道有一种复杂的方法可以让队列管理器的列表与实际的工作队列保持同步，但我希望这个功能是“持久”的，也就是说，我应该能够关闭队列管理器，然后再打开它时还能看到队列的内容。

Answer 1

你想做的事情叫做浏览队列，不过我从这个链接了解到，RabbitMQ 目前还不支持这个功能。

Answer 2

@MichaelDillon 根据你的回答，为了让其他人更方便，我在这里放一个没有确认的例子：

#!/usr/bin/env python
import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='Q.hello')


def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)
    # ch.basic_ack(delivery_tag=method.delivery_tag)

channel.basic_consume(callback, queue='Q.hello')

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

Answer 3

队列浏览并不是直接支持的功能，但如果你创建一个没有自动确认的队列，并且不确认你收到的消息，那么你就可以看到队列里的所有内容。在你查看完之后，可以在通道上发送一个取消命令，或者断开连接再重新连接，这样所有的消息就会被重新放回队列。虽然这样会让消息头里的一个数字增加，但其他内容不会受到影响。

我曾经做过一个应用，消息的顺序并不是特别重要，所以我经常用这种方式查看队列。如果我发现了问题，就会把消息导出到一个文件里，修复后再提交。

如果你只是偶尔想看看一两条消息，可以使用RabbitMQ的管理插件来实现。

另外，如果你只需要知道消息的数量，每次声明队列时或者使用基本的获取命令时都可以得到这个信息。