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.ItemWriter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
@SpringBootApplication
public class BatchExampleApplication {
@Autowired
private JobBuilderFactory jobBuilderFactory;
@Autowired
private StepBuilderFactory stepBuilderFactory;
@Autowired
private JobLauncher jobLauncher;
// 定义Tasklet任务
@Bean
public Tasklet tasklet() {
return new Tasklet() {
@Override
public ExitStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
// 你的任务逻辑
System.out.println("Tasklet is running...");
return ExitStatus.COMPLETED;
}
};
}
// 定义ItemWriter
@Bean
public ItemWriter<String> itemWriter() {
return items -> {
for (String item : items) {
// 你的写入逻辑
System.out.println("Writing item: " + item);
}
};
}
// 创建一个Step
@Bean
public Step step() {
return stepBuilderFactory.get("step")
.tasklet(tasklet())
.build();
}
// 创建一个Job
@Bean
public Job job() {
return jobBuilderFactory.get("job")
.start(step())
.build();
}
public static void main(String[] args) {
SpringApplication.run(BatchExampleApplication.class, args);
}
}这个简单的Spring Batch示例展示了如何在Spring Boot应用程序中定义一个简单的批处理作业。它包括一个任务（Tasklet）和一个步骤（Step），并且可以通过Spring Boot应用程序的main方法启动。这个例子旨在教育开发者如何在Spring Boot中设置和运行批处理作业。