Quel est le moyen de fermer le client distant akka

Question

Si je désactive la ligne A, l'application HelloRemote ne peut pas recevoir le message "bonjour monde", il semble que si nous fermons trop vite le système d'acteur local, le message ne sera pas envoyé à distance?

Bien sûr, l'acteur local pourrait attendre un message de la part de la télécommande pour confirmer le message déjà reçu, mais si nous ajoutons un tel code, le processus sera synchrone, je ne veux pas que ça devienne RPC.

Je veux juste le rendre asynchrone, et aussi ne veux pas perdre de temps par "Thread.sleep (3000)", je veux que le client quitte le plus vite possible, une suggestion?

HelloRemote.scala

package remote 

import akka.actor._ 

object HelloRemote extends App { 
    val system = ActorSystem("HelloRemoteSystem") 
    val remoteActor = system.actorOf(Props[RemoteActor], name = "RemoteActor") 
} 

class RemoteActor extends Actor { 
    def receive = { 
    case msg: String => 
     println(s"received message '$msg'") 
    } 
} 

Local.scala

package local 

import akka.actor._ 

object Local extends App { 
    val system = ActorSystem("LocalSystem") 
    val localActor = system.actorOf(Props[LocalActor], name = "LocalActor") 
    localActor ! "START" 
} 

class LocalActor extends Actor { 
    val remote = context.actorSelection(
    "akka.tcp://HelloRemoteSystem@127.0.0.1:5150/user/RemoteActor") 

    def receive = { 
    case "START" => 
     remote ! "hello world" 
     Thread.sleep(3000) // Line A 
     context.stop(self) 
     context.system.shutdown 
    } 
} 

En outre, la pâte application.conf pour votre essai facile.

partie à distance:

akka { 
     actor { 
     provider = "akka.remote.RemoteActorRefProvider" 
     } 
     remote { 
     netty.tcp { 
      hostname = "127.0.0.1" 
      port = 5150 
     } 
     log-remote-lifecycle-events = off 
     } 
     log-dead-letters = off 
     log-dead-letters-during-shutdown = off 
    } 

partie locale:

akka { 
     actor { 
     provider = "akka.remote.RemoteActorRefProvider" 
     } 
     remote { 
     log-remote-lifecycle-events = off 
     } 
     log-dead-letters = off 
     log-dead-letters-during-shutdown = off 
    } 

Answer 1

Comme la chose plus simple, l'acteur distant peut renvoyer pilule empoisonnée au client local.

Comme ceci:

sender ! Kill 

vous pouvez lire ici http://doc.akka.io/docs/akka/snapshot/scala/actors.html#Killing_an_Actor

Ou vous pouvez choisir un certain message « secret » qui racontent votre acteur local de faire quelque chose avant de s'arrêter.

Exemple court. partie à distance:

class RemoteActor extends Actor { 
    def receive = { 
    case msg: String => 
       println(s"received message '$msg'") 
       sender ! "secretWord" 
    }  
} 

partie locale:

class LocalActor extends Actor { 
    val remote = context.actorSelection(
    "akka.tcp://HelloRemoteSystem@127.0.0.1:5150/user/RemoteActor") 

    def receive = { 
     case "START" => 
      remote ! "hello world" 
     case "secretWord" => 
     context.stop() 
    } 

    def postStop(): Unit = { 
    //do something here 
    } 
}