Spring Batch中能否分两步复用自定义Tasklet处理不同文件路径？

当然可以在不同Step中复用同一个Tasklet类来处理不同参数！关键是要保证每个Step使用的是独立的Tasklet实例（或者通过作用域隔离参数），避免参数互相覆盖。结合你给出的代码，我给你两种可行的实现方案：

方案一：用工厂方法创建独立Tasklet实例 #

这种方式最简单直接，完全适配你的场景——你的Tasklet逻辑明确，就是接收fromPath和toPath执行文件移动操作。

首先，把你的fileAllocationTasklet改成普通的工厂方法（不要加@Bean注解，否则Spring会把它当成单例，多次调用返回同一个实例）：

// 普通工厂方法，每次调用都返回新的Tasklet实例
public FileAllocationTasklet fileAllocationTasklet(String fromPath, String toPath) {
    FileAllocationTasklet tasklet = new FileAllocationTasklet();
    tasklet.setFromPath(fromPath);
    tasklet.setToPath(toPath);
    return tasklet;
}

然后在定义Step的时候，直接调用这个工厂方法传入不同参数即可，每个Step都会拿到独立的Tasklet实例，参数完全隔离：

@Bean
public Step step1() {
    return stepBuilderFactory.get("step1")
            .tasklet(fileAllocationTasklet("input/source.csv", "temp/processed.csv"))
            .build();
}

@Bean
public Step step3() {
    System.out.println("******step3 executing ");
    return stepBuilderFactory.get("step3")
            .tasklet(fileAllocationTasklet("process/data.csv","output/data.csv"))
            .build();
}

方案二：用Step级作用域（@Scope("step")）实现参数隔离 #

如果你的Tasklet需要依赖Spring容器中的其他Bean（比如文件系统资源管理器、数据库连接等），可以用Step作用域来实现复用，同时通过StepExecutionContext传递参数。

首先，把Tasklet标记为Step作用域，并通过SpEL表达式读取参数：

@Component
@Scope("step") // 标记为Step级作用域，每次Step执行都会创建新实例
public class FileAllocationTasklet implements Tasklet {

    // 从Step执行上下文读取参数
    @Value("#{stepExecutionContext['fromPath']}")
    private String fromPath;

    @Value("#{stepExecutionContext['toPath']}")
    private String toPath;

    // 这里可以注入其他Spring管理的Bean，比如ResourceLoader等
    // @Autowired
    // private ResourceLoader resourceLoader;

    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
        // 执行文件移动逻辑
        Files.move(Paths.get(fromPath), Paths.get(toPath), StandardCopyOption.REPLACE_EXISTING);
        return RepeatStatus.FINISHED;
    }

    // 可选：getter/setter，用@Value的话可以不用
}

然后在定义Step时，通过Step监听器把参数放入StepExecutionContext：

@Bean
public Step step1(FileAllocationTasklet fileAllocationTasklet) {
    return stepBuilderFactory.get("step1")
            .tasklet(fileAllocationTasklet)
            .listener(new StepExecutionListener() {
                @Override
                public void beforeStep(StepExecution stepExecution) {
                    // 传入当前Step的参数
                    stepExecution.getExecutionContext().put("fromPath", "input/source.csv");
                    stepExecution.getExecutionContext().put("toPath", "temp/processed.csv");
                }

                @Override
                public ExitStatus afterStep(StepExecution stepExecution) {
                    return null;
                }
            })
            .build();
}

@Bean
public Step step3(FileAllocationTasklet fileAllocationTasklet) {
    System.out.println("******step3 executing ");
    return stepBuilderFactory.get("step3")
            .tasklet(fileAllocationTasklet)
            .listener(new StepExecutionListener() {
                @Override
                public void beforeStep(StepExecution stepExecution) {
                    stepExecution.getExecutionContext().put("fromPath", "process/data.csv");
                    stepExecution.getExecutionContext().put("toPath", "output/data.csv");
                }

                @Override
                public ExitStatus afterStep(StepExecution stepExecution) {
                    return null;
                }
            })
            .build();
}

注意事项 #

• 如果用方案一，绝对不能给工厂方法加@Bean，否则Spring会将Tasklet注册为单例，多次调用会返回同一个实例，后面的参数会覆盖前面的。
• 方案二的Step作用域是Spring Batch提供的特性，只要你用了Spring Boot的自动配置，就不需要额外配置作用域支持。

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