Jak zaplanować globalne zadanie Akka na przestrzeni wielu procesów?

Question

Używam Akka w Play Framework zamiast Job, aby zaplanować uruchamianie kodu co X sekund. Mam coś w rodzaju gromady (działa na Heroku, obecnie na 1 dynie, ale czasami może zdarzyć się kilka równoległych instancji).

Czy istnieje prosty sposób, aby "zadanie" było uruchamiane co N sekund na całym świecie w całym klastrze? Wiem, że Quartz obsługuje mechanizmy pamięci/synchronizacji poza procesem, np. DB - czy mogę użyć czegoś podobnego w Scali?

Jest to konfiguracja aktor, który jest uruchamiany na początku gry:

object Global extends GlobalSettings { 

    override def onStart(app: Application) { 
    val monitorActor = Akka.system.actorOf(Props[MonitorLoadJob], name = "monitorLoad") 
    Akka.system.scheduler.schedule(0 seconds, 10 seconds, monitorActor, Tick) 
    } 
} 

Answer 1

Zapoznaj się z ClusterSingletonManager.

Dla niektórych przypadków użycia jest to wygodne, a niekiedy również obowiązkowe upewnić się, że masz dokładnie jeden aktor pewnego rodzaju systemem gdzieś w klastrze.

Kilka przykładów:

• jeden punkt odpowiedzialności za niektóre klastra całej konsekwentnych decyzji lub koordynacji działań w całym systemie klastra

To wymaga przeprowadzenia Akka Cluster ale to przewidzieć tego typu scenariusz.

Answer 2

Jedną z możliwości byłoby mieć aktora uruchomione na każdym węźle, który czeka na komunikat powiadamiania, aby rozpocząć tę pracę i od harmonogram wysyła wiadomość do tych aktorów.

Answer 3

Albo można użyć worker dyno dedykowany do pracy, przy użyciu standardowej metody main zaplanować swoją pracę w Akce.

Możesz sprawdzić this link (dla Java, ale dostaniesz pomysł na Scala).