Spring批处理：不能用不同的作业参数启动作业，也不能访问作业参数

Question

我得和Spring批处理问题。都与通过命令行传入的JobParameters有关。

第一期：

-ts=${current_date} -path="file.csv"

Caused by: org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException: 
A job instance already exists and is complete for parameters={ts=20210211_1631, path=file.csv}.  
If you want to run this job again, change the parameters.

@Bean(name = "inJob")
public Job inJob(JobRepository jobRepository) {
    return jobBuilderFactory.get("inJob")
            .repository(jobRepository)
            .incrementer(new RunIdIncrementer())
            .start(truncateTable())
            .next(loadCsv())
            .next(updateType())
            .build();
}

@Override
public JobRepository createJobRepository() throws Exception {
    JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
    factory.setDataSource(dataSource);
    factory.setTransactionManager(transactionManager);
    factory.setTablePrefix("logging.BATCH_");
    return factory.getObject();
}

@Bean(name = "inReader")
@StepScope
public FlatFileItemReader<CsvInfile> inReader() {       
    FlatFileItemReader<CsvInfile> reader = new FlatFileItemReader<CsvInfile>();
    reader.setResource(new FileSystemResource(path));
    DefaultLineMapper<CsvInfile> lineMapper = new DefaultLineMapper<>();
    lineMapper.setFieldSetMapper(new CsvInfileFieldMapper());
    DelimitedLineTokenizer tokenizer = new DelimitedLineTokenizer();
    tokenizer.setDelimiter("|");
    tokenizer.setNames(ccn.names);
    lineMapper.setLineTokenizer(tokenizer);
    reader.setLineMapper(lineMapper);
    reader.setLinesToSkip(1);
    reader.open(new ExecutionContext());
    return reader;
}

为了从JobParameters获取路径，我使用BeforeStep注释加载JobParameters并将它们复制到局部变量上。不幸的是，这不起作用。变量将为null并且执行失败，因为文件无法打开。

private String path;

@BeforeStep
public void beforeStep(StepExecution stepExecution) {
    JobParameters jobParameters = stepExecution.getJobParameters();
    this.path = jobParameters.getString("path");
}

如何访问读取器中的作业参数？我想将文件路径作为命令行参数传入，然后读取这个文件。

Answer 1

第一期：这个问题还有别的解决办法吗？

您的当前日期是每分钟解析一次的，因此，如果在该分钟内运行作业不止一次，则可能已经有一个作业实例具有相同的参数，因此出现了问题。您的ts参数的精度应该是一秒（如果需要，也可以更低）。

第二个问题：如何访问阅读器中的作业参数？我想将文件路径作为命令行参数传入，然后读取这个文件。

@Bean(name = "inReader")
@StepScope
public FlatFileItemReader<CsvInfile> inReader(@Value("#{jobParameters['path']}") String path) {       
    FlatFileItemReader<CsvInfile> reader = new FlatFileItemReader<CsvInfile>();
    reader.setResource(new FileSystemResource(path));
    // ...
    return reader;
}

java -jar myjob.jar path=/absolute/path/to/your/file

参考文档的“作业和步骤属性的后期绑定”部分对此进行了解释。