|
对于最新稳定版本，请使用 Spring Batch 文档 6.0.3！ |
使用 Step 注册 ItemStream
该步骤必须在其生命周期的必要节点处理 ItemStream 个回调。（有关 ItemStream 接口的更多信息，请参阅 ItemStream）。这一点至关重要，因为如果步骤失败并可能需要重新启动，ItemStream 接口正是步骤获取执行之间持久状态所需信息的地方。
如果 ItemReader、ItemProcessor 或 ItemWriter 本身实现了 ItemStream 接口，则它们会自动注册。任何其他流都需要单独注册。这种情况常见于将间接依赖（例如委托）注入到读取器和写入器时。您可以通过 stream 元素在 step 上注册流。
-
Java
-
XML
以下示例展示了如何在 Java 中的 step 上注册一个 stream：
Java 配置
@Bean
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
return new StepBuilder("step1", jobRepository)
.<String, String>chunk(2, transactionManager)
.reader(itemReader())
.writer(compositeItemWriter())
.stream(fileItemWriter1())
.stream(fileItemWriter2())
.build();
}
/**
* In Spring Batch 4, the CompositeItemWriter implements ItemStream so this isn't
* necessary, but used for an example.
*/
@Bean
public CompositeItemWriter compositeItemWriter() {
List<ItemWriter> writers = new ArrayList<>(2);
writers.add(fileItemWriter1());
writers.add(fileItemWriter2());
CompositeItemWriter itemWriter = new CompositeItemWriter();
itemWriter.setDelegates(writers);
return itemWriter;
}以下示例展示了如何在 XML 中的 step 上注册一个 stream：
XML 配置
<step id="step1">
<tasklet>
<chunk reader="itemReader" writer="compositeWriter" commit-interval="2">
<streams>
<stream ref="fileItemWriter1"/>
<stream ref="fileItemWriter2"/>
</streams>
</chunk>
</tasklet>
</step>
<beans:bean id="compositeWriter"
class="org.springframework.batch.item.support.CompositeItemWriter">
<beans:property name="delegates">
<beans:list>
<beans:ref bean="fileItemWriter1" />
<beans:ref bean="fileItemWriter2" />
</beans:list>
</beans:property>
</beans:bean>在前面的示例中，CompositeItemWriter 不是一个 ItemStream，但它的两个委托都是。因此，必须将这两个委托写入器显式注册为流，以便框架能够正确处理它们。ItemReader 不需要显式注册为流，因为它是 Step 的直接属性。现在该步骤支持重启，并且在发生故障时，读取器和写入器的状态会被正确持久化。