`
m635674608
  • 浏览: 5028831 次
  • 性别: Icon_minigender_1
  • 来自: 南京
社区版块
存档分类
最新评论

activemq 控制面板里的 Number Of Pending Messages、 Messages Enqueued、Messages Dequeued含

    博客分类:
  • java
 
阅读更多



Number Of Consumers  消费者 这个是消费者端的消费者数量 

Number Of Pending Messages 等待消费的消息 这个是当前未出队列的数量。可以理解为总接收数-总出队列数 
Messages Enqueued 进入队列的消息  进入队列的总数量,包括出队列的。 这个数量只增不减 
Messages Dequeued 出了队列的消息  可以理解为是消费这消费掉的数量 
这个要分两种情况理解 
在queues里它和进入队列的总数量相等(因为一个消息只会被成功消费一次),如果暂时不等是因为消费者还没来得及消费。 
在 topics里 它因为多消费者从而导致数量会比入队列数高。 
简单的理解上面的意思就是 
当有一个消息进入这个队列时,等待消费的消息是1,进入队列的消息是1。 
当消息消费后,等待消费的消息是0,进入队列的消息是1,出队列的消息是1. 
在来一条消息时,等待消费的消息是1,进入队列的消息就是2. 


没有消费者时  Pending Messages   和 入队列数量一样 
有消费者消费的时候 Pedding会减少 出队列会增加 
到最后 就是 入队列和出队列的数量一样多 
以此类推,进入队列的消息和出队列的消息是池子,等待消费的消息是水流。

分享到:
评论

相关推荐

    1.6 Zabbix监控ActiveMQ1

    例如,绘制Pending消息、Consumers数量和Enqueued/Dequeued消息的图表,可以帮助我们更好地理解和优化ActiveMQ的性能。 总结来说,监控ActiveMQ的Zabbix配置涉及编写脚本、在Zabbix中添加监控项、设置触发器以及...

    activemq的简单配置

    - **Number of pending messages**:未处理的消息总数。 - **Number of consumers**:当前消费者的数量。 - **Messages enqueued**:已发送到队列的消息总数。 - **Messages dequeued**:已从队列中移除的消息...

    zabbix 3.4 监控 Activemq 自动发现模板

    用zabbix 自动发现实现activemq 监控pending consumers activemq_scan.sh #!/bin/bash activemq() { MQ_IP=(10.10.11.208:8161) for g in ${MQ_IP[@]} do port=($(curl -uadmin:admin http://${g}/admin/queues.jsp...

    ActiveMQ队列消息过期时间设置和自动清除解决方案.docx

    ActiveMQ 队列消息过期时间设置和自动清除解决方案 ActiveMQ 是一个开源的消息队列系统,用于实现分布式系统之间的异步通信。在使用 ActiveMQ 时,消息过期时间设置和自动清除是一个非常重要的问题。本文将介绍 ...

    BlazeDS+Spring+activeMQ outofmemory

    标题 "BlazeDS+Spring+activeMQ outofmemory" 指的是在使用BlazeDS、Spring和ActiveMQ集成的环境中遇到了内存溢出问题。BlazeDS是一个开放源码的服务器端技术,它允许双向通信,使Flex或AJAX客户端能够与Java后端...

    activeMQ收发工具.rar

    10. **安全配置**:理解ActiveMQ的安全模型,包括用户身份验证和权限控制,这对于企业级部署至关重要。 总之,这个"activeMQ收发工具.jar"是调试和测试ActiveMQ服务器的强大辅助工具,通过它,开发者可以深入理解...

    ActiveMQ In Action精简版

    ActiveMQ的配置主要包括连接器(Connectors)的设置、消息持久化(Persisting Messages)策略、安全性(Securing ActiveMQ)等方面。连接器用于定义客户端如何连接到ActiveMQ服务器,包括网络配置、安全认证等;消息持久化...

    activeMQ-activeMQ

    3. **高可用性**:ActiveMQ提供了多种机制来确保服务的高可用性,比如网络复制(Network of Brokers)、故障转移和镜像队列。这些特性确保了即使在单个服务器出现故障的情况下,消息传递也不会中断。 4. **消息持久...

    ActiveMQ in Action pdf英文版+源代码

    The book lays out the core of ActiveMQ in clear language, starting with the anatomy of a JMS message and moving quickly through connectors, message persistence, authentication and authorization....

    ActiveMQ 配置文件详解

    **ActiveMQ配置文件详解** Apache ActiveMQ 是一个开源的消息中间件,它实现了多种消息协议,如JMS(Java Message Service)和AMQP(Advanced Message Queuing Protocol),并且广泛应用于分布式系统中,提供可靠的...

    ActiveMQ

    7. **安全控制**:ActiveMQ 提供了基于角色的访问控制(Role-Based Access Control, RBAC),可以对用户和资源进行精细的权限管理。 **ActiveMQ 使用场景** 1. **解耦组件**:在大型系统中,通过 ActiveMQ 实现...

    activemq

    ### ActiveMQ-CPP 开发手册知识点详述 #### 一、引言 - **编写目的**:本手册旨在帮助开发者快速掌握 CMS (C++ Messaging Service) 的使用方法,提高 C++ 开发者在消息传递系统方面的开发效率,并作为 CMS 开发的...

    ActiveMQ客户端

    9. **安全性**:ActiveMQ支持基于角色的访问控制(RBAC)、SSL加密以及JAAS认证,保障了消息传递的安全性。 10. **性能优化**:ActiveMQ提供多种性能优化策略,例如预取(prefetching)技术,允许消费者在需要时...

    ActiveMQ的activemq.xml详细配置讲解

    **ActiveMQ的activemq.xml配置详解** ActiveMQ是Apache软件基金会开发的一个开源消息代理,它遵循Java消息服务(JMS)规范,提供可靠的消息传递功能。`activemq.xml`是ActiveMQ的核心配置文件,它定义了服务器的...

    activemq向android推送消息实例

    Log.d("ActiveMQ", "Connected to ActiveMQ with session ID: " + session); // 订阅主题或队列,例如 "/topic/messages" 或 "/queue/testQueue" stompClient.subscribe("/topic/messages", new ...

    activemq 通过ajax发送接收消息简单例子

    ActiveMQ是Apache软件基金会开发的一款开源消息中间件,它遵循开放消息传递协议(Open Message Broker Protocol,也称为AMQP)并支持多种协议,如STOMP、XMPP等。Ajax(Asynchronous JavaScript and XML)是一种在...

    activemq activeMq笔记

    ### ActiveMQ 概述 Apache ActiveMQ 是一款非常流行的开源消息中间件,它支持 Java 消息服务 (JMS) 标准,并提供了多种高级功能,例如持久化、集群、故障转移等。ActiveMQ 能够帮助开发者实现解耦、可靠的消息传输...

    apache-activemq-5.16.5

    Apache ActiveMQ是业界广泛使用的开源消息中间件,它基于Java消息服务(JMS)标准,提供了高度可扩展、可靠的异步通信能力。标题"apache-activemq-5.16.5"指的是该软件的一个特定版本,即5.16.5版本,通常每个新版本...

    apache-activemq Linux版本

    Apache ActiveMQ是业界广泛使用的开源消息中间件,尤其在Linux环境下表现出色。它基于Java语言开发,遵循Apache软件基金会的许可证,并且实现了多种消息传递协议,包括OpenWire、STOMP、AMQP和XMPP等。在Linux系统上...

Global site tag (gtag.js) - Google Analytics