Что предлагает способ отключения удаленного клиента akka

Question

Если я отключу строку A, приложение HelloRemote не сможет получить сообщение «привет мир», похоже, если мы выключим локальную актерскую систему слишком быстро, сообщение не будет отправлено на удаленный?

Конечно, местный актер мог ждать сообщения от пульта, чтобы подтвердить уже полученное сообщение, но если мы добавим такой код, процесс будет синхронным, я не хочу, чтобы вещь стала чем-то вроде RPC.

Я просто хочу сделать его асинхронным, а также не хочу тратить время на «Thread.sleep (3000)», я хочу, чтобы клиент закрыл как можно скорее, какое-либо предложение?

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 
    } 
} 

Кроме того, паста application.conf для легкой попытки.

отдаленная часть:

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 
    } 

локальная часть:

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

Answer 1

В простейших вещах, удаленный актер может отправить обратно токсикологическую таблетку локального клиенту.

Как это:

sender ! Kill 

вы можете прочитать здесь http://doc.akka.io/docs/akka/snapshot/scala/actors.html#Killing_an_Actor

Или вы можете выбрать какое-то сообщение «секрет», что сказать местным актером, чтобы сделать что-то, прежде чем остановить себя.

Краткое описание. Удаленная часть:

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

Местная часть:

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 
    } 
}