ZK-Schedule

Распределённый компонент для планирования задач на основе ZooKeeper и Spring Task. Простая конфигурация обеспечивает распределённое планирование задач.

Особенности

1. Отсутствие зависимости от базы данных.
2. Возможность выполнения задач на одном узле кластера или на всех узлах, с гибкой настройкой.
3. При выполнении только на одном узле, автоматическое переключение при отказе (failover).
4. Поддержка настройки запуска планировщика при старте и во время работы, а также настройка выполнения задач.
5. После сбоя ZooKeeper, выполнение продолжается в соответствии с состоянием до сбоя. При восстановлении ZooKeeper, работа планировщика автоматически возобновляется.
6. Предоставляются интерфейсы для операций во время выполнения: 6.1 Получение идентификатора сервера текущего узла. 6.2 Получение списка зарегистрированных узлов, включая те, которые не выполняют часть задач. 6.3 Получение списка всех зарегистрированных задач, включая приостановленные. 6.4 Получение информации о том, на каких узлах не может выполняться конкретная задача. 6.5 Получение информации о сервере, которому назначена задача. 6.6 Динамическое включение/отключение серверов. 6.7 Динамическая приостановка/возобновление задач. Поддерживается как на текущем узле, так и на всех узлах.

Конфигурация

Создайте файл конфигурации с именем zk-schedule.properties в пути компиляции. Содержание файла:

#(Обязательно) Строка подключения к ZooKeeper
zk.schedule.connectionString=127.0.0.1:2181

#(Необязательно) Автоматическое добавление задач. По умолчанию true
#zk.schedule.autoRegisterTask=true

#(Необязательно) Используется для различения разных приложений, особенно когда несколько приложений используют один и тот же ZooKeeper. По умолчанию это имя приложения
#zk.schedule.prePath=zk-schedule

#(Необязательно) Выполнение задач на всех узлах. По умолчанию false
#zk.schedule.runInAll=true

#(Необязательно) Включение планировщика задач для всех узлов. Повлияет на все задачи на этом узле. По умолчанию true
zk.schedule.start = true

#(Необязательно) Настройка запуска задач. Формат (разделение между определениями задач с помощью английской запятой): {имя класса без пути пакета, первая буква в нижнем регистре}#{имя метода}#{true/false (true означает действие на всех узлах для этой задачи, false означает действие только на этом узле)},...
#zk.schedule.ignoreTask = simpleTask#print#true,simpleTask2#print#false

Вопросы и предложения

hh.suse@gmail.com

Автор [@crystony] 2015-09-16