Auf der Suche nach einer skalierbaren "at" Implementierung

Question

Ich bin auf der Suche nach einem skalierbaren "at" Ersatz, mit hoher Verfügbarkeit. Es muss das Hinzufügen und Entfernen von Jobs zur Laufzeit unterstützen.

Einige Hintergrund: Ich habe eine Anwendung, wo ich Millionen von Ereignissen auslösen, jedes Ereignis tritt nur einmal auf. Ich brauche keine cronähnlichen Mechanismen (erster Sonntag im Monat, etc.), einfach Datum, Zeit und Kontext.

Derzeit verwende ich die Quartz scheduler, und obwohl es ein sehr gutes Projekt ist, hat es Schwierigkeiten, die Menge der Ereignisse, die wir werfen, auch nach vielen Feinabstimmungen (Sharting, Erhöhung der Abfrageintervall, etc.)) aufgrund der Grundsperrung in der Unterstreichungsdatenbank ausgeführt wird. Außerdem ist es für uns etwas übertrieben, da wir im Grunde Millionen von Einmalauslösern und eine relativ kleine Anzahl von Jobs haben.

würde ich jeden Vorschlag

Answer 1

schätzen Vielleicht durch Ausführungszeit verwenden nur Aufgaben JGroupsshared tree mit sortiert. Die Knoten übernehmen die erste Aufgabe und planen den Timer, der zu gegebener Zeit ausgeführt wird. Ein Task-Entfernungs-Timer kann abgebrochen werden. Also im Grunde können Sie nur JGroups und einfache Java-Timer/Executors verwenden.

Ich habe es nicht gelesen ganze, aber hier ist einige proof of concept or maybe even solution

Answer 2

wie über die Java-Timer?

import java.util.*; 

public class MyTask extends TimerTask{ 
    public void run(){ 
     System.out.println("do it!"); 
    } 
} 

und dann

Timer timer = new Timer(); 

MyTask job1 = new MyTask(); 
// once after 2 seconds 
timer.schedule(job1, 2000); 

job1.cancel(); 

MyTask job2 = new MyTask(); 
// nach each 5 seconds after 1 second 
timer.schedule (job2, 1000, 5000); 

Answer 3

Wenn ich das gleiche Szenario mit Blick war ich folgende ...

-Setup eine JMS-Warteschlange Cluster (zB RabbitMQ oder ActiveMQ) unter Verwendung einer Warteschlange Replikation tun würde Setup über ein paar Boxen.

Feuer alle Ereignisse in meiner schönen hoch verfügbaren JMS-Warteschlange.

Dann würde ich einen Agenten Anwendungscode, der die Ereignisse der JMS-Warteschlange tauchte nach Bedarf, konnte ich mehrere Agenten auf mehreren Boxen laufen und haben, dass mit dem richtigen JMS-Failover-URL kombiniert usw.

Sie auch nutzen könnten die gleiche Art von Modell, wenn Ihre Jobs die Ereignisse feuern ...

Fyi, eine schönere Art und Weise der Planung in Kern Java ist wie folgt:

ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(sensibleThreadCount); 
    threadPool.scheduleAtFixedRate(new Runnable() { 

    @Override 
    public void run() { 
     //Pop events from event queue. 
     //Do some stuff with them. 
    } 

    }, initialDelay, period, TimeUnit.X);