如何使用注释在spring批处理中运行多个作业

Question

我正在使用Spring Boot+Spring Batch（注释），遇到了一个我必须运行2个作业的场景。

我有员工和工资记录，需要使用spring批处理更新。我已经按照本教程spring-batch入门教程为Employee和Salary对象配置了BatchConfigurationEmployee和BatchConfigurationSalary类。

我已经按照上面已经提到的教程定义了itemreader、itemprocessor、itemwriter和job。

当我启动Spring Boot应用程序时，两个作业中的任何一个运行，我都希望运行两个BatchConfigured类。我怎样才能做到这一点

********* BatchConfigurationEmployee.java *************

@Configuration
@EnableBatchProcessing
public class BatchConfigurationEmployee {
    public ItemReader<employee> reader() {
        return new EmployeeItemReader();
    }

    @Bean
    public ItemProcessor<Employee, Employee> processor() {
        return new EmployeeItemProcessor();
    }

    @Bean   
    public Job Employee(JobBuilderFactory jobs, Step s1) {
        return jobs.get("Employee")
                .incrementer(new RunIdIncrementer())
                .flow(s1)
                .end()
                .build();
    }

    @Bean
    public Step step1(StepBuilderFactory stepBuilderFactory, ItemReader<Employee> reader,
                    ItemProcessor<Employee, Employee> processor) {
        return stepBuilderFactory.get("step1")
                .<Employee, Employee> chunk(1)
                .reader(reader)
                .processor(processor)
                .build();
    }
}

工资等级在这里

@Configuration
@EnableBatchProcessing
public class BatchConfigurationSalary {
    public ItemReader<Salary> reader() {
        return new SalaryItemReader();
    }

    @Bean
    public ItemProcessor<Salary, Salary> processor() {
        return new SalaryItemProcessor();
    }

    @Bean
    public Job salary(JobBuilderFactory jobs, Step s1) {
        return jobs.get("Salary")
                .incrementer(new RunIdIncrementer())
                .flow(s1)
                .end()
                .build();
    }

    @Bean
    public Step step1(StepBuilderFactory stepBuilderFactory, ItemReader<Salary> reader,
                    ItemProcessor<Salary, Salary> processor) {
        return stepBuilderFactory.get("step1")
                .<Salary, Salary> chunk(1)
                .reader(reader)
                .processor(processor)
                .build();
    }
}




Answer 1

bean的名称在整个Spring上下文中必须是唯一的。

在这两个作业中，您都使用相同的methodName实例化读取器、写入器和处理器。methodname是用于在上下文中标识bean的名称。

在这两个作业定义中，都有reader()、writer()和processor（）。它们会互相覆盖。给它们取唯一的名字，比如readerEmployee()、readerSalary()等等。

那应该能解决你的问题了。