Spring Batch中如何将JobParameter传入Processor类？

错误原因 #

报错核心是手动创建的Processor实例未被Spring容器管理，导致@Scope("step")和@Value注解无法生效。Spring Batch的step级上下文（包含jobParameters）仅在step执行时初始化，而你在配置类中直接new Processor()的对象不受Spring管控，因此EL表达式无法访问到step上下文里的参数。

解决方案 #

方案一：修正Processor的Bean管理与参数注入 #

1. 调整配置类中的Processor Bean定义

确保Processor由Spring创建并标记为step作用域：

@Configuration
@EnableBatchProcessing
@AllArgsConstructor
public class SpringBatchConfig {

    private JobBuilderFactory jobBuilderFactory;
    private StepBuilderFactory stepBuilderFactory;
    private UserRepository userRepository;
    private Processor processor; // 注入Spring管理的Processor实例

    // ...其他代码不变

    @Bean
    @Scope("step")
    public Processor processors() {
        return new Processor();
    }

    @Bean
    public Step step1(){
        return stepBuilderFactory.get("csv-step").<InputUser, User>chunk(500)
                .reader(reader())
                .processor(processor) // 使用注入的实例
                .writer(writer())
                .taskExecutor(taskExecutor())
                .build();
    }

    // ...其他代码不变
}

2. 修改Processor的参数注入方式

改用从stepExecution层级获取参数，避免上下文访问问题：

@Component
@Scope("step")
public class Processor implements ItemProcessor<InputUser, User> {

    private String fileName;

    @Value("#{stepExecution.jobExecution.jobParameters['myParam']}")
    public void setFileName(String fileName) {
        this.fileName = fileName;
    }

    @Override
    public User process(InputUser item) throws Exception {
        // 此处可正常使用fileName参数
        Random random = new Random();
        return new User(random.nextInt(), item.getName(), item.getSalary());
    }
}

方案二：使用@StepScope注解（更推荐） #

Spring Batch提供的@StepScope可简化step级Bean的管理：

1. 重构Processor类

@Component
@StepScope
public class Processor implements ItemProcessor<InputUser, User> {

    private final String fileName;

    // 构造方法直接注入JobParameter
    public Processor(@Value("#{jobParameters['myParam']}") String fileName) {
        this.fileName = fileName;
    }

    @Override
    public User process(InputUser item) throws Exception {
        // 使用fileName参数
        Random random = new Random();
        return new User(random.nextInt(), item.getName(), item.getSalary());
    }
}

2. 配置类中直接注入Processor

@Configuration
@EnableBatchProcessing
@AllArgsConstructor
public class SpringBatchConfig {

    private JobBuilderFactory jobBuilderFactory;
    private StepBuilderFactory stepBuilderFactory;
    private UserRepository userRepository;
    private Processor processor; // 直接注入

    // ...其他代码不变

    @Bean
    public Step step1(){
        return stepBuilderFactory.get("csv-step").<InputUser, User>chunk(500)
                .reader(reader())
                .processor(processor)
                .writer(writer())
                .taskExecutor(taskExecutor())
                .build();
    }

    // ...其他代码不变
}

额外优化（多CSV文件场景） #

如果需要处理6个不同的CSV文件，可将文件路径作为JobParameter传入，动态配置Reader：

@Bean
@StepScope
public FlatFileItemReader<InputUser> reader(@Value("#{jobParameters['filePath']}") String filePath) {
    FlatFileItemReader<InputUser> itemReader = new FlatFileItemReader<>();
    itemReader.setResource(new FileSystemResource(filePath));
    itemReader.setName("csvReader");
    itemReader.setLinesToSkip(1);
    itemReader.setLineMapper(lineMapper());
    return itemReader;
}

启动Job时传入filePath参数即可切换处理的CSV文件。

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