Python RabbitmqAdmin List Queues 命令不获取消息内容，尽管消息存在

Question

我正在学习rabbitMq，现在我想知道如何处理队列内容。

首先，我想用谷歌搜索这个问题并了解命令

python rabbitmqadmin list queues

我已经写了 2 个单独的应用程序。

寄件人：

@Autowired
private AmqpTemplate template;
...
for (int i = 0; i < 100; i++) {
template.convertAndSend("queue1", "message_" + i);
}

接收器：

@RabbitListener(queues = "queue1")
public void listenQueue1(String message, @Header(AmqpHeaders.DELIVERY_TAG) long tag) {
logger.info("Got message:[" + message + "]");
}

如果我一起运行这些应用程序 - 我在接收器端看到消息。

要查看队列中的消息，我决定停止receiver并运行sender

1. 我运行发件人
2. 执行python rabbitmqadmin list queues

并查看以下结果：

+-----------------+----------+
|      name       | messages |
+-----------------+----------+
| query-example-6 |          |
| queue1          |          |
| queue2          |          |
| queue3          |          |
| queue4          |          |
| queue5          |          |
| queue6          |          |
| queue7          |          |
| queue8          |          |
| queue9          |          |
+-----------------+----------+

3.然后我运行接收器并查看接收器接受消息的日志

您能否澄清为什么我在控制台中看不到消息的原因？

如何查看队列消息内容。

Answer 1

我不熟悉rabbitmq。

也许消息是"未确认的"？

例如 我发现我的队列有一条消息：

$ rabbitmqadmin list queues name node messages
+----------------------------+----------------+----------+
|            name            |      node      | messages |
+----------------------------+----------------+----------+
| my_queue_name              | rabbit@xx-2    | 1        |

但是当我运行"get"命令以显示其内容时，rabbitmq 告诉我"没有项目">

所以，我用这个命令查询它：

$ rabbitmqadmin list queues name node messages messages_ready messages_unacknowledged
+----------------------------+----------------+----------+----------------+-------------------------+
|            name            |      node      | messages | messages_ready | messages_unacknowledged |
+----------------------------+----------------+----------+----------------+-------------------------+
| my_queue_name              | rabbit@xxxxx-2 | 1        | 0              | 1                       |
+----------------------------+----------------+----------+----------------+-------------------------+

我不知道为什么。 只需重新启动RabbitMQ服务器，一切似乎都很好。