如何理解 rabbitmqctl 命令的输出

Question

$rabbitmqctl list_queues

Timeout: 60.0 seconds ...
Listing queues for vhost / ...
privateTransactionQ 2
amq.gen-o9dl3Zj7HxS50gkTC2xbBQ  0
task_queue  0

rabbitmqctl 的输出如下所示。我无法弄清楚每列的含义。怎么看每一列的意思？

Answer 1

对此没有“简单”的解决方案，但我们是 IT 人员，我们可以构建它们。我不是 RabbitMQ 方面的专家，也不是编程方面的专家，但我会尽力给出一个好的答案，以防万一有人来到这里寻求帮助。

让我们以从 rabbitmqctl 控制台列出队列的确切情况为例。通过输入“rabbitmqctl”，您可以获得可用命令的列表：

Commands: 
[...]
list_queues [-p <vhost>] [--online] [--offline] [--local] [<queueinfoitem> ...] [-t <timeout>]
[...] 

假设您知道什么是虚拟主机和队列，假设您想列出虚拟主机“TEST”中的所有队列，那么您需要输入：

> rabbitmqctil list_queues -p TEST 
Timeout: 60.0 seconds ...
Listing queues for vhost TEST ...
test.queue 0

默认情况下，您只会获得队列的“名称”及其“当前深度”。 你在哪里找到队列的所有参数？请特别注意您首先键入的帮助说明中的“queueinfoitem”一词。如果您看到 rabbitmqctl 帮助说明（通过键入“rabbitmqctl”），在说明的末尾您可以看到参数“”的可用选项列表。

现在让我们看一个示例，您希望查看更高级的队列状态，例如：队列中的消息就绪、状态未确认的消息、消息 RAM、消费者、消费者的内存利用率、队列状态，当然还有， 其名称。

你是对的一件事：rabbitmqctl 不会以友好的方式返回结果。默认情况下，你会得到这个：

rabbitmqctl list_queues -p TEST  messages_ready, messages_unacknowledged, messages_ram, consumers, consumer_utilisation, state, name
Timeout: 60.0 seconds ...
Listing queues for vhost TEST ...
0       0       0       0               running test.queue

但只要有一点想象力，你就可以做到这一点：

----------------------------------------------------------
Msg. * Msg. * Msg. **       ** Cons. **         **** Name
Rdy * Unack * RAM *** Cons.  * Util. ** State    ***
----------------------------------------------------------
0       0       0       0               running     test.queue

这没什么大不了的，但比默认的要好。 我用一个小的 python 脚本实现了这一点：

import os
vhosts = os.popen("rabbitmqctl list_vhosts name").read() 
logging.info(vhosts)
vhosts = vhosts.split("\n",1)[1]
vhosts = vhosts[:-1]
vhosts = vhosts.split("\n")
for vhost in vhosts: 
    header_a = "Msg. * Msg. * Msg. **       ** Cons. **         **** Name\n" 
    header_b = "Rdy * Unack * RAM *** Cons.  * Util. ** State    ***     \n"
    dash = "----------------------------------------------------------\n"
    queues = os.popen("rabbitmqctl list_queues -p " + vhost + " messages_ready, messages_unacknowledged, messages_ram, consumers, consumer_utilisation, state, name").read() 
    queues = queues.split("\n",2)[2]
    queues_list = dash + header_a + header_b + dash + queues
    print(queues_list)

当然，这可以通过多种方式进行改进，并且总是欢迎批评，我仍然希望它对某人有所帮助。

干杯。