如何向Spring Batch Job传递参数以执行对应文件处理步骤

嘿，刚好我对Spring Batch参数传递这块比较熟，来给你一步步讲清楚怎么实现你的需求——通过传入文件名参数，让Job自动执行对应文件的步骤序列～

不管你是用命令行启动、代码触发还是接口调用，都能轻松传递参数：

• 命令行启动（Spring Boot场景）：直接在启动命令里加参数，比如：

  java -jar your-batch-app.jar --spring.batch.job.names=fileProcessingJob --fileName=FileA
  

  这里--fileName=FileA就是传递的参数，spring.batch.job.names指定要执行的Job名称。
• Java代码触发：用JobParametersBuilder构建参数，然后通过JobLauncher执行：

  @Autowired
  private JobLauncher jobLauncher;
  @Autowired
  private Job fileProcessingJob;
  
  public void runJobForFile(String fileName) throws Exception {
      JobParameters jobParams = new JobParametersBuilder()
              .addString("fileName", fileName)
              // 可选：加timestamp避免重复执行同一参数的Job
              .addLong("timestamp", System.currentTimeMillis())
              .toJobParameters();
      jobLauncher.run(fileProcessingJob, jobParams);
  }
  

• 接口调用（比如REST接口）：如果是Web场景，可以写个接口接收文件名，然后用上面的代码逻辑触发Job。

核心是用JobExecutionDecider做分支判断，把不同文件的步骤封装成独立的Flow，再根据参数跳转到对应的Flow：

1. 先封装各个文件的步骤链为Flow #

把FileA、FileB、FileC的步骤分别打包成Flow，这样结构更清晰：

@Bean
public Flow fileAFlow() {
    return new FlowBuilder<SimpleFlow>("fileAFlow")
            .start(fileAStep1()) // 你已定义的FileA-Step1
            .next(fileAStep2())  // FileA-Step2
            .next(fileAStep3())  // FileA-Step3
            .build();
}

@Bean
public Flow fileBFlow() {
    return new FlowBuilder<SimpleFlow>("fileBFlow")
            .start(fileBStep1())
            .next(fileBStep2())
            // 按你的需求加对应步骤
            .build();
}

// 同理定义fileCFlow...

2. 实现决策器（Decider）判断参数 #

写一个Decider类，读取传入的fileName参数，返回对应的状态标记：

@Component
public class FileNameDecider implements JobExecutionDecider {
    @Override
    public FlowExecutionStatus decide(JobExecution jobExecution, StepExecution stepExecution) {
        String fileName = jobExecution.getJobParameters().getString("fileName");
        if (fileName == null) {
            return FlowExecutionStatus.FAILED; // 没有参数直接失败
        }
        switch (fileName) {
            case "FileA":
                return new FlowExecutionStatus("PROCESS_FILE_A");
            case "FileB":
                return new FlowExecutionStatus("PROCESS_FILE_B");
            case "FileC":
                return new FlowExecutionStatus("PROCESS_FILE_C");
            default:
                return FlowExecutionStatus.FAILED; // 未知文件名返回失败
        }
    }
}

3. 构建带分支的Job #

把Decider和各个Flow整合到Job里，实现动态跳转：

@Bean
public Job fileProcessingJob(JobBuilderFactory jobBuilderFactory,
                             FileNameDecider fileNameDecider,
                             Flow fileAFlow, Flow fileBFlow, Flow fileCFlow) {
    return jobBuilderFactory.get("fileProcessingJob")
            .start(fileNameDecider) // 先执行决策器
            .on("PROCESS_FILE_A").to(fileAFlow) // 匹配到FileA的状态，执行对应Flow
            .on("PROCESS_FILE_B").to(fileBFlow)
            .on("PROCESS_FILE_C").to(fileCFlow)
            .on("FAILED").fail() // 失败状态直接终止Job
            .on("*").end() // 其他状态结束Job
            .build();
}

如果你的Reader/Processor需要用到文件名参数，可以用@StepScope和SpEL表达式注入：

@Bean
@StepScope // 必须加这个注解，才能在步骤运行时获取参数
public FlatFileItemReader<FileAEntity> fileAReader(@Value("#{jobParameters['fileName']}") String fileName) {
    return new FlatFileItemReaderBuilder<FileAEntity>()
            .name("fileAReader")
            .resource(new FileSystemResource(fileName)) // 直接用传入的文件名
            // 配置字段映射等
            .build();
}

这样一来，你传入不同的文件名参数，Job就会自动执行对应的步骤序列啦～

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