6.6. 使用消息计数器
您可以使用消息计数器获取一段时间内队列的信息。这有助于您识别很难看到的趋势。
例如,您可以使用消息计数器来确定如何随着时间的推移使用特定队列。您还可以使用管理 API 定期查询队列中的消息数量,但这不会显示队列实际使用的使用方式。队列中的消息数量可能会保持恒定,因为没有客户端在其上发送或接收消息,或者因为发送到队列的消息数量等于来自它的消息数量。在这两种情况下,队列中的消息数量都保持不变,即使它以非常不同的方式使用。
6.6.1. 消息计数器的类型
消息计数器提供有关代理队列的附加信息。
数量
- 从代理启动后添加到队列的消息总数。
countDelta
- 从上次消息计数器更新以来添加到队列的消息数量。
lastAckTimestamp
- 最后一次确认来自队列中消息的时间戳。
lastAddTimestamp
- 最后一次向队列添加消息的时间戳。
messageCount
- 队列中的当前消息数量。
messageCountDelta
-
从上次消息计数器更新以来从队列中添加/删除的消息总数。例如,如果
messageCountDelta
是-10
,则整个消息已从队列中删除 10 个消息。 udpateTimestamp
- 最后消息计数器更新的时间戳。
您还可以组合消息计数器来确定其他有意义的数据。例如,若要知道从上一次更新以来从队列中消耗了多少个消息,您可以从 countDelta
中减去 messageCountDelta
。
6.6.2. 启用消息计数器
消息计数器可能会对代理内存有小的影响,因此默认禁用它们。要使用消息计数器,您必须首先启用它们。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 启用消息计数器。
<message-counter-enabled>true</message-counter-enabled>
设置消息计数器历史记录和抽样周期。
<message-counter-max-day-history>7</message-counter-max-day-history> <message-counter-sample-period>60000</message-counter-sample-period>
message-counter-max-day-history
- 代理应存储队列指标的天数。默认值为 10 天。
message-counter-sample-period
- 代理应对其进行队列抽样(以毫秒为单位)来收集指标的频率。默认值为 10000 毫秒。
6.6.3. 检索消息计数器
您可以使用管理 API 来检索消息计数器。
先决条件
代理上必须启用消息计数器。
更多信息请参阅 第 6.6.2 节 “启用消息计数器”。
流程
使用管理 API 来检索消息计数器。
// Retrieve a connection to the broker's MBeanServer. MBeanServerConnection mbsc = ... JMSQueueControlMBean queueControl = (JMSQueueControl)MBeanServerInvocationHandler.newProxyInstance(mbsc, on, JMSQueueControl.class, false); // Message counters are retrieved as a JSON string. String counters = queueControl.listMessageCounter(); // Use the MessageCounterInfo helper class to manipulate message counters more easily. MessageCounterInfo messageCounter = MessageCounterInfo.fromJSON(counters); System.out.format("%s message(s) in the queue (since last sample: %s)\n", messageCounter.getMessageCount(), messageCounter.getMessageCountDelta());
其他资源
- 有关消息计数器的详情请参考 第 6.4.3 节 “队列管理操作”。