Spring批处理重试策略和跳过策略问题

Question

我有以下步骤在批处理工作。

    <batch:step id="parse-step">
        <batch:tasklet>
            <batch:chunk reader="xmlCommonReader"
                         processor="xmlCommonProcessor"
                         writer="xmlCommonWriter"
                         commit-interval="1">
                <batch:skip-policy>
                    <bean class="org.springframework.batch.core.step.skip.AlwaysSkipItemSkipPolicy" scope="step"/>
                </batch:skip-policy>
                <batch:retry-policy>
                    <bean class="org.springframework.retry.policy.NeverRetryPolicy" scope="step"/>
                </batch:retry-policy>
            </batch:chunk>
        </batch:tasklet>
        <batch:next on="FAILED" to="file-failed-step"/>
        <batch:next on="COMPLETED" to="file-success-step"/>
        <batch:listeners>
            <batch:listener ref="parseStepExecutionListener"/>
            <batch:listener ref="parseStepSkipListener"/>
        </batch:listeners>
    </batch:step>

当某个异常抛出时，我在parseStepSkipListener中捕捉他并登录数据库。

我期待以下行为：

1. 作业已启动
2. 执行前面的步骤
3. 开始执行解析步骤
4. 阅读项目
5. 进程项
6. 写
   1. 哦，异常。
   2. 捕获异常，登录数据库，转到下一个块（读取、处理、写入）。
   1. 作业已启动
   2. 执行前面的步骤
   3. 开始执行解析步骤
   4. 阅读项目
   5. 进程项
   6. 写
      1. 哦，异常。
      2. 进程项
      3. 写入项
         1. 哦，异常。
         2. 捕获异常，登录数据库，转到下一个块（读取、处理、写入）。

         因此，一个数据块尝试处理和写入两次。

Answer 1

寥寥数语：

这是因为当在写步骤中发生错误时，SB不知道哪个对象导致了异常，所以执行回滚，并且最后未提交块的每一项被再次处理/作为小块，以检测哪个对象是主写错误的原因。您可以在这里阅读更多（使用图表）