весенний пакет: перезапуск завершенного задания с теми же параметрами

Long startNextInstance(String jobName) 
      throws NoSuchJobException, JobParametersNotFoundException, JobRestartException, 
             JobExecutionAlreadyRunningException, JobInstanceAlreadyCompleteException;

Этот метод класса JobOperator вместе с JobParameterIncrementer можно использовать для перезапуска задания, либо неудачного, либо завершенного.

http://static.springsource.org/spring-batch/apidocs/org/springframework/batch/core/launch/support/SimpleJobOperator.html#startNextInstance(java.lang.String)

Spring Batch требует уникальных параметров задания для его выполнения, поэтому вы можете добавить текущее время в качестве параметра задания.

Map<String, JobParameter> confMap = new HashMap<String, JobParameter>();
confMap.put("time", new JobParameter(System.currentTimeMillis()));
JobParameters jobParameters = new JobParameters(confMap);
jobLauncher.run(springCoreJob, jobParameters);

Spring Batch требует уникальных параметров задания для его выполнения. В вашем случае, если вы хотите запустить одно и то же задание с тем же параметром даты, вам следует «добавить» еще один параметр задания, чтобы сделать его уникальным. Вы можете думать об этом как об уникальном наборе параметров задания.

В этом сценарии можно использовать интерфейс org.springframework.batch.core.JobParametersIncrementer, просто дайте ему свой JobParameter, и он добавит run.id, который сделает его уникальным.

public class SampleIncrementer implements JobParametersIncrementer {  

    public JobParameters getNext(JobParameters parameters) { 
        if (parameters==null || parameters.isEmpty()) {
            return new JobParametersBuilder().addLong("run.id", 1L).toJobParameters();
        }
        long id = parameters.getLong("run.id",1L) + 1;
        return new JobParametersBuilder().addLong("run.id", id).toJobParameters();
    } }

Вы можете проверить простой образец, используя его

у меня есть эта функция

public void run()
{
    LOG.info("Processing batch...");
    try
    {
        Job job = createNewJob();
        JobParameters jobParameters = new JobParameters();
        Optional<JobInstance> existingInstance = jobExplorer.getJobInstances(job.getName(), 0, 1).stream().findFirst();
        if (existingInstance.isPresent())
        {
            jobParameters = job.getJobParametersIncrementer().getNext(jobParameters);
            LOG.warn("Trying to restart task \"{}\" with the parameters [{}]", job, jobParameters);
        }
        jobLauncher.run(job, jobParameters);
    }
    catch (JobExecutionAlreadyRunningException ex)
    {
        LOG.warn("The task \"{}\" is already running", BillingBatchConfig.QUALIFIER);
    }
    catch (JobRestartException ex)
    {
        LOG.warn("The task \"{}\" cannot be restarted", BillingBatchConfig.QUALIFIER);
    }
    catch (JobInstanceAlreadyCompleteException ex)
    {
        LOG.warn("The task \"{}\" cannot be restarted cause its finished", BillingBatchConfig.QUALIFIER);
    }
    catch (JobParametersInvalidException ex)
    {
        LOG.warn("The task \"{}\" cannot be excecuted cause the parameters are invalid", BillingBatchConfig.QUALIFIER);
    }
    catch (Exception ex)
    {
        LOG.warn("Unexpected error running the task \"{}\"", BillingBatchConfig.QUALIFIER);
    }
}

Ключ в том, чтобы сначала проверить, существует ли существующий экземпляр org.springframework.batch.core.explore.JobExplorer в базе данных требуемой работы. Если это так, задание должно быть запущено с параметрами, полученными с помощью job.getJobParametersIncrementer().getNext(jobParameters). Это все.

Я следовал той же идее, что и Серкан Арикушу.

Мой пакет можно перезапускать с теми же параметрами, добавляя внутри каждый раз уникальный параметр (отметка времени).

Я делаю это, создавая файл JobParametersIncrementer.

Вот пример кода:

Инкрементатор:

package com.batch;

import java.util.Date;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.JobParametersIncrementer;


public class MyIncrementer implements JobParametersIncrementer {

  public JobParameters getNext(JobParameters parameters) {
   long id = new Date().getTime();
   JobParameters jParam = new JobParametersBuilder()
        .addLong("run.id", id).toJobParameters();

   return jParam;
  }
 }

Дополнительное содержимое в XML задания:

<bean id="myIncrementer" class="com.batch.MyIncrementer"/>

<job id="myJob" ... restartable="true" incrementer="myIncrementer">
    <step ... >
    <tasklet ...>
        <chunk ... />
        ...
    </tasklet>
   </step>
   <batch:listeners>
    ...
   </batch:listeners>
</job>

Вот скриншот