SpringBatch 配置Job之一

r囧r小猫 2022-07-12 11:13 366阅读 0赞

**Job标签的属性以及包含的子标签**

<batch:job  id=""  abstract="true"  incrementer=""  job-repository=""  parent=""  restartable="">  <batch:decision decider="" id=""></batch:decision>  <batch:description></batch:description>  <batch:flow parent="" id=""></batch:flow>  <batch:listeners></batch:listeners>  <batch:split id=""></batch:split>  <batch:step id=""></batch:step>  <batch:validator></batch:validator> </batch:job>

**Job拦截器**

SpringBatch框架在Job执行阶段提供了拦截器，使得在Job执行前后能够加入自定义的业务逻辑处理。Job执行阶段拦截器需要实现接口：org.springframework.batch.core.JobExecutionListener

JobExecutionListener 接口定义

public interface JobExecutionListener {
    
        void beforeJob(JobExecution jobExecution);
    
        void afterJob(JobExecution jobExecution);
    
    }

**配置Job拦截器**

通过属性listeners可以为Job指定拦截器列表，拦截器可以是一个或多个，如有多个，则拦截器执行顺序为配置文件中定义的顺序。

实现JobExecutionListener接口：

public class CsvJobListener implements JobExecutionListener{ 
    
        long startTime;
        long endTime;
    
        @Override
        public void beforeJob(JobExecution jobExecution) {
            startTime = System.currentTimeMillis();
            System.out.println("任务处理开始...");
        }
    
        @Override
        public void afterJob(JobExecution jobExecution) {
            endTime = System.currentTimeMillis();
            System.out.println("任务处理结束...");
            System.out.println("耗时:" + (endTime - startTime) + " ms");
        }
    
    }

**Annotation 拦截器**

Spring Batch框架提供了Annotation机制，可以不实现接口JobExecutionListener，直接通过Annotation的机制定义拦截器：

@BeforeJob  
@AfterJob

**Job Parameters 校验**

自定义参数校验器，需要实现：org.springframework.batch.core.JobParametersValidator接口，或者使用框架已经提供的校验组件类。通过参数校验，可以保证Job执行可以按照给定的参数执行，避免出现不必要的逻辑错误。

SpringBatch 框架默认提供了JobParametersValidator的实现:  
CompositeJobParametersValidato：参数校验组合模式，支持一组参数校验。  
DefaultJobParametersValidator ：参数校验默认实现，支持必须输入的参数和可以选择输入的参数。

![这里写图片描述][SouthEast]

在执行Job的时候，可以通过JobParametersBuilder构造作业参数。

executionJob("job.xml", "billJob", new JobParametersBuilder().addString("date", "20130310"));

**Job抽象与继承**

SpringBatch框架支持抽象的Job定义和Job继承特性。通过定义抽象的Job可以将Job的共性进行抽取，形成父类的Job定义，父Job通常具有较多的共性，然后各个具体的Job可以继承父类Job的特性，并定义自己的属性。通过Job的属性abstract可以定义抽象的Job，通过属性parent可以指定当前Job的父Job.

抽象Job

通过abstract属性可以定义Job为抽象的Job。抽象的Job不能被实例化，只能作为其他Job的父类。通常可以在抽象Job中定义全局性的配置，供子Job使用。

<job id="baseJob" abstract="true">
            ...
            ...
            <listeners>
                <listener ref="csvJobListener" ></listener>
            </listeners>        
        </job>

[SouthEast]: /images/20220710/5b44f15d30d94f5ea377e1d873d438b3.png