Akka-ActorRef。tell（）需要几分钟来传递消息

Question

我有两个演员。每个参与者都位于不同的ActorSystem中。第一个缓存第二个ActorRef。第一个演员：

actorRef.tell(msg, self())

并向第二个参与者发送消息，第二个参与者使用

getSender().tell(reply, self())

问题：从第一个演员到第二个演员的最初讲述（）有时需要1-3分钟（！）传递信息。

除了这个消息之外，没有其他消息在Akka中发送，这意味着邮箱是空的-系统正在为单个请求提供服务。

系统详情：

该应用程序有500个计划的参与者，他们每30秒（阻塞）轮询Amazon SQS并发出请求（SQS为空）。还有330名演员在我的剧本中什么都不做。所有参与者都配置了默认的Akka调度程序。

Box是Amazon EC2实例，具有2个内核和8gb RAM。CPU和RAM利用率为

最初的猜测是CPU饥饿和太多线程的上下文切换。但是在我的i7机器上无法本地复制，即使有x10个参与者，使用75%的可用RAM。

我如何才能真正找到这个问题的原因？有没有可能对Akka基础设施进行分析，看看是什么让这条信息在从一个参与者到另一个参与者的过程中花费了这么多时间？

Answer 1

来自太多线程的上下文切换可能是此问题的根源。为了修复它，添加了以下配置：

actor {
default-dispatcher {
executor = "fork-join-executor"
fork-join-executor
{ parallelism-min = 8 parallelism-factor = 12.0 parallelism-max = 64 task-peeking-mode = "FIFO" }
}
}

因此，我们将每个物理核的线程数从6个增加到24个。24就足以让我们的应用程序顺利运行。回归试验期间未观察到饥饿。