阻止Akka Actors中的呼叫

Question

作为一个新手，我正在努力理解演员是如何工作的。从文档中，我想我理解了actor是在同步模式下执行的对象，并且actor执行可以包含阻塞/sync方法调用，例如db请求

如果是这种情况，那么执行非阻塞/异步调用的推荐方法是什么呢？比方说一个web服务调用，它获取一些东西并在请求完成时向另一个参与者发送消息？我们是否应该简单地在actor中使用以下内容：

未来映射{response=>x！response.body}

这是正确的处理方式吗？

Answer 1

这实际上取决于用例。如果查询不需要序列化，那么您可以在将来执行查询，并将结果发送回发送方，如下所示：

import scala.concurrent.{ future, blocking}
import akka.pattern.pipe

val resFut = future {
  blocking {
    executeQuery()
  }
}

resFut pipeTo sender

您还可以专门为DB调用创建一个专用的调度程序，并使用路由器创建执行元。通过这种方式，您还可以轻松地限制并发DB请求的数量。