Dans l'acteur akka si le message est l'exception comment appeler le même pour peu de temps avec intervalle fixe entre eux

Question

J'ai une classe d'utilité à partir de laquelle j'appelle un service api. Si tout va bien j'obtiendrai la sortie désirée qui est dans le format de chaîne. Ainsi c'est le cas de succès. Mais il peut arriver que j'obtiens une erreur supposer 404 si le serveur est en panne. Dans de tels cas, je veux appeler cette API pour supposer 3 fois avec 1 seconde d'intervalle entre eux. Si dans ces trois tentatives j'obtiens le succès de l'Api alors je ne calmerai pas l'api et n'inscrirai pas le résultat, Ou si après 3 tentatives il jette toujours l'erreur alors je ne continuerai pas et juste noterai l'erreur. ma classe utilitaire

public class Utils { 

public void doOperation(String service_Url) throws Exception { 
    Object message= someFunction(service_Url);//this function is calling the service api 
    final ActorSystem system = ActorSystem.create("helloakka"); 
    final ActorRef akkaBot=system.actorOf(Props.create(MyUntypedActor.class), "akkaBot"); 
    akkaBot.tell(message, ActorRef.noSender()); 
} 

} 

Voici l'acteur

public class MyUntypedActor extends UntypedActor { 
    @Override 
    public void onReceive(Object message) { 
    if (message instanceof HTTPException) { 
     System.out.println(message); 
     //Here as it got exception.I want to call the actor 3 times with 1 second interval between them 
    } 
else if (message instanceof String) { 
     System.out.println(message); 
     getSender().tell(value, getSelf()); 
    } 
else { 
     unhandled(message); 
    } 
    } 
} 

L'objectif est de tester un api particulier fonctionne ou ne pas utiliser akka actor.If l'api retourne exception alors appel que api en utilisant 3 fois acteur avec un intervalle de 1 sec entre chaque appel.Si après 3 fois nous recevons toujours l'erreur, puis enregistrer l'erreur, si en réessayant, nous obtenons la sortie désirée puis enregistrez-le.

Je ne sais pas comment y parvenir en utilisant des acteurs Akka.Veuillez me guider si vous le savez.

Answer 1

Ce que vous demandez peut être accompli avec une légère modification de l'organisation de votre code. Il serait plus facile pour votre acteur d'effectuer toutes les requêtes plutôt que seulement les requêtes consécutives à un échec.

Vous allez tout d'abord besoin d'un moyen de représenter les échecs:

public class RequestFailure { 
    public String request; 
    public int count; 

    public RequestFailure(String r, int c) { 
    request = r; 
    count = c; 
    } 
} 

Cette classe peut alors être un type de message envoyé à votre acteur qui agira en conséquence:

public class MyUntypedActor extends UntypedActor { 
    public void onReceive(Object message) { 
    if(message instanceOf String) { 
     Object response = someFunction((String) message); 
     if(response instanceOf HTTPException) { 
     Thread.sleep(1000); 
     getSelf().tell(new RequestFailure((String) message, 1), getSender()); 
     } 
     else 
     getSender().tell(response, getSelf()) 
    } 
    else if(message instanceOf RequestFailure) { 
     RequestFailure rf = (RequestFailure) message; 
     if(rf.count <= 3) { 
     Object response = someFunction(rf.request); 
     if(response instanceOf HTTPException) { 
      Thread.sleep(1000); 
      getSelf().tell(new RequestFailure(rf.request, rf.count + 1), getSender(); 
     } 
     else 
      getSender().tell(response, getSelf()) 
     } 
     } 
     else 
     //FIXME : question doesn't specify what to return 
     //  if max count reached 
    } 
    } 
} 

alors vous Demander le Actor avec une demande String pour démarrer le processus.