将来/尋ねることなくRemoteActorsを使用する

Question

私は、クライアント側のアクタからのメッセージを非同期的に（！）送って、サーバからアクタにメッセージを返したいと思っています。重要な点は、私は（？）を使用して未来を手に入れたくないということです。

私は次のコード例を持っている：

import akka.actor.Actor._ 
import akka.event.EventHandler 
import akka.actor.{ActorRef, Actor} 


case class FromUser(s: String) 

case class FromServer(s: String) 

class ServerActor extends Actor { 
    protected def receive = { 
    case FromUser(msg) => self.sender ! FromServer(msg) 
    } 
} 

class ClientActor(val remoteServer: ActorRef) extends Actor { 
    protected def receive = { 
    case FromUser(msg) => { 
     EventHandler.info(this, "I got '" + msg + "' from the user.") 
     remoteServer ! FromUser(msg) 
    } 
    case FromServer(msg) => EventHandler.info(this, "I got '" + msg + "' from the server.") 
    } 
} 

object Client { 
    def main(args: Array[String]) { 
    val s = Actor.remote.actorFor("ServerActor", "NYCWD2328", 4552) 
    val c = Actor.actorOf(new ClientActor(s)).start 
    c ! FromUser("Hello") 
    } 
} 

object Server { 
    def main(args: Array[String]) { 
    Actor.remote.start("NYCWD2328", 4552) 
    Actor.remote.register("ServerActor", actorOf(new ServerActor)) 
    } 

} 

このコードは、次のトレースで失敗します。それを行うことが可能であるべきであるように

[GENERIC] [11/9/11 12:32 PM] [RemoteClientWriteFailed(uuid { 
    high: 15711794799146701281 
    low: 10512246108465469656 
} 
actorInfo { 

    .... 

timeout: 5000 
} 
,java.nio.channels.ClosedChannelException,akka.remote.netty.NettyRemoteSupport@a1d1f4,/127.0.0.1:2552)] 
[GENERIC] [11/9/11 12:32 PM]  [RemoteClientError(java.nio.channels.ClosedChannelException,akka.remote.netty.NettyRemoteSupport@a1d1f4,/127.0.0.1:2552)] 
[ERROR] [11/9/11 12:32 PM] [akka:event-driven:dispatcher:global-3] [LocalActorRef] null 
java.nio.channels.ClosedChannelException 
    at org.jboss.netty.channel.socket.nio.NioWorker.cleanUpWriteBuffer(NioWorker.java:643) 

これがそうです。それは...ですか？

Answer 1

それは古い質問です、万全を期すためにヴィクトルはすでにそれに答えが、私は「応答なし」の状態を好きではないので、：mainメソッドが

object Client { 
    def main(args: Array[String]) { 
    // choose available port on local machine 
    Actor.remote.start("YourHostnameHere", 4553) 
    val s = Actor.remote.actorFor("ServerActor", "NYCWD2328", 4552) 
    val c = Actor.actorOf(new ClientActor(s)).start 
    c ! FromUser("Hello") 
    } 
} 

開始リモートサービスに変更する必要があります（ホストとポート）にはリモートマシンからアクセスできる必要があります。ここでは「NYCWD2328」です。そのリモートホストによって開始された新しい接続を介して返信が送信されるためです。