无法存储和检索从一个步骤到另一个步骤的数据-在Spring BatchJob中

Question

我们正在处理一个Spring批处理作业，其中我们需要存储在一个步骤中计算的数据，并在下一个步骤中检索它。

我能够在Spring批处理源代码中使用以下实现以独立的方式实现这一点

http://static.springsource.org/spring-batch/reference/html/patterns.html#passingDataToFutureSteps

但是我们以CLIENT/MASTER和SERVER的方式实现它。其中CLIENT/MASTER具有与作业和分区相关的代码。

客户端位于EAR之外，由Shell脚本用于调用Batch Jobs。

客户端的Bean配置：

<job id="esk956" xmlns="http://www.springframework.org/schema/batch">
    <step id="importSalesAlert-master">
        <partition handler="partitionHandler" partitioner="partitioner" />
    </step>

</job>

<bean id="partitioner"
    class="org.springframework.batch.core.partition.support.SimplePartitioner" />

所有与步骤及其实现（读卡器、处理器和写入器）相关的代码都在服务器/从机端。

从代码：

<step id="importSalesAlert" xmlns="http://www.springframework.org/schema/batch">
    <tasklet transaction-manager="transactionManager">
        <chunk reader="salesAlertFileItemReader" processor="nucleusItemProcessor"
            writer="nucleusItemWriter" commit-interval="10" />
        <listeners>
            <listener ref="loggingStepListener" />
        </listeners>
    </tasklet>
</step>

我们使用JMS集成和Weblogic作为Web服务器。

请指导我们解决这个问题。

Answer 1

要将信息从分区器传递给执行器（步骤），您可以在分区时在stepExefftionContext中设置它，然后使用laty-绑定来设置值。看看这里的示例（https://github.com/SpringSource/spring-batch/blob/master/spring-batch-samples/src/main/resources/jobs/partitionJdbcJob.xml），特别是看看itemReader中的值${stepExcutionContext[minValue]}。此值来自分区器设置的stepExfigtionContext。

您还可以以相同的方式访问其他后期绑定变量，就像jobExecutionContext和jobParameters一样。只需确保itemreader的根元素中有属性scope=“step”，并且使用名称空间声明jobRepository