scala – 如何配置Akka应用程序？

发布时间：2020-12-16 09:41:34 所属栏目：安全来源：网络整理

导读：我有一个小的Akka应用程序，它在其演员之间传递许多消息，每个演员对其接收到的数据进行一些计算。我想要的是分析这个应用程序，以便查看代码的哪些部分占用大部分时间等等。我尝试过VisualVM，但我真的不明白发生了什么。我添加了分析器输出的图片。我的

我有一个小的Akka应用程序，它在其演员之间传递许多消息，每个演员对其接收到的数据进行一些计算。我想要的是分析这个应用程序，以便查看代码的哪些部分占用大部分时间等等。

我尝试过VisualVM，但我真的不明白发生了什么。我添加了分析器输出的图片。

我的问题是

>这是第一行，为什么要占用这么多时间？ (scala.concurrent.forkjoin.ForkJoinPool.scan())
> Akka应用程序可以根据异步行为来分析吗？
>我可以看到一个具体的actor(-type)对于它接收到的一个特定消息(-type)有多长时间？
>还有其他最佳做法来分析Akka应用程序？

解决方法

>默认情况下，没有配置数据包，这是他们在scala.concurrent.forkjoin.ForkJoinPool.scan()的配置文件中记录的时间。如果所有隐藏的包都被允许进行采样，那么真正的CPU时间消费者将被揭示。例如，以下之前/之后的说明性配置文件揭示了线程在大部分时间被sun.misc.Unsafe.park等待脱机。

before

after

> Akka应用程序可以通过适当的仪器和通话跟踪进行分析。 Google着名的 Dapper,a Large-Scale Distributed Systems Tracing Infrastructure论文详细说明了该技术。 Twitter基于此创建了 Zipkin。它是开源的，具有 extension for distributed tracing of Akka.遵循 wiki，以了解如何设置一个允许

trace call hierarchies inside an actor system;

debug request processing pipelines (you can log to traces,annotate them with custom key-value pairs);

see dependencies between derived requests and their contribution to resulting response time;

find and analyse slowest requests in your system.

还有一个新的孩子在块，Kamon.它是一个反应友好的工具包，用于监视运行在JVM之上的应用程序，这是特别热衷于使用Typesafe反应平台构建的应用程序。这肯定意味着对于Akka而言，集成是以kamon-akka和kamon-akka远程模块的形式提供的，它们带来了字节码仪器，用于收集指标并代表您执行自动跟踪上下文传播。浏览从Akka Integration Overview开始的文档，了解它可以做什么以及如何实现。

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!