Spring Integration DSL在流之间收集度量
-> InboundFlow1 -> Transformer|
ActiveMQ Broker ->JMS InboundAdapter -> Router | -> OutboundFlow -> JMS OutboundAdapter
-> InboundFlow2 -> Transformer|
有什么方法可以从InboundAdapter到OutboundAdapter收集这样的度量：
- 每秒的消息量；
- 邮件总数；
- 分钟通过流传递时间；
- 通过流的最大传输时间；
- 通过流传递的平均时间；
- 错误消息的数量；
- 处理邮件的持续时间；
我尝试了使用MessageChannelMetrics提出的解决方案：
https://docs.Spring.io/Spring-Integration/reference/html/system-management-chapter.html#mgmt-channel-features https://github.com/Spring-projects/Spring-Integration-samples/tree/master/medire/monitoring Spring Integration Channel Statistics Metrics
但它们没有涵盖所需的功能。
共有1个答案
除了第一个和最后一个以外的一切都在；第一个可以导出；最后一个将意味着为每个消息捕获它，这将是昂贵的。
但是，Spring Integration 5.0.4现在除了这些标准度量之外还支持千分尺。
编辑
-
我最近遇到了亚马逊提出的一个面试问题，我无法找到一个优化的算法来解决这个问题： 给定一个输入数组，每个元素表示线塔的高度。每个塔的宽度为1。开始下雨了。塔之间收集了多少水？ 实例 另一个例子 起初我认为这可以通过库存跨度问题来解决(http://www.geeksforgeeks.org/the-stock-span-problem/)但我错了，所以如果有人能想出一个时间优化的算法来解决这个问题，
-
为了更好地理解新的流API，我试图转换一些旧代码，但我被困在这一个。 我似乎无法为它创建有效的收集器：
-
我想获取地图的值，找到min值，并为地图的每个条目构造一个新的CodesWitMinValue实例。我希望使用Java11个流，我可以在多行中使用多个流（一个用于min值，一个用于转换）来实现这一点。是否可以使用java 11流和收集器在单行中实现？谢谢。
-
有人能建议从节点集群收集指标的最佳模式吗（每个节点都是带有Java应用程序的Tomcat Docker容器）？ 我们计划使用ELK堆栈（ElasticSearch、Logstash、Kibana）作为可视化工具，但我们的问题是如何将指标交付给Kibana？ 我们使用DropWizard度量库，它提供每个实例的度量(量表、计时器、直方图)。 显然，应该收集每个实例的一些指标(例如，cpu、内存等..
-
我使用的是java 11，我有一个名为MyObject的对象列表，看起来像这样 我想使用流将这些对象收集到地图中 我试着用收集器来做。toMap（），但似乎不可能做到这一点 我的问题是可以制作一张地图吗
-
我已经在JDK 1.8上工作了几天，遇到了一些类似的代码： 现在，对于一直在使用流（）的人来说，它可能看起来既简单又干净，但我找不到实现方法的实际类。 当我说列表时，我有以下问题。流（）： 我从哪里获取？ 他们是如何在不实际“干扰”现有集合的情况下实现它的？（假设他们没有接触它们） 我确实试着浏览了java的文档。util。AbstractCollection和java。util。Abstract