导航：首页 > 开发技术 >

SpringBatch跳过异常限制和自定义跳过配置SkipPolicy接口的方法

发表于：2026-11-04 作者：千家信息网编辑

千家信息网最后更新 2026年11月04日，这篇文章主要介绍"SpringBatch跳过异常限制和自定义跳过配置SkipPolicy接口的方法"，在日常操作中，相信很多人在SpringBatch跳过异常限制和自定义跳过配置SkipPolicy接

千家信息网最后更新 2026年11月04日SpringBatch跳过异常限制和自定义跳过配置SkipPolicy接口的方法

这篇文章主要介绍"SpringBatch跳过异常限制和自定义跳过配置SkipPolicy接口的方法"，在日常操作中，相信很多人在SpringBatch跳过异常限制和自定义跳过配置SkipPolicy接口的方法问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"SpringBatch跳过异常限制和自定义跳过配置SkipPolicy接口的方法"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

SpringBatch容错处理

1. 案例说明

从DB中reader出1000条数据，chunk = 100，当第二个chunk出现NullPointerException或者StringIndexOutOfBoundsException异常。业务要求batch不终了，程序继续执行。

2. 跳过异常限制

下记有两种实现方法。

2.1 skip 和 skipLimit配置

  @Bean  public Step job1step1() throws Throwable {    return stepBuilderFactory        .get(_JOB_STEP_NAME)          .listener(_stepListener)          .chunk(_CHUNK_SIZE)          .reader(reader())          .processor(processor())          .writer(writer())          .faultTolerant()          .skipLimit(10)          .skip(NullPointerException.class)          .skip(StringIndexOutOfBoundsException.class)          .build();  }

上记代码示例中的skipLimit方法限制最大跳过数，skip方法限制跳过的异常类型。

这样某条数据出现异常时，并不会终了step，而是跳过本条错误数据，继续处理下一条。

2.2 自定义跳过配置SkipPolicy 接口

SkipPolicy相对于skip更加灵活。

例：业务要求，userId = 110的用户出现上记两个异常时，程序终了。

step代码

  @Bean  public Step job1step1() throws Throwable {    return stepBuilderFactory        .get(_JOB_STEP_NAME)          .listener(_stepListener)          .chunk(_CHUNK_SIZE)          .reader(reader())          .processor(processor())          .writer(writer())          .faultTolerant()          .skipPolicy(new SkipPolicyTask())          .build();  }

自定义SkipPolicy 接口代码

public class SkipPolicyTask implements SkipPolicy {    private static final int MAX_SKIP_COUNT = 10;    private static final int USER_ID= 110;     @Override    public boolean isSkipFlg(Throwable throwable, int skipCount)       throws SkipLimitExceededException {         if (throwable instanceof NullPointerException && skipCount < MAX_SKIP_COUNT) {            return true;        }         if (throwable instanceof StringIndexOutOfBoundsException && skipCount < MAX_SKIP_COUNT ) {            if(common.getUserId == INVALID_TX_AMOUNT_LIMIT) {                return false;            } else {                return true;            }        }        return false;    } }

return flase 程序终了，retuen true 跳过异常。

SpringBatch 错误积累

1.如果nextStep在该JOB中还没有配置

也就是说nextStep还不存在的情况下，就会报错

Caused by: java.lang.IllegalArgumentException: Missing state for [StateTransition: [state=bain_Job.bainToTableStep, pattern=BALANCED, next=bain_Job.trustAcctBatPayStep]]
at org.springframework.batch.core.job.flow.support.SimpleFlow.initializeTransitions(SimpleFlow.java:283) ~[spring-batch-core-3.0.0.RELEASE.jar:3.0.0.RELEASE]
at org.springframework.batch.core.job.flow.support.SimpleFlow.afterPropertiesSet(SimpleFlow.java:128) ~[spring-batch-core-3.0.0.RELEASE.jar:3.0.0.RELEASE]
at org.springframework.batch.core.configuration.xml.SimpleFlowFactoryBean.getObject(SimpleFlowFactoryBean.java:125) ~[spring-batch-core-3.0.0.RELEASE.jar:3.0.0.RELEASE]
at org.springframework.batch.core.configuration.xml.SimpleFlowFactoryBean.getObject(SimpleFlowFactoryBean.java:46) ~[spring-batch-core-3.0.0.RELEASE.jar:3.0.0.RELEASE]
at org.springframework.beans.factory.support.FactoryBeanRegistrySupport.doGetObjectFromFactoryBean(FactoryBeanRegistrySupport.java:168) ~[spring-beans-4.1.5.RELEASE.jar:4.1.5.RELEASE]
... 42 common frames omitted

到此，关于"SpringBatch跳过异常限制和自定义跳过配置SkipPolicy接口的方法"的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注网站，小编会继续努力为大家带来更多实用的文章！

很赞哦！