AskTimeoutException : [5000 ms] 후에 시간 초과 요청

Question

REST API에 akka-http를 사용하고 AccountActors에 akka 액터를 사용하여 통화 거래 시스템을 구축하려고합니다.

post { 
    (path("accounts"/"move-money") & entity(as[MoveMoneyRequest])) { moveMoneyRequest => 

    complete(
     (bankActor ? moveMoneyRequest).map(x => MoveMoneyResponse("Money Transfer Successful!")) 
    ) 
    } 
} 

bankActor은 주요 애플 리케이션

val bankActor = mainActorSystem.actorOf(Props(classOf[BankingActor], accountService), name = "bankActor") 

내부 BankActor 내부에 생성되고, 우리는이 :

이

 def receive: Receive = LoggingReceive { 
    case req: MoveMoneyRequest => 
     val fromAcc = createAccountActor(Some(req.fromAccount)) 
     val toAcc = createAccountActor(Some(req.toAccount)) 

     fromAcc ? DebitAccount(req.tranferAmount) 
     become(awaitFrom(fromAcc, toAcc, req.tranferAmount, sender)) 

    } 


private def createAccountActor(accountNum: Option[String]): ActorRef = { 
    actorOf(Props(classOf[AccountActor], accountNum, accountService)) 
    } 

질문 : 지금, 최초의 API 호출마다, 그것은 성공이다 배우가 죽거나 셧다운 된 것 같아요? (ask)는 메시지가 receive 메소드에 도달하지 않기 때문에 액터를 찾지 않습니다. 요청 전화를 다른 것으로해야합니까? 선물을 다루는

Answer 1

올바른 지침은 예를 들어, docs에서

post { 
    (path("accounts"/"move-money") & entity(as[MoveMoneyRequest])) { moveMoneyRequest => 

    val fut = (bankActor ? moveMoneyRequest).map(x => MoveMoneyResponse("Money Transfer Successful!")) 

    onComplete(fut){ 
     case util.Success(_) => complete(StatusCodes.OK) 
     case util.Failure(ex) => complete(StatusCodes.InternalServerError) 
    } 
    } 
} 

자세한 내용 onComplete입니다.