快捷導(dǎo)航

深入解析SpringBatch適配器

更新時(shí)間：2021年11月04日 09:24:38 作者：境里婆娑

Spring Batch是Spring的一個(gè)子項(xiàng)目,使用Java語(yǔ)言并基于Spring框架為基礎(chǔ)開(kāi)發(fā),使得已經(jīng)使用 Spring 框架的開(kāi)發(fā)者或者企業(yè)更容易訪問(wèn)和利用企業(yè)服務(wù)，本文給大家介紹SpringBatch適配器的相關(guān)知識(shí)，感興趣的朋友一起看看吧

一、SpringBatch適配器

1、SpringBatch分別有讀(reader)、處理(processor)、寫(writer)、tasklet處理器。

讀適配器：ItemReaderAdapter
處理適配器：ItemProcessorAdapter
寫適配器：ItemWriterAdapter
tasklet適配器：MethodInvokingTaskletAdapter

2、SpringBatch之所以給我們開(kāi)這么多適配器原因是讓我們把既有的服務(wù)作為參數(shù)傳到適配器里面，避免開(kāi)發(fā)重復(fù)代碼。不得不說(shuō)SpringBatch開(kāi)發(fā)人員想的真周到。

3、SpringBatch適配器都有三個(gè)公共的方法：

public Object targetObject （目標(biāo)對(duì)象，將要調(diào)用的實(shí)例）
public String targetMethod（目標(biāo)方法，將要在實(shí)例上調(diào)用的方法）
public Object[] arguments（配置選型，用于提供一組數(shù)組類型參數(shù)）

二、SpringBatch適配器實(shí)戰(zhàn)(Tasklet舉例)

演示MethodInvokingTaskletAdapter適配器

1、創(chuàng)建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適配器執(zhí)行的目標(biāo)類和方法

@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;
    }
}

3、適配器執(zhí)行目標(biāo)方法一定要先看看有沒(méi)有參數(shù)，如果有參數(shù)一定要把此方法(setArguments)設(shè)置上，否則會(huì)報(bào)"No matching arguments found for method"異常

4、執(zhí)行結(jié)果如圖所示：