Акка акка всегда в ожидании будущего

Question

У меня есть следующий актер, как определено ниже, для «входа» пользователя.

object AuthenticationActor { 
    def props = Props[AuthenticationActor] 

    case class LoginUser(id: UUID) 
} 

class AuthenticationActor @Inject()(cache: CacheApi, userService: UserService) extends Actor{ 
    import AuthenticationActor._ 

    def receive = { 
    case LoginEmployee(id: UUID) => { 
     userService.getUserById(id).foreach { 
     case Some(e) => { 
      println("Logged user in") 
      val sessionId = UUID.randomUUID() 
      cache.set(sessionId.toString, e) 
      sender() ! Some(e, sessionId) 
     } 
     case None => println("No user was found") 
     } 
    } 
    } 
} 

Примечание: userService.getUserById возвращает Future[Option[User]]

И следующую очень упрощенно API кал к нему

class EmployeeController @Inject()(@Named("authentication-actor") authActor: ActorRef)(implicit ec: ExecutionContext) extends Controller { 

    override implicit val timeout: Timeout = 5.seconds 

    def login(id: UUID) = Action.async { implicit request => 
    (authActor ? LoginUser(id)).mapTo[Option[(User, UUID)]].map { 
     case Some(authInfo) => Ok("Authenticated").withSession(request.session + ("auth" -> authInfo._2.toString)) 
     case None => Forbidden("Not Authenticated") 
    } 
    } 
} 

Оба println вызовов будут выполняться, но login вызова будет всегда терпит неудачу говорит, что спросить, есть тайм-аут. Какие-либо предложения?

Answer 1

Когда вы делаете такую ​​вещь (доступ к отправителю в Future сек обратного вызова), вы должны хранить sender в val в Outter объеме при получении запроса, потому что это очень вероятно, изменится до Future завершается.

def receive = { 
    case LoginEmployee(id: UUID) => { 
     val recipient = sender 

     userService.getUserById(id).foreach { 
     case Some(e) => { 
      ... 
      recipient ! Some(e, sessionId) 
     } 
     ... 
     } 
    } 
    } 

Вы также никогда не отправляете результат, когда пользователь не был найден.

Что вы на самом деле должны делать здесь труба Future результат к sender

def receive = { 
    case LoginEmployee(id: UUID) => { 
    userService.getUserById(id) map { _.map { e => 
     val sessionId = UUID.randomUUID() 
     cache.set(sessionId.toString, e) 
     (e, sessionId) 
     } 
    } pipeTo sender 
    } 
} 

или с принтами

def receive = { 
    case LoginEmployee(id: UUID) => { 
    userService.getUserById(id) map { 
     case Some(e) => 
     println("logged user in") 
     val sessionId = UUID.randomUUID() 
     cache.set(sessionId.toString, e) 
     Some(e, sessionId) 
     case None => 
     println("user not found") 
     None 
    } pipeTo sender 
    } 
}