配置 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 repositoryJobRepository 的 Java 特定名称,它在处理过程中定期存储 StepExecutionExecutionContext(在提交之前)。
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-repositoryJobRepository 的 XML 特定名称,它在处理过程中定期存储 StepExecutionExecutionContext(在提交之前)。对于内联 <step/>(在 <job/> 中定义的一个),它是 <job/> 元素上的一个属性。对于独立的 <step/>,它被定义为 <tasklet/> 的一个属性。
3 commit-interval:在提交事务之前要处理的项目数量的 XML 特定名称。
请注意,job-repository 默认值为 jobRepositorytransaction-manager 默认值为 transactionManager。此外,ItemProcessor 是可选的,因为项目可以直接从读取器传递到写入器。

前面的配置包括创建面向项目的步骤所需的唯一依赖项

  • reader:提供要处理的项目的 ItemReader

  • writer:处理 ItemReader 提供的项目的 ItemWriter