使用jobParameters在tasklet和步骤之间传递参数返回null

Question

我定义了简单的工作。tasklet然后步骤。

我正在尝试在这两者之间传递filePath。

当我到达stem时，会调用读取器，在那里，文件路径保持为null。

我错过了什么？

职位配置：

@Bean
    public Job processFileJob() throws Exception {
          return this.jobs.get("processFileJob").start(downloadFileStep()).next(processor()).build();//.next(pushToKafkaStep()).build();

    }



public Step downloadFileStep() {
        return this.steps.get("downloadFileTaskletStep").tasklet(downloadFileTasklet()).build();
    }


    @Bean
    protected Tasklet downloadFileTasklet() {
        return new DownloadFileTasklet();
    }




@Bean
public Step processor() {
         return stepBuilderFactory.get("processor")
      .<PushItemDTO, PushItemDTO>chunk(1) 
                        .reader(reader(OVERRIDDEN_BY_EXPRESSION))
                        ...
                        .build();
            }



                           //here filePath always null!!
@Bean
    @Scope(value = "step", proxyMode = ScopedProxyMode.INTERFACES)
    public ItemStreamReader<PushItemDTO> reader(@Value("#{jobParameters[filePath]}") String filePath) {
        FlatFileItemReader<PushItemDTO> itemReader = new FlatFileItemReader<PushItemDTO>();
        itemReader.setLineMapper(lineMapper());
        itemReader.setLinesToSkip(1);
        itemReader.setResource(new FileSystemResource(filePath));
        return itemReader;
    }

下载文件任务：

public class DownloadFileTasklet implements Tasklet, StepExecutionListener {

   String filePath;

    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {

        filePath="someurl";        
        return RepeatStatus.FINISHED;
    }



    @Override
    public void beforeStep(StepExecution stepExecution) {

    }

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {
        JobParameters jobParameters = stepExecution.getJobExecution().getJobParameters();
       // jobParameters.ad
        stepExecution.getExecutionContext().putString("filePath", filePath);
        //Return null to leave the old value unchanged.
        return null;
    }

调用此作业时，我设法直接从jobLauncher传递参数，但当我尝试在tasklet中定义新参数并希望在下一步中使用它时，我将其设置为null

谢谢你。

正如推荐的那样，我应该使用ExecutionContextPubltionListener。

因此，我在java配置中添加了以下内容：

@Bean
    public ExecutionContextPromotionListener executionContextPromotionListener()
    {
        ExecutionContextPromotionListener executionContextPromotionListener=new ExecutionContextPromotionListener();
        executionContextPromotionListener.setKeys(new String[]{"filePath"});
        return new ExecutionContextPromotionListener();
    }

但是我得到例外：

Caused by: java.lang.IllegalArgumentException: The 'keys' property must be provided

我通过更改为return executionContextPromotionListener来修复它；

但是，filePath仍然为null。

我还尝试通过以下方式修改步骤声明：

*添加了执行上下文促销监听器

public Step downloadFileStep() {
    return this.steps.get("downloadFileTaskletStep").tasklet(downloadFileTasklet()).listener(executionContextPromotionListener()).build();
}

filePath参数仍然为空

Answer 1

向步骤的执行上下文（ExecutionContext）添加一个值，使其仅对该步骤可用。为了使它能够被另一个步骤访问，您需要将该键提升到作业的执行上下文（ExecutionContext）。为此，请查看ExecutionContextPromotionListener。它将把您配置的任何键从当前步骤的执行上下文升级到作业的执行上下文，以便可以从其他步骤访问它们。

您可以在以下文档中阅读有关ExecutionContextPromotionListener的更多信息：http://docs.spring.io/spring-batch/apidocs/org/springframework/batch/core/listener/ExecutionContextPromotionListener.html