java - 如何对 Akka actor 系统进行阻塞/同步调用？

Question

Akka 2.4.1 Java API 此处。我现在没有足够的资源来学习 Scala，所以我要求这里的代码示例也使用 Java API。

我有一个现有的ActorSystem，它充满了异步 Actor ，而且工作得很好。我现在需要在同步上下文中重用这个 Actor 系统，如下所示:

// Groovy pseudo-code; NOT inside the actor system here!
ComputationRequest request = new ComputationRequest(1, 7, true)
MasterActor master = actorSystem.get(...)
ComputationResult result = actorSystem.tell(master, request)

在 Akka 的文档中，我没有看到将请求发送到 Actor 系统(从外部)然后检索结果的清晰示例。我可以在这里使用 Futures 吗？在 Akka(代码示例)中处理此模式的标准方法是什么？

Answer 1

有 ask模式做你想要的。它期望目标参与者通过告诉它getSender()来“返回”响应。您将获得一个 Future 响应并可以使用它(如果必须的话，可以阻止)。

import akka.dispatch.*;
import scala.concurrent.ExecutionContext;
import scala.concurrent.Future;
import scala.concurrent.Await;
import scala.concurrent.Promise;
import akka.util.Timeout;


ComputationRequest request = new ComputationRequest(1, 7, true);
MasterActor master = actorSystem.get(...);

Timeout timeout = new Timeout(Duration.create(5, "seconds"));
Future<Object> future = Patterns.ask(master, request, timeout);
ComputationResult result = (ComputationResult) Await.result(future, timeout.duration());