1

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

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

4

1 回答 1

1

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

于 2013-11-06T17:08:49.753 回答