委派模式以及向 Step 註冊
請注意,CompositeItemWriter
是委派模式的一個範例,這在 Spring Batch 中很常見。委派物件本身可能會實作回呼介面,例如 StepListener
。如果它們這樣做,並且與 Spring Batch Core 結合使用,作為 Job
中 Step
的一部分,那麼幾乎可以肯定需要手動向 Step
註冊它們。直接連接到 Step
的 reader、writer 或 processor,如果實作了 ItemStream
或 StepListener
介面,則會自動註冊。但是,由於委派物件不為 Step
所知,因此需要將它們作為 listeners 或 streams(或在適當情況下兩者都作為)注入。
-
Java
-
XML
以下範例示範如何在 Java 中將委派物件作為 stream 注入
Java 配置
@Bean
public Job ioSampleJob(JobRepository jobRepository, Step step1) {
return new JobBuilder("ioSampleJob", jobRepository)
.start(step1)
.build();
}
@Bean
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
return new StepBuilder("step1", jobRepository)
.<String, String>chunk(2, transactionManager)
.reader(fooReader())
.processor(fooProcessor())
.writer(compositeItemWriter())
.stream(barWriter())
.build();
}
@Bean
public CustomCompositeItemWriter compositeItemWriter() {
CustomCompositeItemWriter writer = new CustomCompositeItemWriter();
writer.setDelegate(barWriter());
return writer;
}
@Bean
public BarWriter barWriter() {
return new BarWriter();
}
以下範例示範如何在 XML 中將委派物件作為 stream 注入
XML 配置
<job id="ioSampleJob">
<step name="step1">
<tasklet>
<chunk reader="fooReader" processor="fooProcessor" writer="compositeItemWriter"
commit-interval="2">
<streams>
<stream ref="barWriter" />
</streams>
</chunk>
</tasklet>
</step>
</job>
<bean id="compositeItemWriter" class="...CustomCompositeItemWriter">
<property name="delegate" ref="barWriter" />
</bean>
<bean id="barWriter" class="...BarWriter" />