我正在使用Spring Boot + Spring Batch(注释),遇到了我必须运行2个作业的场景。
我有员工和薪水记录,需要使用春季批处理进行更新。通过按照本教程BatchConiguration
为Employee和Salary对象(分别命名为BatchConfigurationEmployee和BatchConfigurationSalary)配置了spring-batch getting started tutorial类。
我已经按照上面已经提到的教程定义了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上下文中必须是唯一的。
在两个作业中,您都使用相同的方法名实例化读取器,写入器和处理器。 methodname是用于在上下文中标识Bean的名称。
在两个作业定义中,您都有reader(),writer()和processor()。他们会互相覆盖。给他们唯一的名称,例如readerEmployee(),readerSalary()等。
应该可以解决您的问题。
您的作业未使用@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.
应启动哪些作业。
我认为这也是运行多个Jobs的一种很好的方法。