java - 如何将 ItemListener 注册到 CompositeItemProcessor

Question

我想将一些数据从一个步骤传递到另一个步骤，例如从step_1到step_2。我已将数据传递到步骤_1 中的 ExecutionContext 中。在步骤_2 中，我尝试使用检索 JobExecution 的 @beforeStep 来恢复数据。

但是，step_2引用了一个CompositeItemProcessor，它默认情况下似乎没有注册为监听器。如何将 ItemProcessListener 注册到 CompositeItemProcessor 的一个进程以恢复 JobExecution(然后恢复步骤_1 中的数据)？

Answer 1

要注册任何监听器，您可以在您的作业中列出监听器 - 在步骤内，然后当您实现监听器时 - 您可以实现特定的监听器

  <bean id="customItemProcessListener" 
          class="com.listeners.CustomItemProcessListener" />

     <job id="myJob" xmlns="http://www.springframework.org/schema/batch">
        <step id="step2">
            <tasklet>
            <chunk reader="reader" writer="writer"
                commit-interval="1" />
                <listeners>
                <listener ref="customItemProcessListener" />
                </listeners>
            </tasklet>
        </step>
        </job>

然后你就可以实现处理器

    public class CustomItemProcessListener implements ItemProcessListener<T> {

    @Override
    public void beforeProcess(T items) {
        System.out.println("ItemProcessListener - beforeProcess");
    }

    @Override
    public void afterProcess(T items , S result) {
        System.out.println("ItemProcessListener - afterProcess");
    }

    @Override
    public void onProcessError(T items , Exception exception) {
        System.out.println("ItemProcessListener - onProcessError ");
    }

}