Нужен Java фреймворк с планировщиком заданий. На какие технологии обратить внимание?

Question

[Антон]

Понадобился функционал (в общих чертах):

• Сервис принимает сообщение, в сообщении есть поле - время обработки. Когда время наступило - сообщение должно быть обработано
  
• Scheduler с настройкой правил
  Ex1: выполнять какое-то действие каждый час с 9.00 - 18.00 по будням
  Ex2: выполнять какое-то действие каждый день в 20.00 (при недоступности данных - попытаться повторить действие через 15 минут)
  
  

Возможно есть какие-то открытые решения?
В данный момент присматриваюсь к Apache Camel, возможно там есть готовое решение?

Answer 1

[Никита]

Если не используется какой-то фреймворк типа спринга, в котором есть свои планировщики, то лучше кварца я еще ничего не знаю.
quartz-scheduler.org

Answer 2

[Evhen]

С помощью spring framework можно планировать задачи.

Над методом, который должен выполнится указываешь аннотацию @Scheduled(cron="...") в которой в cron-формате указываешь когда и с какой периодичностью должен срабатывать метод.

Task Execution and Scheduling

Answer 3

[angry_cellophane]

Самый простой вариант - ScheduledThreadPoolExecutor
Более удобный - quartz
Еще лучше - спринговский TaskExecutor

Answer 4

[Антон]

Спасибо за ответы.
На 1й взгляд больше пока понравился Spring'овый, но пока слабо представляю как реализовать 1й пункт

Сервис принимает сообщение, в сообщении есть поле - время обработки. Когда время наступило - сообщение должно быть обработано

можете рассказать в 2х словах?

Comments

[Evhen]

Первое что пришло в голову... если конечно количество промежутков времени для обработки фиксированное

В контроллере, который будет обрабатывать запросы, создать мапу очередей:

Map> mapQueue = new HashMap>();
mapQueue.put("9:00", new ConcurrentLinkedQueue());
mapQueue.put("12:00", new ConcurrentLinkedQueue());
mapQueue.put("15:00", new ConcurrentLinkedQueue());
....

в контроллере, обрабатывающий запросы с сообщениями

... timeMessageControlller(Message msg) {
mapQueue.get(msg.getTime()).offer(msg);
}

сообщение будет попадать в очередь предназначенную для времени указанном в сообщении.

Потом создаем для каждого времени метод с пометкой @Scheduled

@Scheduled(cron="0 0 9 * * *")
void handler_9_00( ) {
Queue q = mapQueue.get("9:00");
Message m;

while ((m = q.poll()) != null) {
doWork(m);
}
}

Приблизительно как то так

[Антон]

Вот собственно это и интересовало, чтобы не писать собственный велосипед возможно есть ...
Сейчас пробую сделать на JMS Message Selectors