java - 演员回复非演员

Question

我刚刚开始使用 AKKA，并且有一个关于非参与者代码如何与参与者代码对话的基本问题。

非参与者代码如何调用参与者并获得响应？我试过从非演员调用演员，Patterns.ask但这不起作用，因为演员没有可以回应的“发件人”。

那么我该怎么做呢？

Answer 1

这应该工作得很好。当您使用 时ask，将创建一个轻量级参与者（我相信由 a 表示PromiseActorRef）来表示发送者，以便可以发送回响应，该响应将完成Future通过ask. 一个小例子来展示这一点。首先是测试演员：

class TestActor extends UntypedActor{
  public TestActor(){

  }

  public void onReceive(Object msg){
    getContext().sender().tell("bar", getContext().self());
  }
}

然后将调用它的非参与者代码

import java.util.concurrent.TimeUnit;
import scala.concurrent.Await;
import scala.concurrent.Future;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.pattern.Patterns;
import akka.util.Timeout;

public class AskTest {

  public static void main(String[] args) throws Exception{
    ActorSystem sys = ActorSystem.apply("test");
    ActorRef ref = sys.actorOf(Props.create(TestActor.class), "mytest");        
    Timeout t = new Timeout(5, TimeUnit.SECONDS);
    Future<Object> fut = Patterns.ask(ref, "foo", t);
    String response = (String)Await.result(fut, t.duration());
    System.out.println(response);
  }
}