基本概念

Spring Batch是批处理框架。
作业(Job)是状态以及状态之间转换的集合。
作业里包含步骤（Spring Bean），每一个步骤解耦到独立的处理器中，并负责自己的数据，把所需的业务逻辑应用到数据上，然后把数据写入合适的位置。这样提供了灵活性、可维护性、伸缩性、可靠性。
又两类主要步骤：

步骤分类	简介	常用于
基于Tasklet的步骤	相对简单，使用Tasklet实现，在事务范围内重复执行execute方法，直到execute方法让步骤停止	初始化、运行存储过程、发送通知等
基于块Chunk的步骤	更严格，最多又三个主要部分：ItemRead、ItemProcessor、ItemWriter（条目读写处理器）	适于基于条目的处理（item-based procssing）

批处理作业的接口

接口	说明
org.springframework.batch.core.job	作业，ApplicationContext里配置
org.springframework.batch.core.step	配置的步骤
org.springframework.batch.core.step.tasklet	策略接口，提供了在一次事务范围内执行逻辑的能力
org.springframework.batch.item.ItemReader<T>	策略接口，提供步骤的输入
org.springframework.batch.item.ItemProcessor<I,O>	业务逻辑、验证等应用于单个条目
org.springframework.batch.item.ItemWriter<T>	策略接口，提供步骤的持久化

JobRepository是架构主要共享部分，负责维护作业的状态、各种处理指标，如开始时间、结束时间、状态、读写次数等，通常由RDB数据库支持。
JobLauncher组件负责作业的执行，调用execute方法，验证重启作业是否有效，决定如何执行作业（当前线程、线程池），验证参数等，与具体实现无关，开箱即用。
JobInstance是Spring Batch作业的一次逻辑执行，可由作业名称、逻辑执行提供的唯一参数集来标识。每次执行，不一定有JobInstance，除非执行标识变了。
JobExecution代表作业的一次物理执行，每次执行都会有新的JobExecution。
StepExecution是步骤的一次物理执行，一个JobExecution可以有多个StepExecution。

并行化

并行化有5种方式

方式	说明
多线程的步骤	作业被配置为以块来处理工作，每个块被封装在自己的事务中。
并行地执行步骤	两个步骤之间没有任何关系
异步的ItemProcesser/ItemWriter	AsychonousItemProcessor作为修饰器，返回Future，最后Future列表传给AsynchonousItemWriter
远程分块	跨JVM处理，主节点与远程工作者保持通信，工作者处理条目的自主写入还是发给主节点写入。JobRepository对分布式状态一无所知。
远程分取	不需要持久通信，每个工作者自包含，使用相同配置。

运行示例

先用Spring Initializr生成代码框架：

修改HelloWorldApplication.java文件：

package com.xiaolong.helloworld;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.EnableBatchProcessing;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.batch.core.scope.context.ChunkContext;
import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;@EnableBatchProcessing  // 启动批处理基础设施
@SpringBootApplication  // 启动自动配置，结合了@ComponentScan和@EnableAutoConfiguration的元注解
public class HelloWorldApplication {@Autowired  // 作业构建器private JobBuilderFactory jobBuilderFactory;@Autowired  // 步骤构建器private StepBuilderFactory stepBuilderFactory;@Beanpublic Step step() {return this.stepBuilderFactory.get("step1").tasklet(new Tasklet() {  // 内联方式实现tasklet@Overridepublic RepeatStatus execute(StepContribution contribution,ChunkContext chunkContext) throws Exception {System.out.println("Hello, World!");return RepeatStatus.FINISHED;}}).build();}@Beanpublic Job job() {return this.jobBuilderFactory.get("job").start(step()).build();}public static void main(String[] args) {SpringApplication.run(HelloWorldApplication.class, args);}}

代码主要分三部分：@EnableBatchProcessing注解、JobBuilderFactory注入、StepBuilderFactory注入。
@EnableBatchProcessing注解用来启动批处理的基础设施，大部分基础设施由Spring Bean定义，不必再提供，其中包括：
JobRepository：记录作业运行时状态。
JobLauncher：启动作业。
JobExplorer：使用JobRegistry执行制度操作。
JobRegistry：在使用特定的启动器实现时找到作业
PlatformTransactionManager：在工作过程中处理事务。
JobBuilderFactory：作业构建器。
StepBuilderFactory：步骤构建器。