如何在Spring Batch中通过SkipListener实现校验与错误捕获？

你当前配置中ValidatingItemProcessor.setFilter(true)的设置是导致无法捕获异常的核心原因：

• 当filter=true时，校验失败的Item会被过滤（处理器返回null），而不是抛出ValidationException。
• Spring Batch会将返回null的Item视为正常过滤，不会触发容错（faultTolerant）的skip逻辑，因此SkipListener.onSkipInProcess不会被调用。

方案一：关闭过滤，让异常触发SkipListener #

如果不需要保留过滤逻辑（允许校验失败的Item触发skip流程），只需修改ValidatingItemProcessor的配置，移除setFilter(true)（默认值为false，校验失败时直接抛出异常）：

@Bean
public ValidatingItemProcessor<User> validatingItemProcessor() {
    ValidatingItemProcessor<User> itemProcessor = new ValidatingItemProcessor<>(new UserValidator());
    // 移除setFilter(true)，校验失败时抛出ValidationException
    return itemProcessor;
}

修改后，当校验失败抛出ValidationException时，faultTolerant().skip(ValidationException.class)会生效，SkipListener.onSkipInProcess方法会被正常调用，你可以在该方法中获取异常信息和对应的User对象，执行数据库存储逻辑。

方案二：保留过滤功能，同时记录校验错误 #

如果必须保留过滤（无效Item不进入Writer），但需要记录校验错误，可以自定义ValidatingItemProcessor的扩展类，在校验失败时手动触发监听器的错误记录逻辑：

1. 自定义扩展处理器 #

public class LoggingValidatingItemProcessor<T> extends ValidatingItemProcessor<T> {

    private final UserValidationListener validationListener;

    public LoggingValidatingItemProcessor(Validator<T> validator, UserValidationListener validationListener) {
        super(validator);
        this.validationListener = validationListener;
        setFilter(true); // 保留过滤逻辑
    }

    @Override
    public T process(T item) throws ValidationException {
        try {
            return super.process(item);
        } catch (ValidationException e) {
            // 手动调用监听器记录错误
            validationListener.onSkipInProcess(item, e);
            return null; // 过滤当前Item
        }
    }
}

2. 修改处理器Bean配置 #

@Bean
public ValidatingItemProcessor<User> validatingItemProcessor(UserValidationListener listener) {
    return new LoggingValidatingItemProcessor<>(new UserValidator(), listener);
}

这种方式既保留了过滤无效Item的功能，又能在校验失败时捕获异常信息并执行后续的数据库存储逻辑。

内容的提问来源于stack exchange，提问作者wick3d