配置 Step
尽管 Step
的必需依赖项列表相对较短,但它是一个非常复杂的类,可能包含许多协作者。
-
Java
-
XML
在使用 Java 配置时,您可以使用 Spring Batch 构建器,如下例所示
Java 配置
/**
* Note the JobRepository is typically autowired in and not needed to be explicitly
* configured
*/
@Bean
public Job sampleJob(JobRepository jobRepository, Step sampleStep) {
return new JobBuilder("sampleJob", jobRepository)
.start(sampleStep)
.build();
}
/**
* Note the TransactionManager is typically autowired in and not needed to be explicitly
* configured
*/
@Bean
public Step sampleStep(JobRepository jobRepository, (2)
PlatformTransactionManager transactionManager) { (1)
return new StepBuilder("sampleStep", jobRepository)
.<String, String>chunk(10, transactionManager) (3)
.reader(itemReader())
.writer(itemWriter())
.build();
}
1 | transactionManager :Spring 的 PlatformTransactionManager ,在处理过程中开始和提交事务。 |
2 | repository :JobRepository 的 Java 特定名称,它在处理过程中定期存储 StepExecution 和 ExecutionContext (在提交之前)。 |
3 | chunk :依赖项的 Java 特定名称,表示这是一个基于项目的步骤,以及在提交事务之前要处理的项目数量。 |
请注意,repository 默认值为 jobRepository (通过 @EnableBatchProcessing 提供),transactionManager 默认值为 transactionManager (从应用程序上下文提供)。此外,ItemProcessor 是可选的,因为项目可以直接从读取器传递到写入器。
|
为了简化配置,您可以使用 Spring Batch XML 命名空间,如下例所示
XML 配置
<job id="sampleJob" job-repository="jobRepository"> (2)
<step id="step1">
<tasklet transaction-manager="transactionManager"> (1)
<chunk reader="itemReader" writer="itemWriter" commit-interval="10"/> (3)
</tasklet>
</step>
</job>
1 | transaction-manager :Spring 的 PlatformTransactionManager ,在处理过程中开始和提交事务。 |
2 | job-repository :JobRepository 的 XML 特定名称,它在处理过程中定期存储 StepExecution 和 ExecutionContext (在提交之前)。对于内联 <step/> (在 <job/> 中定义的一个),它是 <job/> 元素上的一个属性。对于独立的 <step/> ,它被定义为 <tasklet/> 的一个属性。 |
3 | commit-interval :在提交事务之前要处理的项目数量的 XML 特定名称。 |
请注意,job-repository 默认值为 jobRepository ,transaction-manager 默认值为 transactionManager 。此外,ItemProcessor 是可选的,因为项目可以直接从读取器传递到写入器。
|
前面的配置包括创建面向项目的步骤所需的唯一依赖项
-
reader
:提供要处理的项目的ItemReader
。 -
writer
:处理ItemReader
提供的项目的ItemWriter
。