深入解析SpringBatch适配器

Spring Batch是Spring的一个子项目,使用Java语言并基于Spring框架为基础开发,使得已经使用 Spring 框架的开发者或者企业更容易访问和利用企业服务，本文给大家介绍SpringBatch适配器的相关知识

Spring Batch是Spring的一个子项目,使用Java语言并基于Spring框架为基础开发,使得已经使用 Spring 框架的开发者或者企业更容易访问和利用企业服务，本文给大家介绍SpringBatch适配器的相关知识，感兴趣的朋友一起看看吧

一、SpringBatch适配器

1、SpringBatch分别有读(reader)、处理(processor)、写(writer)、tasklet处理器。

读适配器：ItemReaderAdapter
处理适配器：ItemProcessorAdapter
写适配器：ItemWriterAdapter
tasklet适配器：MethodInvokingTaskletAdapter

2、SpringBatch之所以给我们开这么多适配器原因是让我们把既有的服务作为参数传到适配器里面，避免开发重复代码。不得不说SpringBatch开发人员想的真周到。

3、SpringBatch适配器都有三个公共的方法：

public Object targetObject （目标对象，将要调用的实例）
public String targetMethod（目标方法，将要在实例上调用的方法）
public Object[] arguments（配置选型，用于提供一组数组类型参数）

二、SpringBatch适配器实战(Tasklet举例)

演示MethodInvokingTaskletAdapter适配器

1、创建Job配置TaskletAdapterConfiguration

				?

									@Configuration

									@EnableBatchProcessing

									public class TaskletAdapterConfiguration {

									    @Autowired

									    private JobBuilderFactory jobBuilderFactory;

									    @Autowired

									    private StepBuilderFactory stepBuilderFactory;

									    @Autowired

									    public PeopleService peopleService;

									    @Bean

									    public Job taskletAdapterJob() {

									        return jobBuilderFactory.get("taskletAdapterJob")

									                .start(taskletAdapterStep())

									                .build();

									    }

									    @Bean

									    public Step taskletAdapterStep() {

									        return stepBuilderFactory.get("taskletAdapterStep")

									                .tasklet(methodInvokingTaskletAdapter())

									                .build();

									    }

									    @Bean

									    public MethodInvokingTaskletAdapter methodInvokingTaskletAdapter() {

									        MethodInvokingTaskletAdapter adapter = new MethodInvokingTaskletAdapter();

									        adapter.setTargetObject(peopleService);

									        adapter.setTargetMethod("upperCase");

									        adapter.setArguments(new Object[]{new People("lee","10","北京","1233")});

									        return adapter;

									    }

									}

2、Tasklet适配器执行的目标类和方法

				?

									@Service

									public class PeopleService {

									    public People upperCase(People people) {

									         People p = new People();

									         p.setName(people.getName().toUpperCase(Locale.ROOT));

									         p.setAdress(people.getAdress().toUpperCase(Locale.ROOT));

									         p.setAge(people.getAge());

									         p.setIdCard(people.getIdCard());

									        System.out.println("p：" + p);

									         return p;

									    }

									}