找不到关键字为'akka.version'的配置设置。
我正在学习akka-remoting，这是我的项目结构 项目结构如下：project/pom.xml project/mymodule/pom.xml project/mymodule/src/main/resources/application.conf project/mymodule/...
通过Source.actorRef创建的akka stream Source访问底层ActorRef
我正在尝试使用Source.actorRef方法创建一个akka.stream.scaladsl.Source对象。类似以下形式的内容：import akka.stream.OverflowStrategy.fail import akka.stream.scaladsl.Source ca...
在Akka Actors中如何阻塞调用
作为一名新手，我正在努力理解演员是如何工作的。从文档中，我认为我理解了演员是在同步模式下执行的对象，并且演员执行可以包含阻塞/同步方法调用，例如数据库请求。 但我不明白的是，如果你编写一个包含某些阻塞调用（如阻塞查询执行）的演员，它会破坏整个线程池（从CPU利用率等方面来看），对吗？我的意思...
Akka中聚类和远程之间的区别
我已经使用了Akka在单个JVM上开发了我的应用程序。现在我想将工作负载分布到多台计算机上。我开始阅读文档并感到困惑。 有两种方式可以使Akka应用程序实现分布式，即集群和远程通信。我不理解这两者之间的区别。如果我理解正确，两者互相排斥，因为在配置中需要使用不同的提供程序来引用Actor： ...
如何将Map[A,Future[B]]转换成Future[Map[A,B]]？
我一直在使用Scala Akka库，并遇到了一些问题。正如标题所说，我需要将Map [A，Future [B]]转换为Future [Map [A，B]]。 我知道可以对类似List的可迭代对象使用Future.sequence ，但在这种情况下不起作用。 我想知道：在Scala中是否有一种...
在Akka中测试Actor
当我运行用于测试演员的基本示例时：class MySpec(_system: ActorSystem) extends TestKit(_system) with ImplicitSender with WordSpec with MustMatchers with BeforeAndAf...
创建Akka中的actors的成本是多少？
考虑这样一种情况，我正在使用 Akka 实现一个处理传入任务的系统。我有一个主要的 actor 接收任务并将它们分派给一些 worker actor 处理任务。 我的第一反应是通过调度程序为每个传入任务创建一个 actor。在 worker actor 处理任务后，actor 会被停止。 ...
如何使用Akka实现REST Web服务？
我打算采用纯Akka技术实现REST风格的Web API。我不确定是否使用spray框架，若好用我会考虑使用Scalatra。基本上，我想应用Scala Actor模型的并发优势，而不希望Servlet容器成为这一过程的障碍。 还有什么其他选项吗？ 更新1：哪一个前端更适合在Akka后端实...
Akka TypedActor和编写自己的静态接口到Actor类，哪个更好？
我已经使用Akka和Scala大约一个月了，对于用消息替换显式接口这一点我有些困惑。请看下面这个简单的Akka Actor：case class DoMyHomework() class Parent extends Actor { def receive = { case d: ...
Akka中的I/O是如何工作的？
当需要执行I/O操作（例如数据库操作）时，Akka中的actor模型如何工作？ 据我所知，阻塞操作将抛出异常（由于Netty的事件驱动特性，这将破坏所有并发性，Akka使用它）。因此，我必须使用Future或类似的方法 - 但我不理解并发模型。 一个actor可以同时处理多个消息吗？ 如...