Spring-Batch: как убедиться, что во время выполнения задания его нельзя запускать снова одновременно

Вы можете создать собственный Tasklet в качестве первого шага и используйте JobExecutionDao, чтобы найти все JobExecutions. Если их несколько, работает - генерирует исключение.

Я уверен, что это будет не лучшее решение, но, тем не менее, я надеюсь, что это поможет в вашей ситуации.

При выполнении задания убедитесь, что вы запускаете задание с одним и тем же параметром. После завершения успешного выполнения вашего задания настройте сценарии вызова для удаления записи, соответствующей этому выполнению пакетного задания.

Таким образом, это выдаст ошибку и не позволит вам запустить 2 выполнения одного и того же задания одновременно. Удаление гарантирует, что последовательное выполнение разрешено.

АЛЬТЕРНАТИВНЫЙ МЕТОД: напишите задание с одним параметром job-execution-id. Каждый раз перед выполнением задания запрашивайте максимальное значение job-execution-id для выполненных заданий из пакетных таблиц для задания. Теперь выполните задание с job-execution-id, увеличенным на 1 в качестве входного параметра.

Я думаю, что это лучший метод, чем выше. Я не уверен, предоставляет ли сам Springbatch какие-либо простые варианты реализации этого сценария.

Возможно, я неправильно истолковал ваш вопрос, но вы можете ограничить количество параллельных выполнений любого отдельного шага, указав throttle-limit в тасклете внутри шага. Указав один, вы должны убедиться, что у вас есть только одно выполнение за раз:

<batch:step id="stepA" next="stepB">
  <batch:tasklet throttle-limit="1">
    <batch:chunk reader="myReader" writer="myWriter" commit-interval="100"/>
  </batch:tasklet>
</batch:step>

Вы можете настроить пользовательский интерфейс spring-batch-Admin для просмотра состояния заданий (сбой/выполняется/завершено и т. д.). При правильной настройке пользовательского интерфейса Spring Batch Admin вы даже можете просматривать статус нескольких задач внутри разных заданий.

Реализовать это в рамках одной JVM можно с помощью двоичного семафора. Это поможет избежать параллельного выполнения одного и того же задания. Заставить второй экземпляр ждать будет немного сложно, если вы не хотите, чтобы он просто пропустил выполнение, если установлено значение семафора.

Вы можете выполнить более сложную сериализацию (в том числе на пакетных узлах Spring), используя подходящую реализацию «Выборы лидера». Я использовал Netflix Curator (рецепт Apache Zookeeper) в своем проекте. Некоторые указатели здесь: https://github.com/regunathb/Trooper/wiki/Useful-Batch-Libraries

Я сделал это, написав специальный инкремент, который увеличивает свойства только после завершения предыдущего выполнения задания.

    public class CompletedJobRunIdIncrementer extends RunIdIncrementer {
    private final JobRepository jobRepository;
    private final String jobName;

    public CompletedJobRunIdIncrementer(JobRepository jobRepository, String jobName) {
        this.jobRepository = jobRepository;
        this.jobName = jobName;
    }

    @Override
    public JobParameters getNext(JobParameters parameters) {
        JobExecution lastJobExecution = jobRepository.getLastJobExecution(jobName, parameters);
        return lastJobExecution == null || lastJobExecution.getStatus() == BatchStatus.COMPLETED ? super.getNext(parameters) : parameters;
    }
}

и задание с этим инкрементом:

jobBuilders.get("myJob").incrementer(new CompletedJobRunIdIncrementer(jobRepository, "myJob").start(someTask()).build()

Вы можете добавить пользовательскую реализацию JobExecutionListener.

Ниже приведен пример реализации слушателя:

    @Component
    public class JobExecutionListener implements JobExecutionListener{


@Autowired
private JobExplorer jobExplorer;


@Override
public void beforeJob(JobExecution jobExecution) {
    int runningJobsCount = jobExplorer.findRunningJobExecutions(jobExecution.getJobInstance().getJobName()).size();
    if(runningJobsCount > 1){
        throw new RuntimeException("There are already active running instances of this job, Please cancel those executions first.");
    }
}

@Override
public void afterJob(JobExecution jobExecution) {

}

}

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