Spring 集成渠道统计指标
Spring Integration Channel Statistics Metrics
我怎么没听懂 Spring-Integration Metrics 内容。我想要的是关于有多少 message/second 通过消息通道、最小和最大吞吐量是多少的统计输出。如果我使用 newTicketChannel.getSendRate()
,那么我将变成以下输出:
我清楚的是N
(消息数量)。对我来说意味着每秒处理的消息数量(?)。但是我完全不清楚 min
和 max
的值。我需要像 min=200, max=380 => 表示 200 是最后一分钟的最低速率,最后一分钟最大 380,或者类似的东西。
好的做法是什么?提前致谢。 :-)
min
和max
是自上次reset()
以来;如果您不重置,它们代表自应用程序启动以来的 min/max。
平均值是随时间和消息数量的指数移动平均值。
您必须定期 reset()
MessageChannelMetrics
才能获得新的 min/max。
同时为了获得我想要的结果,我做了以下操作:
想要的是
- Messages/Second
- 最大消息/秒
- 最少消息/秒
解决方案:
1/newTicketChannel.getSendDuration().getMean() * 1000
1/newTicketChannel.getSendDuration().getMin() * 1000
1/newTicketChannel.getSendDuration().getMax() * 1000
如果 spring 集成指标中有共同的功能可以得到相同的结果,请不要犹豫告诉我。有人提供有关我在问题中发布的值的平均值的信息会很酷。
感谢和干杯:-)
我怎么没听懂 Spring-Integration Metrics 内容。我想要的是关于有多少 message/second 通过消息通道、最小和最大吞吐量是多少的统计输出。如果我使用 newTicketChannel.getSendRate()
,那么我将变成以下输出:
我清楚的是N
(消息数量)。对我来说意味着每秒处理的消息数量(?)。但是我完全不清楚 min
和 max
的值。我需要像 min=200, max=380 => 表示 200 是最后一分钟的最低速率,最后一分钟最大 380,或者类似的东西。
好的做法是什么?提前致谢。 :-)
min
和max
是自上次reset()
以来;如果您不重置,它们代表自应用程序启动以来的 min/max。
平均值是随时间和消息数量的指数移动平均值。
您必须定期 reset()
MessageChannelMetrics
才能获得新的 min/max。
同时为了获得我想要的结果,我做了以下操作:
想要的是
- Messages/Second
- 最大消息/秒
- 最少消息/秒
解决方案:
1/newTicketChannel.getSendDuration().getMean() * 1000
1/newTicketChannel.getSendDuration().getMin() * 1000
1/newTicketChannel.getSendDuration().getMax() * 1000
如果 spring 集成指标中有共同的功能可以得到相同的结果,请不要犹豫告诉我。有人提供有关我在问题中发布的值的平均值的信息会很酷。
感谢和干杯:-)