Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
我已经重构了一个播放应用程序中的大量电子邮件发送代码，以使用actor异步地执行此操作。当我需要发送电子邮件时，现在可以注入一个EmailActor，然后致电...
我不确定为群集分片配置Akka Actor，我不太确定的一件事是，是否可以为实体配置多个停止消息以正常关闭。例如，实体...
我正在使用Akka制作文件传输系统。我看文件已经有一段时间了。当前的进度状态是Actor2收到了Actor1发送的文件，并将其写入本地...
我想知道在Play后台Akka任务中使用异步服务（返回Future [OfResult]）的正确方法是什么。播放文档中没有关于此的信息，看来我不能只是...
Akka中的System Actor和User Actor有什么区别？
所以我可以使用actor系统创建许多actor。我还可以使用SpawnProtocol创建许多演员。这两种类型的参与者之间有什么区别。我能想到的是-我们得到...
如何从Akka客户端HttpResponse中解析json主体
我正在使用Akka的HTTP客户端库来请求json，并且我想使用Play Framework的play-json来解析json。在获得Akka的HttpResponse之后，我不知道如何从...
我通过Ask向演员发送不同的消息。超时时，我想提供一个默认值，该默认值对于询问参与者的消息是不同的。由于超时异常始终是...
当MyActor收到开始消息时，它将运行Akka流，并将接收到的每个项目发布到Akka事件流。 MyActor类（隐式系统：ActorSystem，实现：Materializer，ec：...
akka.persistence.typed.internal.JournalFailureException：恢复期间的异常。如何解决？
使用Akka持久性，我得到此异常：引起原因：akka.persistence.typed.internal.JournalFailureException：恢复期间的异常。最后已知序列号[0]。 PersistenceId [...
要求失败：未配置默认日志插件，请参阅'reference.conf'
我在与cassandra一起使用persistentActor期间遇到错误，我什至找不到问题所在，甚至我在应用程序.conf文件中将cassandra添加为日志错误[错误] [04/29/2020 14：55：57.517] [...] >
我正在使用akka群集，并尝试为不同的环境设置两个不同的配置。一个用于我的本地设置，其中我将使用种子节点启动应用程序。第二个用于我的...
我有一系列看起来像这样的路径； path（“ slides” / Segment）{segment => getFromDirectory（s“ $ {cfg.slidesDir} / $ segment”）}〜path（“ foo” / Segment）{segment => getFromDirectory（s“ $ {...
如何在集群启动时预启动实体？我已经找到了一种方法，但是我认为这不是正确的方法。它包括将StartEntity（entityId）消息发送到...
我正在尝试在Akka HTTP中创建一个HTTP请求，该请求将能够通过HTTP请求发送两个字符串“ string1”和“ string2”。我目前有以下代码可以处理简单的...
已知分派器线程负责执行参与者消息。使用吞吐量参数，我们可以定义no。由调度程序线程处理的消息，然后再移至另一个...
如何在运行时使用application.conf更改akka Actors日志级别
如何设置application.conf使其能够在运行时更改akka logLevel？我可以设置任何属性吗？我正在使用slf4j和logback作为后端。我刚刚设置了logback.xml：
Akka流：使用OverflowStrategy.fail（）模拟失败的流
我是Akka和Akka流的新手。我创建了一个虚拟流，并希望它以异常结束，因为我的map（）函数非常慢，并且我将缓冲区设置为1。所以我的问题分为两部分：为什么...
我如何使进程使用ActorOf创建Actor，并允许Actor ping父进程。我的目的是允许参与者将信号发送到其父进程（ActorSystem主线程）以调用...
为什么AKKA TypedActor类具有两个具有相同签名的方法？
在使用TypedActor.get（system）intellij拼写错误“歧义方法调用”时，此处系统的类型为ActorSystem。我在TypedActor类文件的反编译源代码中发现有两个...