Spring批处理和JobInstancealReadyCompleteException：

Question

我有一个Spring批处理作业，它通过SFTP从远程Linux服务器检索文件。远程服务器上的目录是一个包含七天文件（约400个文件）的存档。文件的大小相对较小。

Spring批处理知道哪些文件已经被处理。

当我启动应用程序时。第一次,Spring Batch tasklet检索文件时,Spring Batch会为它已经处理的每个文件生成一个异常：

>

在Transformer类中，是否应该检查文件是否存在于本地，并且仅对尚未处理的新文件调用JobLaunchRequest（）s？

/**

>

将BAI文件转换为Spring批处理作业启动请求*/public class FileMessageToJobRequestTransformer{public static final Logger Logger=LoggerFactory.getLogger（FileMessageToJobRequestTransformer.class）；私有作业作业；

public void setFileParameterName（String fileParameterName）{Logger.Debug（“File parameter Name：{}”,fileParameterName）；This.fileParameterName=fileParameterName；}

@Transformer public JobLaunchRequest transform（Message Message）{logger.debug（“File Message：{}”,Message）；JobParametersBuilder JobParametersBuilder=new JobParametersBuilder（）；

jobParametersBuilder.addString(fileParameterName,
        "file://" + message.getPayload().getAbsolutePath());

LOGGER.debug("Job params: {}", jobParametersBuilder.toJobParameters());

return new JobLaunchRequest(job, jobParametersBuilder.toJobParameters());

}}

JobInstanceAlReadyCompleteException

<！--获取新的BAI文件时，转换为spring批处理作业请求-->

附加addDate（）允许多次处理文件。现在数据库中有DUP。

jobParametersBuilder.addString(fileParameterName,
                "file://" + message.getPayload().getAbsolutePath())).addDate("rundate", new Date()).toJobParameters();

例如。

public interface JobExplorer {

    List<JobInstance> getJobInstances(String jobName, int start, int count);

    JobExecution getJobExecution(Long executionId);

    StepExecution getStepExecution(Long jobExecutionId, Long stepExecutionId);

    JobInstance getJobInstance(Long instanceId);

    List<JobExecution> getJobExecutions(JobInstance jobInstance);

    Set<JobExecuthtml" target="_blank">ion> findRunningJobExecutions(String jobName);
}

如何捕获异常？




Answer 1

我看到您在作业启动程序中只传递了一个参数作为“文件名”。一旦作业启动器启动，它将从存储库的BATCH_JOB_EXECUTION表中查询，并检查上次处理的作业的状态。在当前的作业执行中，输入参数与以前执行的作业相同，并且批处理状态&退出代码=completed，那么您将得到JobInstancealReadyCompleteException。你应该尝试在每一次执行中都传递唯一的Parmaeters。只需传递一个当前时间作为参数并尝试它

JobParameters jobparam =   new JobParametersBuilder().addString(fileParameterName, "file://" + message.getPayload().getAbsolutePath())
                        .addDate("rundate", new Date()).toJobParameters();

JobExecution execution = jobLauncher.run(job, jobparam);
         catch (Exception e) {
             if ( e instanceof JobInstanceAlreadyCompleteException){
                 System.out.println("Raj*************");
             }

>

2是的，您可以这样处理

catch（Exception e）{if（e instanceof JobInstanceAlreadyCompleteException）{system.out.println（“need to handle*************”）；}