配置 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 特定名稱,用於在處理期間( justo 在提交之前)定期儲存 StepExecutionExecutionContext
3 chunk:此依賴項的 Java 特定名稱,表示這是一個基於 Item 的 Step,以及在提交事務之前要處理的 Item 數量。
請注意,repository 預設為 jobRepository(透過 @EnableBatchProcessing 提供),transactionManager 預設為 transactionManager(從應用程式上下文提供)。此外,ItemProcessor 是可選的,因為 Item 可以直接從 reader 傳遞到 writer。

為了簡化配置,可以使用 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 特定名稱,用於在處理期間( justo 在提交之前)定期儲存 StepExecutionExecutionContext。對於內聯 <step/>(在 <job/> 中定義),它是 <job/> 元素上的一個屬性。對於獨立 <step/>,它被定義為 <tasklet/> 的一個屬性。
3 commit-interval:要處理的 Item 數量的 XML 特定名稱,在提交事務之前。
請注意,job-repository 預設為 jobRepositorytransaction-manager 預設為 transactionManager。此外,ItemProcessor 是可選的,因為 Item 可以直接從 reader 傳遞到 writer。

上述配置包含了建立面向 Item 的 Step 所需的唯一依賴項

  • reader:提供要處理的 Item 的 ItemReader

  • writer:處理由 ItemReader 提供的 Item 的 ItemWriter