Spring批处理-循环读取器、处理器和写入器N次

Question

我有“N”没有的。客户/客户。对于每个客户/客户，我需要从数据库（读取器）中获取记录，然后我必须处理（处理器）客户/客户的所有记录，然后我必须将记录写入文件（写入器）。

如何将spring批处理作业循环N次？

Answer 1

本地分区将解决您的问题。

在您的分区器中,您将把您的所有客户端ID放入map中,如下所示（只是伪代码）,

public class PartitionByClient implements Partitioner {

        @Override
        public Map<String, ExecutionContext> partition(int gridSize) {
            Map<String, ExecutionContext> result = new HashMap<>();
            int partitionNumber = 1;
            for (String client: allClients) {
            ExecutionContext value = new ExecutionContext();
            value.putString("client", client);
            result.put("Client [" + client+ "] : THREAD " + partitionNumber, value);
            partitionNumber++;
            }

        } 

        return result;
        }
    }

这只是一个伪代码。您必须查看分区的详细文档。

@Bean
    public TaskExecutor taskExecutor() {
    SimpleAsyncTaskExecutor simpleTaskExecutor = new SimpleAsyncTaskExecutor();
    simpleTaskExecutor.setConcurrencyLimit(concurrencyLimit);
    return simpleTaskExecutor;
    }