Spring批处理多线程与分区

Question

我有一个要求，我想在下面的场景中使用Spring批处理框架。

我有一个在交易日期列上分区的表。我想使用Spring批处理框架的阅读器、处理器和写入器来处理该表的记录。我想做的是根据交易日期创建单独的线程进行读取、写入和处理。假设有4个交易日期，那么我想为单独的交易日期创建4个单独的线程。在每个线程中，阅读器将从该交易日期的表中读取记录，在处理器中丰富记录，然后在写入器中发布/写入。

我是Spring批处理的新手，因此我需要帮助通过使用Spring批处理多线程或分区来设计正确的方法。

Answer 1

您可以使用本地分区或主从方法来解决问题。在Spring配置中，按照以下步骤编写主和从步骤。

<batch:job id="tradeProcessor">
    <batch:step id="master">
        <partition step="slave" partitioner="tradePartitioner">
            <handler grid-size="4" task-executor="taskExecutor" />
        </partition>
    </batch:step>       
</batch:job>
<batch:step id="slave">
    <batch:tasklet>
        <batch:chunk reader="dataReader" writer="dataWriter"
                          processor="dataProcessor" commit-interval="10">
        </batch:chunk>
    </batch:tasklet>
</batch:step>

有关更多详细信息，您可以参考此处讨论的简单示例。

Answer 2

也许您可以使用如下的本地分区：

<batch:job id="MyBatch" xmlns="http://www.springframework.org/schema/batch">
    <batch:step id="masterStep">
        <batch:partition step="slave" partitioner="splitPartitioner">
            <batch:handler grid-size="4" task-executor="taskExecutor"  />
        </batch:partition>
    </batch:step>
</batch:job>

然后使用组织创建拆分器。springframework。一批果心隔断支持分区器接口。然后在partition method中，根据需要拆分源数据，创建的每个ExecutionContext都将由它自己的线程执行。