配置 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 特定名稱,用於在處理期間( justo 在提交之前)定期儲存 StepExecution 和 ExecutionContext 。 |
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-repository :JobRepository 的 XML 特定名稱,用於在處理期間( justo 在提交之前)定期儲存 StepExecution 和 ExecutionContext 。對於內聯 <step/> (在 <job/> 中定義),它是 <job/> 元素上的一個屬性。對於獨立 <step/> ,它被定義為 <tasklet/> 的一個屬性。 |
3 | commit-interval :要處理的 Item 數量的 XML 特定名稱,在提交事務之前。 |
請注意,job-repository 預設為 jobRepository ,transaction-manager 預設為 transactionManager 。此外,ItemProcessor 是可選的,因為 Item 可以直接從 reader 傳遞到 writer。 |
上述配置包含了建立面向 Item 的 Step 所需的唯一依賴項
-
reader
:提供要處理的 Item 的ItemReader
。 -
writer
:處理由ItemReader
提供的 Item 的ItemWriter
。