java - 生产者入队和消费者出队的消息的 activemq 日志记录

Question

我们使用 activemq 作为 Java 独立应用程序的消息队列。我的问题是，基于 activemq Web 控制台，队列有一定数量的消息入队和出队。但是，根据我在代码中添加的 sysout 语句，似乎应用程序消耗的消息数量少于 activemq Web 控制台上显示的消息数量。例如，在 activemq 控制台上，没有。入队和出队的消息数约为 1800。但是，控制台上显示的出队消息数（我每收到一条消息增加一个计数器）仅为 1700 左右。

我真的不知道大约在哪里。100 条消息去了。所以我在想，如果我知道如何让 activemq 记录由生产者排队并由消费者出列的消息，我可能会有一些想法。这可能吗？如果是，如何做到这一点？

Answer 1

enqueued == 自上次重启后放入队列的消息数量 dequeued == 消费者成功处理的消息数量 两个数字的差异 == 正在运行的消息数量，通常由“调度”计数器跟踪。“in-flight”表示已发送给消费者，但尚未确认。