Spring boot batch :如何使用作业参数运行作业

# application.properties
job.name=myJob
job.input.file=path/to/input/file.csv

# application.yml
job:
  name: myJob
  input:
    file: path/to/input/file.csv

import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@EnableBatchProcessing
public class BatchConfig {

    @Value("${job.name}")
    private String jobName;

    @Value("${job.input.file}")
    private String inputFilePath;

    @Bean
    public Job job(JobBuilderFactory jobBuilderFactory, Step step) {
        return jobBuilderFactory.get(jobName)
                .start(step)
                .build();
    }

    @Bean
    public Step step(StepBuilderFactory stepBuilderFactory) {
        return stepBuilderFactory.get("step1")
                .<String, String>chunk(10)
                .reader(reader(inputFilePath))
                .writer(writer())
                .build();
    }

    @Bean
    public ItemReader<String> reader(String filePath) {
        // 实现自定义的 ItemReader
        return new CustomItemReader(filePath);
    }

    @Bean
    public ItemWriter<String> writer() {
        // 实现自定义的 ItemWriter
        return new CustomItemWriter();
    }
}

java -jar mybatchapp.jar --job.name=myJob --job.input.file=path/to/input/file.csv

import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class JobRunner {

    @Autowired
    private JobLauncher jobLauncher;

    @Autowired
    private Job job;

    public void runJob() throws Exception {
        JobParameters jobParameters = new JobParametersBuilder()
                .addLong("time", System.currentTimeMillis())
                .toJobParameters();
        jobLauncher.run(job, jobParameters);
    }
}