activemq记录生产者排队和消费者出列的消息
我们使用activemq作为Java独立应用程序的消息队列。我的问题是，基于activemq web控制台，队列有一定数量的消息排队和出列。但是，根据我在代码中添加的sysout语句，应用程序消耗的消息数似乎少于activemq web控制台上显示的消息数。例如，在activemq控制台上，没有。排队和出列的消息约为1800条。但是，在控制台上显示的出列消息数（我每接收一条消息就增加一个计数器）只有大约1700条。
我真的不知道大约在哪里。100条信息发送了。因此，我在想，如果我知道如何让activemq记录生产者排队和消费者出队的消息，也许我会有一些想法。这可能吗？如果是，如何做到这一点？
共有1个答案
加入队列==自上次重启后放入队列的消息数退出队列==消费者成功处理的消息数这两个数字的差==正在运行的消息数，通常由“分派”计数器跟踪。“在飞行中”的意思是发送给消费者，但还没有被ACK。
-
本教程演示了如何发送和接收来自Spring Kafka的消息。 首先创建一个能够发送消息给Kafka主题的Spring Kafka Producer。 接下来，我们创建一个Spring Kafka Consumer，它可以收听发送给Kafka主题的消息。使用适当的键/值序列化器和解串器来配置它们。 最后用一个简单的Spring Boot应用程序演示应用程序。 下载并安装Apache Kafka 要
-
我有一个使用ActiveMQ的消息队列。web请求用persistency=true将消息放入队列。现在，我有两个消费者，它们都作为单独的会话连接到这个队列。使用者1总是确认消息，但使用者2从不这样做。 JMS队列实现负载平衡器语义。一条消息将被一个使用者接收。如果在发送消息时没有可用的使用者，它将被保留，直到有可以处理消息的使用者可用为止。如果使用者接收到一条消息，但在关闭之前没有确认它，那么该
-
问题内容： 我想创建某种线程应用程序。但是我不确定在两者之间实现队列的最佳方法是什么。 因此，我提出了两个想法（这两个想法可能都是完全错误的）。我想知道哪种更好，如果它们都烂了，那么实现队列的最佳方法是什么。我关心的主要是这些示例中队列的实现。我正在扩展一个内部类的Queue类，它是线程安全的。下面是两个示例，每个示例有4个类。 主班 消费阶层 生产者类别 队列类 要么 主班 消费阶层 生产者类别
-
我最近开始使用消息队列（使用ActiveMQ)，并进行了试验。 null 谢谢你的建议，
-
生产者线程与消费者线程使用信号量同步 生产者线程与消费者线程使用信号量同步 源码/* * Copyright (c) 2006-2018, RT-Thread Development Team * * SPDX-License-Identifier: Apache-2.0 * * Change Logs: * Date Author Notes * 2018-08-24 yangjie the f
-
所谓的生产者消费者模型就是 某个模块（函数）负责生产数据，这些数据由另一个模块来负责处理 一般生产者消费者模型包含三个部分 生产者、缓冲区、消费者 为什么生产者消费者模型要含三个部分？直接生产和消费不行么？ 一个案例说明一切 生产者好比现实生活中的某个人 缓冲区好比现实生活中的邮箱 消费者好比现实生活中的邮递员 如果只有生产者和消费者, 那么相当于只有写信的人和邮递员，那么如果将来过去的邮递员离职