Spring批处理：一次处理多条记录

Question

我使用的是spring批处理，和通常使用的一样，我有读取器、处理器和写入器。

我有两个问题

1>Reader查询所有200条记录（表中记录总大小为200，我给出了pageSize=200)，因此它得到所有200条记录，在处理器中，我们需要所有这些记录的列表，因为我们必须将每个记录与其他199条记录进行比较，以便将它们分组在不同的层中。因此我在想，如果我们能在处理步骤中得到那个列表，我就可以操纵它们了。我该如何处理。

2>在处理阶段，我需要从数据库中获取一些主数据，根据这些数据来处理所有的输入记录，我考虑在处理bean中注入数据源，获取所有的主表数据，处理所有的记录。这是一个好的方法或请提出其他的建议。

<job id="sampleJob">
    <step id="step1">
        <tasklet>
            <chunk reader="itemReader" processor="processor" writer="itemWriter" commit-interval="20"/>
        </tasklet>
    </step>
</job>

处理器是

@Override
public User process(Object item) throws Exception {
    // transform item to user
    return user;
}

我想要像

public List<User> process(List<Object> item) throws Exception {
    // transform item to user
    return user;
}

我在这里发现了一些帖子，但是他们说要在writer中得到列表。但是我不喜欢在writer中处理任何东西，因为这会扼杀writer和处理器的定义。是否有任何配置来获取这个过程方法中的列表。

谢谢你

Answer 1

由于itemprocessor接收您从itemreader返回的任何内容，因此您需要您的itemreader来返回列表。列表实际上是您正在处理的“项目”。Spring批处理示例中有一个这样的示例。AggregateItemReader从委托ItemReader读取所有项，并将它们作为单个列表返回。您可以在Github上查看它：https://Github.com/spring-projects/spring-batch/blob/master/spring-batch-samples/src/main/java/org/springframework/batch/sample/domain/multiline/aggregateitemreader.java