Spring Batch自定义ListItemReader初始化及执行异常问题咨询

当前实现的问题完全出在生命周期逻辑错位：

• 构造函数提前把list初始化为空ArrayList，导致read()里list == null的初始化判断除了手动置空的场景外永远不会触发
• 初始化、重置逻辑不该放在read()方法里：Spring Batch对ItemReader的约定是方法返回null即代表当前步骤所有数据读取完成，你在list为空的分支里把list置为null，会让后续可能的重试、重启场景重新触发初始化，从头开始读数据，直接触发无限循环
• 用list.remove(0)弹出元素的写法性能很差，ArrayList头删是O(n)复杂度，文件量大的时候卡顿明显

Spring Batch提供的StepExecutionListener生命周期回调本来就是用来处理步骤前后的初始化、资源清理逻辑的，beforeStep触发时作业上下文、步骤上下文已经完全加载完成，根本不需要在read()里做懒初始化。
直接把初始化逻辑移到beforeStep，清理逻辑移到afterStep，用索引指针记录读取位置即可，修正后的代码如下：

public class CustomFileListItemReader implements ItemReader<Path>, StepExecutionListener {

    private List<Path> fileList;
    private int readIndex = 0;
    private JobExecution jobExecution;

    @Nullable
    @Override
    public Path read() {
        if (readIndex < fileList.size()) {
            return fileList.get(readIndex++);
        }
        return null;
    }

    @Override
    public void beforeStep(StepExecution stepExecution) {
        // 此节点上下文已完全就绪，直接读取参数初始化即可
        this.jobExecution = stepExecution.getJobExecution();
        String targetDirPath = jobExecution.getExecutionContext().getString(Constants.CONTEXT_PATH);
        Path targetDir = Paths.get(targetDirPath);

        this.fileList = new ArrayList<>();
        // 替换成你自己的目录遍历规则
        try (Stream<Path> fileStream = Files.walk(targetDir)) {
            fileStream.filter(Files::isRegularFile)
                    .forEach(fileList::add);
        } catch (IOException e) {
            throw new IllegalArgumentException("目标目录遍历失败: " + targetDirPath, e);
        }
        this.readIndex = 0;
    }

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {
        // 步骤执行完成后清理状态，支持后续作业复用当前Reader实例
        this.fileList = null;
        this.readIndex = 0;
        this.jobExecution = null;
        return ExitStatus.COMPLETED;
    }
}

• read()方法只做纯粹的读逻辑，不要掺杂任何初始化、资源销毁、状态重置的代码，这个方法会被框架高频调用，掺杂额外逻辑很容易出现时序bug
• 不要修改待读取列表的结构，用递增索引读取的方式性能更好，后续如果要实现断点续跑，直接把readIndex存入步骤执行上下文即可，不需要额外处理列表状态
• 如果你的Reader是原型作用域（每次作业创建新实例），连afterStep里的清理逻辑都可以省略，初始化逻辑放在beforeStep里就不会出现时序问题

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