ItemWriter的Spring Boot多线程

Question

我有一个包含两个主要步骤的 Spring Boot Batch 作业，第一个步骤是从电子表格中读取一堆行。第二个写入数据库。现在，它已设置为串行写入数据库

public CompositeItemWriter<SoftLayerData> compositeSoftlayerDataWriter(
    JpaItemWriter<SoftLayerData> softlayerDataWriter) {
  CompositeItemWriter<SoftLayerData> compositeWriter = new CompositeItemWriter<>();
  compositeWriter.setDelegates(asList(softlayerDataWriter));
  return compositeWriter;
}

问题是音量很大。由于没有理由维持任何秩序，我希望有多个作家。我试过这个：

final int writerCount = 10;
List<ItemWriter<? super SoftLayerData>> writers = new ArrayList<>(writerCount);
for(int counter=0;counter<writerCount;counter++) {
  writers.add(new JpaItemWriter<SoftLayerData>());
}
CompositeItemWriter<SoftLayerData> result = new CompositeItemWriter<>();
result.setDelegates(writers);
return result;

但我收到的是IllegalArgumentException: No EntityManagerFactory specified。

我喜欢这种方法，但我怀疑我必须遵循一些非常复杂的 Spring Boot 方法。编写多个作家的最佳方法是什么？

谢谢， 樵夫

Answer 1

CompositeItemWriter 调用委托编写器是顺序的，而不是并行的。因此，在复合编写器中创建 10 个 JpaItemWriters 作为委托不会使您的步骤多线程。

如果您希望该步骤变为多线程，则需要向其添加TaskExecutor，例如：

@Bean
public TaskExecutor taskExecutor() {
    return new SimpleAsyncTaskExecutor("spring_batch");
}

@Bean
public Step sampleStep(TaskExecutor taskExecutor) {
    return this.stepBuilderFactory.get("sampleStep")
                .<String, String>chunk(10)
                .reader(itemReader())
                .writer(itemWriter())
                .taskExecutor(taskExecutor)
                .build();
}

请参考Multi-Threaded step。

现在您的问题是您正在使用new 运算符创建JpaItemWriter，因此Spring 不会调用afterPropertiesSet 方法来检查强制属性。您需要在此作者上设置EntityManagerFactory。