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 节 “队列管理操作”。