Envoi d'un message sur le démarrage d'un acteur avec un émetteur réel (non temporaire) ActorRef?

Question

J'aimerais qu'un acteur envoie un message au démarrage et reçoive une réponse plus tard.

L'envoi du message depuis preStart génère une référence temporaire sender (car l'acteur n'a pas encore démarré?). Donc, la réponse sera probablement une lettre morte.

Des conseils seraient appréciés. Excuses si ma prémisse est mal informé - je suis nouveau à Akka.

Answer 1

Une approche est d'envoyer un message à self à preStart:

class MyActor extends Actor { 

    def preStart(): Unit = { 
    self ! CallService 
    } 

    def receive = { 
    case CallService => 
     (service ? ServiceRequest).mapTo[ServiceResponse].pipeTo(self) 
    case ServiceResponse => 
     // do something with the response 
    } 
} 

Comme décrit dans ce answer, si vous voulez que l'acteur pour envoyer le message avant qu'il traite tous les autres messages, vous pourriez stash les autres messages:

class MyActor extends Actor with Stash { 

    def preStart(): Unit = { 
    self ! CallService 
    } 

    def uninitialized: Receive = { 
    case CallService => 
     (service ? ServiceRequest).mapTo[ServiceResponse].pipeTo(self) 
     unstashAll() 
     context.become(initialized) 
    case _ => stash() // if we get a message other than CallService, stash it 
    } 

    def initialized: Receive = { 
    case ServiceResponse => 
     // do something with the response from the service 
    case ... 
    } 

    def receive = uninitialized 
} 

Answer 2

Votre prémisse est en effet pas correct: quand prédémarrage fonctionne l'acteur est déjà complètement démarré, il est self référence n'est jamais temporaire. Sans code, il est impossible de vous aider plus loin, cependant.

Answer 3

L'expéditeur doit toujours être considéré comme "temporaire" - cf. ce billet de blog, par exemple:

La règle est tout simplement refermera jamais sur la méthode de l'expéditeur dans un bloc de code qui est potentiellement exécuté dans un autre thread, comme une tâche planifiée ou un avenir. L'astuce consiste à capturer l'expéditeur actuel dans un val, comme illustré ci-dessous ...

- Closing Over An Akka Actor Sender In The Receive

Faites une copie de l'expéditeur, puis plus tard, lorsque vous êtes prêt à répondre, répondre à cette copie de l'acteurRef et non pas "expéditeur".