ActorSystem.scheduler cesse de fonctionner après nombre d'événements

Question

j'ai un scala suivant snipet:

implicit val system = ActorSystem() 
implicit val materializer = ActorMaterializer() 
implicit val wsClient = AhcWSClient() 
import scala.concurrent.ExecutionContext.Implicits.global  

ActorSystem().scheduler.schedule(30.seconds, 5.minutes)(
{ 
    Logger.debug("5m tick") 
    /* more code */ 
} 

Il est une partie d'application domotique et il doit être exécuté à long terme pendant des mois entre le redémarrage.

En ce moment, il tiques toutes les 5 minutes, et produit un message d'enregistrement à la console et le fichier. Il y a aussi une méthode très simple qui fonctionne sous l'appel de Logger, mais il n'y a pas d'erreur.

Le problème est, après ~ 2-3 jours, les arrêts tic-tac. J'ai re-exécuté l'application plusieurs fois et il semble s'arrêter sans erreur, après cette période de temps. Je n'ai pas trouvé d'aide en ligne, alors j'espère que certains d'entre vous ont déjà rencontré le même problème et connaissent la réponse.

Merci,

Martin

Answer 1

je ne peux pas vraiment dire ce que la question est que vous avez, mais pour le rendre plus transparent pour le débogage, vous pouvez utiliser une autre approche.

Utiliser un acteur à la place qui utilise scheduleOnce pour programmer un message à lui-même au lieu d'utiliser le schedule normal:

def receive: Unit = { 
    case "tick" => 
     Logger.debug("5m tick") 
     context.system.scheduler.scheduleOnce(5.minutes, self, "tick") 
} 

Dans le parent de cet acteur, vous pouvez utiliser la directive de surveillance Restart, donc dans le cas où l'acteur s'arrête, il est juste redémarré.

Une autre option serait de se pencher sur la Quartz-Scheduler qui est un peu plus large pour de longues tâches en cours d'exécution (et spécifiquement écrit pour ce contrairement à Akka)