Configuring a Step
-
reader: 提供要处理的项的项目读取器。
-
writer: 处理项目读取器提供的项的项目写入器。
尽管必需依赖项列表较短,但 Step 类是一个复杂的类,可能包含许多协作者,例如:
-
transactionManager: 开始和提交处理期间事务的事务管理器。
-
repository: 定期存储 StepExecution 和 ExecutionContext 的存储库。
-
chunk: 在提交事务之前要处理的项数。
尽管 Step
的必需依赖项列表相对较短,但它是一个可能包含许多协作者的极其复杂的类。
- Java
-
在使用 Java 配置时,您可以使用 Spring Batch 构建器,如下例所示:
Java Configuration
/**
* 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
是可选的,因为可以将项目可以直接从读取器传递到写入器。
- XML
-
为了简化配置,您可以使用 Spring Batch XML 命名空间,如下例所示:
XML Configuration
<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
。