import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.StepContribution;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.core.scope.context.ChunkContext;
import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.batch.item.ItemProcessor;
import org.springframework.batch.item.ItemReader;
import org.springframework.batch.item.ItemWriter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Component
public class MyBatchJobConfig {
private JobBuilderFactory jobs;
private StepBuilderFactory steps;
private ItemReader<MyInputType> reader;
private ItemProcessor<MyInputType, MyOutputType> processor;
private ItemWriter<MyOutputType> writer;
@Autowired
public MyBatchJobConfig(JobBuilderFactory jobs, StepBuilderFactory steps,
ItemReader<MyInputType> reader,
ItemProcessor<MyInputType, MyOutputType> processor,
ItemWriter<MyOutputType> writer) {
this.jobs = jobs;
this.steps = steps;
this.reader = reader;
this.processor = processor;
this.writer = writer;
}
public Job getJob(JobLauncher jobLauncher) {
return jobs.get("myJob")
.start(buildStep())
.build();
}
private Step buildStep() {
return steps.get("myStep")
.<MyInputType, MyOutputType>chunk(10)
.reader(reader)
.processor(processor)
.writer(writer)
.build();
}
}这个代码示例展示了如何使用Spring Batch的注解和Java配置来定义一个简单的批处理作业。这里的MyBatchJobConfig类通过自动装配方式接收了JobBuilderFactory、StepBuilderFactory以及批处理步骤中需要用到的ItemReader、ItemProcessor和ItemWriter。然后，它定义了一个作业，该作业由一个步骤组成，步骤中包含了对这些组件的引用。这个简单的例子展示了如何将Spring Batch集成到Spring应用程序中去。