Spring Batch框架工作原理

SpringBatch框架。它包含以下主要構建塊

一個 Batch(批處理)過程由一個 Job(作業)組成。這個實體封裝了整個批處理過程。

一個 Job(作業)可以由一個或多個 Step(步驟)組成。在大多數情況下,一個步驟將讀取數據(通過 ItemReader),處理數據(使用 ItemProcessor),然后寫入數據(通過 ItemWriter)。

JobLauncher處理啟動一個 Job(作業)。

JobRepository存儲關于配置和執行的 Job(作業)的元數據。

示例

pom依賴

        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-batch</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.batch</groupId>            <artifactId>spring-batch-test</artifactId>            <scope>test</scope>        </dependency>        <dependency>            <groupId>MySQL</groupId>            <artifactId>mysql-connector-java</artifactId>            <version>8.0.15</version>        </dependency>

配置 Spring Batch Job

創建一個 BatchConfig類,它將配置Spring Batch。類頂部的@Configuration注解表明Spring可以使用該類作為bean定義的源。

我們添加了@EnableBatchProcessing注解,它支持所有所需 SpringBatch特性。它還提供了設置批處理作業的基本配置。

通過添加這個注解會需要很多操作。下面是 @EnableBatchProcessing創建的概述:

• JobRepository (bean名稱 "jobRepository")

• JobLauncher (bean名稱 "jobLauncher")

• JobRegistry (bean名稱 "jobRegistry")

• JobExplorer (bean名稱 "jobExplorer")

• PlatformTransactionManager (bean名稱 "transactionManager")

• JobBuilderFactory (bean名稱"jobBuilders"),它可以方便地防止您必須將作業存儲庫注入到每個Job(作業)中

• StepBuilderFactory (bean名稱 "stepBuilders"),以方便您避免將作業存儲庫和事務管理器注入到每個Step(步驟)中

為了使 SpringBatch使用基于Map的 JobRepository,我們需要擴展 DefaultBatchConfigurer。重寫 setDataSource()方法以不設置 DataSource。這將導致自動配置使用基于Map的 JobRepository。

import org.springframework.batch.core.configuration.annotation.DefaultBatchConfigurer;import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;import org.springframework.context.annotation.Configuration;@Configuration@EnableBatchProcessingpublic class BatchConfig extends DefaultBatchConfigurer {}

配置Hello World Spring Batch 作業

@Configurationpublic class HelloWorldJobConfig {    @Bean    public Job helloWorlJob(JobBuilderFactory jobBuilders, StepBuilderFactory stepBuilders) {        return jobBuilders.get("helloWorldJob").start(helloWorldStep(stepBuilders)).build();    }    @Bean    public Step helloWorldStep(StepBuilderFactory stepBuilders) {        return stepBuilders.get("helloWorldStep").<Person, String>chunk(10)                .reader(reader()).processor(processor()).writer(writer()).build();    }    @Bean    public FlatFileItemReader<Person> reader() {        return new FlatFileItemReaderBuilder<Person>().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<String> writer() {        return new FlatFileItemWriterBuilder<String>().name("greetingItemWriter")                .resource(new FileSystemResource("txt/greetings.txt"))                .lineAggregator(new PassThroughLineAggregator<>()).build();    }}

處理數據

public class PersonItemProcessor implements ItemProcessor<Person, String> {    private static final Logger LOGGER = LoggerFactory.getLogger(PersonItemProcessor.class);    @Override    public String process(Person person) throws Exception {        String greeting = "Hello " + person.getFirstName() + " " + person.getLastName() + "!";        LOGGER.info("converting '{}' into '{}'", person, greeting);        return greeting;    }}

測試Spring Batch 示例

使用 @RunWith和 @SpringBootTest測試注解告訴 JUnit使用Spring的測試支持運行,并使用SpringBoot的支持引導。

SpringBatch附帶一個 JobLauncherTestUtils實用程序類,用于測試批處理作業。

我們首先創建一個內部 BatchTestConfig類,將helloWorld作業添加到 JobLauncherTestUtils bean中。然后使用此bean的 launchJob()方法運行批處理作業。

如果執行的作業沒有任何錯誤,則 ExitCode的值為 COMPLETED。

@RunWith(SpringRunner.class)@SpringBootTest(classes = {XcSpringbootApplicationTests.BatchTestConfig.class})public class XcSpringbootApplicationTests {    @Autowired    private JobLauncherTestUtils jobLauncherTestUtils;    @Test    public void testHelloWorldJob() throws Exception {        JobExecution jobExecution = jobLauncherTestUtils.launchJob();        assertThat(jobExecution.getExitStatus().getExitCode()).isEqualTo("COMPLETED");    }    @Configuration    @Import({BatchConfig.class, HelloWorldJobConfig.class})    static class BatchTestConfig {        @Autowired        private Job helloWorlJob;        @Bean        JobLauncherTestUtils jobLauncherTestUtils() throws NoSuchJobException {            JobLauncherTestUtils jobLauncherTestUtils = new JobLauncherTestUtils();            jobLauncherTestUtils.setJob(helloWorlJob);            return jobLauncherTestUtils;        }    }}

參考:https://codenotfound.com/spring-batch-example.html