Spring Batch-如何将多个项目的列表从输入传递到ItemReader，ItemProc处理器和ItemWriter

Question

我有一个简单的csv文件，我正在读1000块，插入到数据库中。现在，如果我想检查db中是否存在行，并且在插入之前是否等于输入，如果存在行，并且行相等-忽略，否则插入或更新，我使用的是ItemProcessor。实现后，意识到jdbc调用太慢（平均120ms），并希望在调用db和检查输入之前对ID进行批处理。在这个阶段，ItemReader一次向ItemProcessor传递一个项目。现在，我试图一次将1000个项目传递给ItemProcessor，这样jdbc调用就可以成批处理。在尝试这一点时，我们能够检查一些示例，但无法获得读者的工作。这是示例代码。

public class customReader implements ItemReader<List<T>> {
private static List<T> records = null;
ItemReader<String> itemReader;

@Autowired customDao customDao; 
private int index = 0; 
@Override public List<T> read() throws Exception {
//reader logic
//while(records.size() < 1000){
      String record = itemReader.read();
      if(Objects.isNull(record)){
          break;
      } 
      records.add(record);
 }
 return (List<T>) records;

}

这是配置

@Bean
    return stepBuilderFactory
            .get("step")
            .<List<String>, List<String>>chunk(1000)
            .reader(reader())
            .processor(processor())
            .writer(writer())
            .build();

如果任何人有一个简单的示例，他们可以将1000行csv文件的列表传递给处理器，请分享该示例。选中了共享的示例：使一个条目读取器返回一个列表，而不是单个对象——Spring批处理获取异常，未选中对处理器、编写器的调用，等等。

Spring Batch-带有列表的项目阅读器和项目处理器上面也检查了，但是有一些异常，比如在注释中列出的和未检查的类型等。如果您有一个没有多线程的事务中具有多行的阅读器、处理器和写入器的工作示例，请分享。

Answer 1

从这个问题来看，您似乎在使用自定义ItemReader阅读列表时遇到问题（如果有任何其他问题，请纠正我）。首先，您可以发布ItemProcessor和ItemWriter的结构，这将有助于更深入地了解问题。

为了更清楚地了解Spring批处理是如何工作的，您可以使用阅读器一次阅读一个或多个项目。但是，批处理框架一次发送一个项目给处理器（即使它已经通过批处理读取准备了一个项目列表），写入器将从处理器接收输出列表以写入目标（基于块大小）。如果你正在从读取器读取列表并从读取器返回相同的列表，那么处理器将接收列表进行处理，但写入器应该有列表