Spring Batch跳过处理器异常时更新数据库状态被回滚或死循环如何解决

问题根因 #

1. 直接在SkipPolicy中更新状态的问题：SkipPolicy的执行在当前Chunk的事务上下文内，后续空Chunk写入抛出的ForceRollbackForWriteSkipException会回滚整个Chunk事务，你的更新操作会被一同回滚。
2. 自定义ExceptionHandler的问题：你捕获异常后没有向上抛出，Spring Batch会认为异常已处理、无需跳过当前条目，会重复处理同一条数据触发死循环。
3. 空Chunk写入异常不是Spring Batch的Bug：SimpleChunkProcessor的默认实现默认写入列表非空，你遇到的异常是chunkSize设为1、processor抛出异常后整个Chunk无有效写入元素的特定场景问题，不需要修改框架源码。

推荐解决方案 #

方案1：使用SkipListener+独立事务更新（最规范） #

SkipListener是Spring Batch专门提供用来处理跳过逻辑的扩展点，你担心的多步骤复用问题可以通过封装公共组件解决，不会产生重复代码。

步骤1：封装独立事务的状态更新逻辑

更新失败条目的方法要开启独立新事务，不受主Chunk事务回滚影响：

@Service
public class ItemStatusService {
    @Autowired
    private JdbcTemplate jdbcTemplate;

    // 开启独立事务，更新操作会单独提交
    @Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
    public void markItemProcessFailed(Long itemId) {
        jdbcTemplate.update("update your_table set status = 'PROCESS_FAILED' where id = ?", itemId);
    }
}

步骤2：实现通用SkipListener

@Component
public class MyExceptionSkipListener implements SkipListener<Input, Output> {
    @Autowired
    private ItemStatusService itemStatusService;

    @Override
    public void onSkipInProcess(Input item, Throwable t) {
        if (t instanceof MyException) {
            // 更新失败条目状态
            itemStatusService.markItemProcessFailed(item.getId());
            // 其他通用逻辑，比如日志记录也可以在这里统一处理
        }
    }

    // 其余跳过方法无逻辑可空实现
    @Override
    public void onSkipInRead(Throwable t) {}
    @Override
    public void onSkipInWrite(Output item, Throwable t) {}
}

步骤3：Step配置中添加监听器

return this.stepBuilderFactory.get("name")
        .<Input, Output>chunk(1)
        .reader(reader())
        .processor(processor())
        .faultTolerant()
        .skip(MyException.class)
        .skipLimit(Integer.MAX_VALUE) // 按需配置跳过上限
        .listener(myExceptionSkipListener)
        .writer(writer())
        .build();

所有需要处理MyException跳过逻辑的步骤，直接注入这个通用的SkipListener即可，无需重复写逻辑。

方案2：适配空Chunk写入场景 #

如果不想改动现有异常处理逻辑，也可以自定义writer包装类，处理空列表写入的情况，避免抛出异常触发回滚：

public class SafeItemWriter implements ItemWriter<Output> {
    // 代理你原有的writer
    private final ItemWriter<Output> delegate;

    public SafeItemWriter(ItemWriter<Output> delegate) {
        this.delegate = delegate;
    }

    @Override
    public void write(List<? extends Output> items) throws Exception {
        if (CollectionUtils.isEmpty(items)) {
            // 空列表直接返回，不执行写入逻辑
            return;
        }
        delegate.write(items);
    }
}

Step配置中用SafeItemWriter包裹你原有的writer即可：

.writer(new SafeItemWriter(writer()))

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