一、概述
Spring Batch是一个轻量级，全面的批处理框架。
一个典型的批处理过程可能是：
Spring Batch 应用架构图：
一个Batch(批处理)过程由一个Job(作业)组成。这个实体封装了整个批处理过程。
一个Job(作业)可以由一个或多个Step(步骤)组成。在大多数情况下，一个步骤将读取数据(通过ItemReader)，处理数据(使用ItemProcessor)，然后写入数据(通过ItemWriter)。
JobLauncher处理启动一个Job(作业)。
最后，JobRepository存储关于配置和执行的Job(作业)的元数据。
二、实例
1、新建 springboot项目
创建项目传送门
选择配置，添加依赖，GENERATE 后导入到你的IDE
2、springboot 项目配置
2.1 在新建项目时添加依赖了，就会发现pom中引入了 spring-barch的相关依赖，如新建项目时没有添加依赖，则需要手动添加。
//pom.xmlorg.springframework.boot spring-boot-starter-batch org.springframework.boot spring-boot-starter-test test org.junit.vintage junit-vintage-engine org.springframework.batch spring-batch-test test org.springframework.boot spring-boot-maven-plugin
2.2 为主程序的@SpringBootApplication注解添加exclude属性，可以防止 SpringBoot 为数据库连接自动配置 DataSource
//主程序
@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
public class Springbatch2020829Application {
public static void main(String[] args) {
SpringApplication.run(Springbatch2020829Application.class, args);
}
}
2.3 新建实体model
//Person.java
public class Person {
private String firstName;
private String lastName;
}
//构造函数，get,set方法, toString()方法略
2.4 配置 Spring Batch Job
2.4.1 新建 BatchConfig 类，重写父类 setDataSource 方法
//BatchConfig.java
@Configuration
@EnableBatchProcessing
public class BatchConfig extends DefaultBatchConfigurer {
@Override
public void setDataSource(DataSource dataSource) {
}
}
2.4.2 新建 HelloWorldJobConfig 类，配置 job ，step
//HelloWorldJobConfig.java
@Configuration
public class HelloWorldJobConfig {
//新建 Job，Spring 将自动注入 jobBuilders ,stepBuilders两个 beans
@Bean
public Job helloWorlJob(JobBuilderFactory jobBuilders,
StepBuilderFactory stepBuilders) {
return jobBuilders.get("helloWorldJob")
.start(helloWorldStep(stepBuilders)).build();
}
//新建 Step，使用 StepBuilderFactory 创建
@Bean
public Step helloWorldStep(StepBuilderFactory stepBuilders) {
return stepBuilders.get("helloWorldStep")
.chunk(10).reader(reader())
.processor((Function<&＃63; super Person, &＃63; extends String>) processor()).writer(writer()).build();
}
//读取数据，指定需要读取的资源
@Bean
public FlatFileItemReader reader() {
return new FlatFileItemReaderBuilder()
.name("personItemReader")
.resource(new ClassPathResource("csv/persons.csv"))
.delimited().names(new String[] {"firstName", "lastName"})
.targetType(Person.class).build();
}
//处理数据
@Bean
public PersonItemProcessor processor() {
return new PersonItemProcessor();
}
//写入数据，指定写入路径文件
@Bean
public FlatFileItemWriter writer() {
return new FlatFileItemWriterBuilder()
.name("greetingItemWriter")
.resource(new FileSystemResource(
"target/test-outputs/greetings.txt"))
.lineAggregator(new PassThroughLineAggregator<>()).build();
}
}
2.5 处理数据
京公网安备 11010802041100号