Buscando una implementación "at" escalable

Question

Estoy buscando un reemplazo "at" escalable, con alta disponibilidad. Debe admitir la adición y eliminación de trabajos en tiempo de ejecución.

Algunos antecedentes: Tengo una aplicación donde desencadenar millones de eventos, cada evento ocurre una sola vez. No necesito mecanismos tipo cron (primer domingo del mes, etc.), simplemente fecha, hora y contexto.

Actualmente estoy usando el Quartz scheduler, y si bien es un proyecto muy bueno, tiene dificultades para manejar la cantidad de eventos que le arrojamos, incluso después de un montón de ajustes (fragmentación, aumento del intervalo de sondeo, etc.) debido al bloqueo básico que realiza en la base de datos de subrayado. Además, es un poco exagerado para nosotros, ya que básicamente tenemos millones de desencadenantes de una sola vez y un número relativamente pequeño de trabajos.

lo agradecería cualquier sugerencia

Answer 1

Tal vez sólo tiene que utilizar JGroupsshared tree con tareas Según tiempo de ejecución. Los nodos tomarán la primera tarea y programarán el temporizador, que se ejecutará en un momento determinado. En la tarea, quitar el temporizador puede cancelarse. Así que, básicamente, puede usar solo JGroups y Timers/Executors simples de Java.

No he leído entero, pero aquí es un poco de proof of concept or maybe even solution

Answer 2

¿y el temporizador de Java?

import java.util.*; 

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

y luego

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

Si estaba enfrentando el mismo escenario que haría la siguiente ...

instalación de un clúster de cola JMS (por ejemplo RabbitMQ o ActiveMQ) usando una cola de replicación configurar en unas pocas cajas.

Dispare todos los eventos en mi agradable cola JMS altamente disponible.

Entonces me codificar una aplicación agente que hizo estallar los eventos de la cola JMS, según sea necesario, podría ejecutar múltiples agentes en múltiples cajas y he que combinada con la correcta JMS conmutación por error url etc.

También es posible usar el mismo tipo de modelo si sus puestos de trabajo están disparando los eventos ...

FYI, una manera más agradable de la programación en el núcleo de Java es la siguiente:

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);