2

使用远程演员时，我有一个意外的行为。我有一个服务器和一个“客户端”。客户端向服务器参与者发送消息，服务器进行回复。当我使用'？操作员一切都按预期工作。我从服务器得到答案。

服务器：

class HelloWorldActor extends Actor {
  def receive = {
    case msg => self reply (msg + " World")
  }
}

object Server extends App{
  Actor.remote.start("localhost",2552);
  Actor.remote.register("hello-service",Actor.actorOf[HelloWorldActor])
}

客户端：

object Client extends App {
  // client code
  val actor = remote.actorFor(
    "hello-service", "localhost", 2552)
  val result = (actor ? "Hello").as[String]
  println(result)
}

现在我更改了代码，使客户成为演员，只对答案做出反应。但是，不是回复不会发送回客户端。相反，在服务器上创建了一个“ClientActor”实例并将回复发送到那里？

修改后的客户端：

class ClientActor extends Actor {
  def receive = {
    case "Ask" =>{
      val actor = remote.actorFor(
        "hello-service", "localhost", 2552)
      actor ! "Hello"
    }
    case response:String => println(response) // This executed on the server! That's not what I expect?
  }
}

object Client extends App {
  // client code
  val client = actorOf[ClientActor].start();
  client ! "Ask"
}

我错过了什么？这是 Akka 的预期行为吗？我怎样才能强迫它把答案发回给客户？

感谢您的任何意见。

4

1 回答 1

5

您尚未在客户端上启动远程处理。

于 2011-10-06T13:45:52.920 回答