Spring Batch Step Scope是如何工作的

Question

我有一个要求，我需要根据rest调用处理文件，在rest调用中我得到文件名，我将它添加到job参数中，并在创建bean时使用它。

我正在为（读者，作家）创建步骤范围Beans，并使用作业参数。我在一个新的线程中开始这项工作，因为我使用异步任务Excepper来启动这项工作，我的问题是当我们定义@StepScope时，如何在Spring创建bean

jobParametersBuilder.addString("fileName", request.getFileName());
jobExecution = jobLauncher.run(job, jobParametersBuilder.toJobParameters());
@Bean
public JobLauncher jobLauncher() {
    SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
    jobLauncher.setJobRepository(jobRepository());
    jobLauncher.setTaskExecutor(asyncTaskExecutor());
    return jobLauncher;
}

@Bean
@StepScope
public ItemWriter<Object> writer(@Value ("#{jobParameters['fileName']}"String    fileName) {
    JdbcBatchItemWriter<Object> writer = new JdbcBatchItemWriter<>();
    writer.setItemSqlParameterSourceProvider(
        new BeanPropertyItemSqlParameterSourceProvider<Object>());
    writer.setSql(queryCollection.getquery());
    writer.setDataSource(dataSource(fileName));
    return writer;
}

Answer 1

Spring批处理StepScope对象是对特定步骤唯一的对象，而不是单例对象。您可能知道，Spring中默认的bean作用域是单例对象。但是通过将Spring批处理组件指定为StepScope意味着Spring Batch将使用Spring容器为每个步骤执行实例化该组件的新实例。

这对于进行参数后期绑定通常很有用，其中参数可以在StepContext或JobExecttionContext级别指定，并且需要替换占位符，就像您的示例中的文件名要求一样。

使用StepScope的另一个有用的原因是当您决定在并行步骤中重用相同的组件时。如果组件管理任何内部状态，重要的是它是基于StepScope的，这样一个线程就不会损害另一个线程管理的状态（例如，给定步骤的每个线程都有自己的StepScope组件实例）。