Spring批处理-将多个文件写入多个目标

Question

我是Spring批处理的新手，目前正在处理一个新的批处理作业。我的批处理作业：

1. 读取器：读取数据库中的记录（即5家公司的员工）
2. 处理器：处理记录
3. 5个writer：过滤并写入每个文件（即A公司的员工在A路径写入A公司文件，B公司的员工在B路径写入B公司文件），最后一个writer将A公司的所有离职员工写入D公司。
4. 任务：将文件保存到数据库中。

目前，我正在使用CompositeItemWriter编写5个文件，它工作了。

<bean id="ComapanyWriter" 
    class="org.springframework.batch.item.support.CompositeItemWriter">
  <property name="delegates">
    <list>
      <ref bean="CompanyAWriter" />
      <ref bean="CompanyBWriter" />
      <ref bean="CompanyCWriter" />
      <ref bean="CompanyDWriter" />
      <ref bean="ResignedEmpWriter" />
    </list>
  </property>
</bean>

然而，我意识到，如果读取器从数据库中检索到50K条记录，每个写入器将循环所有记录，搜索各自的公司员工并写入文件，这总共是5×50K次，是多余的。所以，我担心演出。

我能想到的一些解决办法：

1. 试图从数据池（项目）中删除写入的记录，这样下一个写入器将循环较少的数据，但似乎不允许这样做？（我得到这个错误java.lang.UnsupportedOperationException)
2. 将记录拆分为5个列表(companyAList,companyBList等）供每个编写者编写，但我不确定如何实现这一点
3. 在writer中将记录拆分为5个列表，并使用1个writer写入5个文件，但不确定是否可行。
4. 将公司ID作为参数传递，这样作业将根据该参数动态地处理和写入文件。此方法需要对4个公司触发4次职务，不能处理所有公司的离职员工。
5. 现在我正在查看ClassifierCompositeItemWriter，不确定它是否有帮助。

请指教我如何实现上述方法或如何实现批量作业目标。

Answer 1

ClassifierCompositeItemWriter是一种方法。分类器将对项目进行分类，并将其传递给指定的编写器。这样，每个writer将只接收分配给它的类的项，而不是循环块的所有项。

您可以在这里找到如何使用ClassifierCompositeItemWriter的示例:https://github.com/spring-projects/spring-batch/blob/master/spring-batch-infrastructure/src/test/java/org/springframework/batch/item/support/classifierCompositeItemWriterTests.java

这里有一个类似的问题，我在这里添加它以供参考：读取平面文件并写入多个写入器，这些写入器将写入不同的对象。

希望这有帮助。