Step 注册 ItemStream

该步骤必须在其生命周期中的必要点处理 ItemStream 回调。(有关 ItemStream 接口的更多信息,请参阅 ItemStream)。如果一个步骤失败并且可能需要重新启动,这一点至关重要,因为 ItemStream 接口是该步骤获取执行之间持久化状态所需信息的地方。

如果 ItemReaderItemProcessorItemWriter 本身实现了 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(transactionManager)
				.reader(itemReader())
				.writer(compositeItemWriter())
				.stream(fileItemWriter1())
				.stream(fileItemWriter2())
				.build();
}

以下示例展示了如何在 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>

在前面的示例中,CompositeItemWriter 不是 ItemStream,但它的两个委托都是。因此,两个委托写入器都必须明确注册为流,以便框架正确处理它们。ItemReader 不需要明确注册为流,因为它是 Step 的直接属性。现在该步骤可以重新启动,并且在发生故障时,读取器和写入器的状态将正确持久化。

© . This site is unofficial and not affiliated with VMware.