配置跳过逻辑

在许多情况下,处理过程中遇到的错误不应导致Step失败,但应该跳过。这通常是一个必须做出的决定 由了解数据本身及其含义的人制作。财务数据, 例如,可能无法跳过,因为它会导致资金被转账,这 需要完全准确。另一方面,加载提供商列表可能会 允许跳过。如果提供商因格式不正确或 缺少必要的信息,可能没有问题。通常,这些不好的 记录也会被记录下来,稍后在讨论听众时会介绍这一点。spring-doc.cadn.net.cn

以下 Java 示例显示了使用跳过限制的示例:spring-doc.cadn.net.cn

Java 配置
@Bean
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
	return new StepBuilder("step1", jobRepository)
				.<String, String>chunk(10, transactionManager)
				.reader(flatFileItemReader())
				.writer(itemWriter())
				.faultTolerant()
				.skipLimit(10)
				.skip(FlatFileParseException.class)
				.build();
}

注意:该skipLimit可以使用skipLimit()方法。如果未指定,则默认跳过限制设置为 10。spring-doc.cadn.net.cn

以下 XML 示例显示了使用跳过限制的示例:spring-doc.cadn.net.cn

XML 配置
<step id="step1">
   <tasklet>
      <chunk reader="flatFileItemReader" writer="itemWriter"
             commit-interval="10" skip-limit="10">
         <skippable-exception-classes>
            <include class="org.springframework.batch.item.file.FlatFileParseException"/>
         </skippable-exception-classes>
      </chunk>
   </tasklet>
</step>

在前面的示例中,FlatFileItemReader被使用。如果在任何时候,一个FlatFileParseException,则跳过该项目并计入总数 跳过限制为 10。声明的异常(及其子类)可能会被抛出 在块处理的任何阶段(读取、处理或写入)。单独计数 由内部读取、处理和写入的跳过组成 步骤执行,但限制适用于所有跳过。一旦跳过限制 达到,则找到的下一个异常会导致该步骤失败。换句话说,第十一个 skip 触发异常,而不是第十个异常。spring-doc.cadn.net.cn

前面示例的一个问题是,除了FlatFileParseException导致Job失败。在某些情况下,这可能是 正确的行为。但是,在其他情况下,可能更容易识别哪些 异常应该会导致失败并跳过其他所有内容。spring-doc.cadn.net.cn

以下 Java 示例显示了排除特定异常的示例:spring-doc.cadn.net.cn

Java 配置
@Bean
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
	return new StepBuilder("step1", jobRepository)
				.<String, String>chunk(10, transactionManager)
				.reader(flatFileItemReader())
				.writer(itemWriter())
				.faultTolerant()
				.skipLimit(10)
				.skip(Exception.class)
				.noSkip(FileNotFoundException.class)
				.build();
}

注意:该skipLimit可以使用skipLimit()方法。如果未指定,则默认跳过限制设置为 10。spring-doc.cadn.net.cn

以下 XML 示例显示了排除特定异常的示例:spring-doc.cadn.net.cn

XML 配置
<step id="step1">
    <tasklet>
        <chunk reader="flatFileItemReader" writer="itemWriter"
               commit-interval="10" skip-limit="10">
            <skippable-exception-classes>
                <include class="java.lang.Exception"/>
                <exclude class="java.io.FileNotFoundException"/>
            </skippable-exception-classes>
        </chunk>
    </tasklet>
</step>

通过识别java.lang.Exception作为可跳过的异常类,配置 表示所有Exceptions是可跳过的。但是,通过“排除”java.io.FileNotFoundException,则配置细化了可跳过的列表 异常类为 allExceptions 除了 FileNotFoundException.任何被排除的 如果遇到异常类,则是致命的(即,它们不会被跳过)。spring-doc.cadn.net.cn

对于遇到的任何异常,可跳过性由最接近的超类确定 在类层次结构中。任何未分类的异常都被视为“致命”。spring-doc.cadn.net.cn

的顺序skipnoSkip方法调用无关紧要。spring-doc.cadn.net.cn

的顺序<include/><exclude/>元素无关紧要。spring-doc.cadn.net.cn