Chiamare un attore in un percorso Spray e attendere la risposta dell'attore

Question

Dopo aver utilizzato Play! Quadro per un po ', sto dando un primo sguardo a Spray. Ho iniziato da un campione che ho trovato su GitHub, ora voglio modificarlo ma non è facile per me capire come funziona.

Come posso attendere un messaggio da un attore nel codice qui sotto?

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 si basa già su akka.io

Quindi, se si desidera solo per completare il percorso con la risposta attore, è possibile utilizzare chiedere modello

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] 

Se si desidera inoltrare richiede al tuo modello di attore e completare la rotta da qualche parte nel sistema degli attori, devi inoltrare RequestContext agli attori. Forse, questo example potrebbe aiutarti. In bocca al lupo!

Answer 2

Dai un'occhiata al mio esempio di progetto. This service utilizza Futures per completare le rotte. Come ha commentato Rup, è una cattiva pratica aspettare una risposta. Restituisci un futuro immediatamente e fallo completare quando ottiene un risultato.

Nell'esempio classifier ! cm si utilizza il pattern "tell" dell'attore. Invia un messaggio cm all'attore classifier e si sposta su. Se vuoi aspettarti una risposta in futuro usa il modello "chiedi": classifier ? cm. Nel tuo metodo di ricezione dell'attore cm restituirai un futuro con sender ! responseMsg che tornerà in futuro.