Ищете масштабируемую реализацию «на»

Question

Я ищу масштабируемую замену «на» с высокой доступностью. Он должен поддерживать добавление и удаление заданий во время выполнения.

Немного фона: У меня есть приложение, в котором я запускаю миллионы событий, каждое событие происходит только один раз. Мне не нужны механизмы типа cron (первое воскресенье месяца и т. Д.), Просто дата, время и контекст.

В настоящее время я использую Quartz scheduler, и хотя это очень хороший проект, у него есть трудности с обработкой количества событий, которые мы бросаем на него, даже после многократной настройки (осколки, увеличение интервала опроса и т. Д.).) из-за базовой блокировки, выполняемой в базе данных подчеркивания. Кроме того, для нас это немного утомительно, поскольку в основном у нас есть миллионы одноразовых триггеров и относительно небольшое количество рабочих мест.

Я ценю любое предложение

Answer 1

Может просто использовать JGroupsshared tree с задачами, отсортированных по времени выполнения. В узлах будет выполняться первая задача и таймер расписания, который будет выполняться в заданное время. На задачу удалить таймер можно отменить. Итак, вы можете использовать только JGroups и простые таймеры/исполнители Java.

я не читал ее целиком, но вот некоторые proof of concept or maybe even solution

Answer 2

как насчет таймера Java?

import java.util.*; 

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

, а затем

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

Если я сталкивался тот же сценарий, я бы сделать следующее ...

Настройка очереди кластера JMS (например, RabbitMQ или ActiveMQ) с использованием репликации очереди установите несколько ящиков.

Огонь всех событий в моей красивой высокодоступной очереди JMS.

Тогда я бы код приложения агента, который совал событие очереди JMS в случае необходимости, я мог запускать несколько агентов на нескольких коробках и что в сочетании с правильным JMS отказоустойчивого URL и т.д.

Вы также можете использовать тот же самый вид модели, если ваши рабочие места стрельбы события ...

Fyi, более приятный способ планирования в ядре Java выглядит следующим образом:

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