注册ItemStream替换为Step

步骤必须注意ItemStreamcallbacks 在其 生命周期。（有关ItemStream接口，请参阅 ItemStream ）。如果某个步骤失败并且可能会失败，这一点至关重要 需要重新启动，因为ItemStreaminterface 是 Step 获取 它需要的有关执行之间持久状态的信息。spring-doc.cadn.net.cn

如果ItemReader,ItemProcessor或ItemWriter本身实现了ItemStream接口，这些将自动注册。任何其他流都需要 单独注册。这通常是间接依赖项（例如 委托被注入到 Reader 和 Writer 中。您可以在step通过stream元素。spring-doc.cadn.net.cn

以下示例演示如何注册stream在step在 Java 中：spring-doc.cadn.net.cn

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;
}

以下示例演示如何注册stream在step在 XML 中：spring-doc.cadn.net.cn

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.步骤 现在可以重新启动，并且读取器和写入器的状态会正确地保留在 事件。spring-doc.cadn.net.cn