我正在使用Spring Boot + Spring Batch(注释),遇到了必须运行2个作业的场景。
我有员工和薪水记录,需要使用春季批处理进行更新。我已经BatchConiguration
按照本教程的spring-batch Employee和Salary对象入门教程(分别名为BatchConfigurationEmployee和BatchConfigurationSalary)配置了类。
我已经定义了ItemReader
,ItemProcessor
,ItemWriter
并Job
按照这上面已经提到的教程。
当我启动Spring Boot应用程序时,将运行两个Job之一,我想同时运行两个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();
}
}
在整个Spring Context中,Bean的名称必须唯一。
在这两个作业中,您都使用相同的方法名实例化读取器,写入器和处理器。methodname是用于在上下文中标识Bean的名称。
在两个作业定义中,您都有reader(),writer()和processor()。他们会互相覆盖。给他们唯一的名称,如readerEmployee(),readerSalary()等。
那应该解决您的问题。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句