弹簧间歇流量控制

Question

我有一份春季批次的工作，有一个阅读器，一个处理器和一个作家。

首先，我想知道这三个组件是按照什么顺序运行的:它们是连续的(对于提交间隔=1)，还是在编写前一个组件之前读取一个新项，以避免延迟？

我对此感兴趣，因为我有以下情况：

我想要一个“装配线”：读->过程->写->再读->.

这意味着在写入前一项之前不会读取任何内容。

这东西已经被开箱了吗？如果没有，我怎样才能完成这件事？

Answer 1

在Spring中，ItemReader、ItemProcessor和ItemWriter之间的交互如下所示：

• 直到块大小达到为止
  • ItemReader.read()

​

• 虽然有些项目尚未处理，但
  • ItemProcessor.process()

​

• ItemWriter.write() //单个调用块中的所有项。

也就是说，当块大小设置为1时，它将被处理为读取、处理、写入、重复。

需要注意的是，不仅上面的契约是有保证的，而且每个步骤在下一个步骤执行之前都要运行到完成(拆分不能承受)。

您可以在这里阅读更多关于各种组件如何在文档中交互的信息：http://docs.spring.io/spring-batch/trunk/reference/html/configureStep.html#chunkOrientedProcessing