Wywołanie aktora na trasie natrysku i oczekiwanie na odpowiedź aktora

Question

Po użyciu Play! Ramy na chwilę spoglądam na Spray. Zacząłem od próbki, którą znalazłem na GitHub, teraz chcę ją zmodyfikować, ale nie jest mi łatwo zrozumieć, jak to działa.

Jak mogę czekać na wiadomość od aktora w poniższym kodzie?

package api 

import akka.actor.ActorRef 
import scala.concurrent.ExecutionContext 
import spray.routing.Directives 
import core.ClassifierActor 

class ClassifierService(classifier: ActorRef)(implicit executionContext: ExecutionContext) 
    extends Directives with DefaultJsonFormats { 

    import ClassifierActor._ 

    implicit val classifyMessageFormat = jsonFormat4(ClassifyMessage) 

    val route = 
    path("classify") { 
     post { 
     handleWith { 
      // The ClassifierActor gets a ClassifyMessage and 
      // sends a ClassifiedMessage back to the sender. 
      // How can wait for the ClassifiedMessage here 
      // and send a HttpResponse back? 
      cm: ClassifyMessage => classifier ! cm 
      // ??? 
     } 
     } 
    } 

} 

Answer 1

Spray opiera się już na akka.io

Tak więc, jeśli chcesz, żeby zakończyć swoją trasę z odpowiedzią aktora, można użyć zapytać wzorzec

import akka.pattern.ask 
import scala.concurrent.duration._ 
implicit val timeout = Timeout(5 seconds) // needed for `?` below 

val route = 
    path("classify") { 
     post { 
     onComplete(actorResponse(yourActor, yourMessage)) { 
      complete(_) 
     } 
     } 
    } 

def actorResponse[T](actor: ActorRef, msg: ClassifyMessage): Future[T] = 
(actor ? msg).mapTo[T] 

Jeśli chcesz przekazać Żądaj od swojego aktora modelu i kompletnej trasy gdzieś w systemie aktorskim, musisz przekazać RequestContext do aktorów. Być może ten example może ci pomóc. Powodzenia!

Answer 2

Spójrz na mój przykładowy projekt. This service używa kontraktów Futures do uzupełniania tras. Jak komentował Rup, zła praktyka czeka na odpowiedź. Oddaj natychmiast przyszłość i pozwól jej zakończyć, gdy uzyska wynik.

W twoim przykładzie classifier ! cm używa wzoru aktora "tell". Wysyła wiadomość cm do aktora classifier i przechodzi dalej. Jeśli chcesz oczekiwać odpowiedzi w przyszłości, użyj wzoru "ask": classifier ? cm. W twojej metodzie otrzymywania aktora cm będziesz zwracał przyszłość z sender ! responseMsg, która powróci w przyszłości.