如何使用批注在Spring Batch中运行多个作业

问题描述 投票:5回答:3

我正在使用Spring Boot + Spring Batch(注释),遇到了我必须运行2个作业的场景。

我有员工和薪水记录,需要使用春季批处理进行更新。通过按照本教程BatchConiguration为Employee和Salary对象(分别命名为BatchConfigurationEmployee和BatchConfigurationSalary)配置了spring-batch getting started tutorial类。

我已经按照上面已经提到的教程定义了ItemReaderItemProcessorItemWriterJob

当我启动我的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();
    }
}
java spring spring-boot spring-batch
3个回答
10
投票

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

在两个作业中,您都使用相同的方法名实例化读取器,写入器和处理器。 methodname是用于在上下文中标识Bean的名称。

在两个作业定义中,您都有reader(),writer()和processor()。他们会互相覆盖。给他们唯一的名称,例如readerEmployee(),readerSalary()等。

应该可以解决您的问题。


1
投票

您的作业未使用@Bean进行注释,因此spring上下文不知道它们。

看看类JobLauncherCommandLineRunner。 SpringContext中实现Job接口的所有Bean都将被注入。找到的所有作业将被执行。 (这发生在JobLauncherCommandLineRunner中的executeExecuteJobs方法内部)

[如果由于某种原因,您不想在上下文中将它们作为bean,那么您必须在jobregistry中注册您的作业。(该方法执行JobLauncherCommandLineRunner的registeredJobs将负责启动已注册的作业)] >

顺便说一句,您可以使用属性进行控制

spring.batch.job.names= # Comma-separated list of job names to execute on startup (For instance
 `job1,job2`). By default, all Jobs found in the context are executed.

应启动哪些作业。


0
投票

我认为这也是运行多个Jobs的一种很好的方法。

© www.soinside.com 2019 - 2024. All rights reserved.