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

2019-07-22 15:20:34 阅读：155 来源： 互联网

标签：java spring spring-boot spring-batch

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

我有需要使用spring批处理更新的Employee和Salary记录.我按照本教程spring-batch getting started tutorial为Employee和Salary对象配置了BatchConiguration类,分别命名为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();
    }
}

解决方法:

Bean的名称在整个Spring Context中必须是唯一的.

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

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

那应该可以解决你的问题.

标签：java,spring,spring-boot,spring-batch
来源： https://codeday.me/bug/20190722/1503724.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

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