斯卡拉阿卡演員，問模式，發送答覆時遇到的死信

Question

我想發送一個請求，使用問模式的遠程演員。當地的演員會收到一些價值，並在它上面執行一些任務並更新它。 然後，當本地演員嘗試發送更新值給遠程演員時，發送時發生錯誤。我應該如何處理這個錯誤？

錯誤： [INFO] [2017年3月31日17：28：18.383] [ClientSystem-akka.actor.default-調度-3] [阿卡：// ClientSystem/deadLetters] 消息[check.package $ Rcvdcxt]從Actor [akka：// ClientSystem/user/localA1＃1050660737]發送給Actor [akka：// ClientSystem/deadLetters]未送達。 [1]遇到了死信。

Remote Actor: 

class RemoteActor() extends Actor { 

    def receive = { 


    case TaskFromLocal() =>{ 
     implicit val timeout: Timeout = 15000 
     val currentSender = sender 
     val f1 = currentSender ? RemoteActor.rtree.cxtA 
      f1.onComplete{ 
      case Success(Rcvdcxt(cxtA))=> 
       println("Success"+cxtA) 
      case Success(s) => 
        println("Success :"+s) 
      case Failure(ex) => 
        println("failure:"+ex) 
      } 
     } 


    case _ => println("unknown msg") 
    } 
} 
object RemoteActor{ 

    def createRndCxtC(count: Int):List[CxtC] = (for (i <- 1 to count) yield CxtC(Random.nextString(5), Random.nextInt())).toList 
    def createRndCxtB(count: Int): List[CxtB] = (for (i <- 1 to count) yield CxtB(createRndCxtC(count), Random.nextInt())).toList 
    def createRndCxtA(count: Int): List[CxtA] = (for (i <- 1 to count) yield CxtA(createRndCxtC(count), 5)).toList 
    var rtree = RCxt(createRndCxtA(1),createRndCxtB(2),1,"") 

    def main(args: Array[String]) {  
     val configFile = getClass.getClassLoader.getResource("remote_application.conf").getFile 
     val config = ConfigFactory.parseFile(new File(configFile)) 
     val system = ActorSystem("RemoteSystem" , config) 
     val remoteActor = system.actorOf(Props[RemoteActor], name="remote") 
     println("remote is ready") 
    } 
} 



Local Actor : 


class LocalActorA extends Actor{  

    @throws[Exception](classOf[Exception]) 
    val remoteActor = context.actorSelection("akka.tcp://RemoteSystem@127.0.0.1:5150/user/remote") 

    def receive = { 



    case TaskLA1(taskA) => { 

    implicit val timeout: Timeout = 15000 
     val rCxt = remoteActor ? TaskFromLocal() 
     val currentSender = sender 
     rCxt.onComplete{ 
      case Success(Rcvdcxt(cxtA))=> 
       println("Success"+cxtA) 
       println("Sender: "+ sender) 
       currentSender ! Rcvdcxt(cxtA) 

      case Success(s)=> 
       println("Got nothing from Remote"+s) 
       currentSender ! "Failuree" 

      case Failure(ex) => 
       println("Failure in getting remote") 
       currentSender ! "Failure" 
      } 
    } 
    } 
} 

object LocalActorA {  


    def createRndCxtC(count: Int):List[CxtC] = (for (i <- 1 to count) yield CxtC(Random.nextString(5), Random.nextInt())).toList 
    def createRndCxtB(count: Int): List[CxtB] = (for (i <- 1 to count) yield CxtB(createRndCxtC(count), Random.nextInt())).toList 
    def createRndCxtA(count: Int): List[CxtA] = (for (i <- 1 to count) yield CxtA(createRndCxtC(count), 3)).toList 
    var tree = RCxt(createRndCxtA(2),createRndCxtB(2),1,"") 

    def main(args: Array[String]) { 
    val configFile = getClass.getClassLoader.getResource("local_application.conf").getFile 
    val config = ConfigFactory.parseFile(new File(configFile)) 
    val system = ActorSystem("ClientSystem",config) 
    val localActorA1 = system.actorOf(Props[LocalActorA], name="localA1") 
    println("LocalActor A tree : "+tree) 
    localActorA1 ! TaskLA1(new DummySum()) 
    } 
} 

Answer 1

既然你沒有張貼所有的代碼，我真的不能告訴完全錯誤，但我最好的猜測是有關的事實，你在呼喚在LocalActor的onCompletesender。這是不安全的，應該不惜一切代價避免。相反，做遠程男主角類似的東西：

class LocalActor { 
    def receive = { 
    case TaskLA1(taskA) => 
     val currentSender = sender 
     rCxt.onComplete { 
     case Success(Rcvdcxt(cxtA))=> 
      currentSender ! Rcvdcxt(cxtA) 
      ... 
     } 
    } 
}