Spring Batch的Job Parameters校验（五）

       Spring Batch框架提供了Job作业参数的校验功能，可以让开发者决定哪些参数是必须的，哪些参数是可选的。开发者可以自定义实现参数校验器，这需要实现接口：org.springframework.batch.core.JobParametersValidator,也可以使用框架已经提供的校验组件类。

框架提供的校验组件类：

• CompositeJobParametersValidator
• DefaultJobParametersValidator

Demo4BatchMain.java:

package com.xj.demo4;

import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.Date;


public class Demo4BatchMain {

    public static void main(String[] args) {
        Demo4BatchMain batchMain = new Demo4BatchMain();
        System.out.println("**************第一次执行  Begin**************");

        //不会报错，因为要求必须要有date参数
        batchMain.executeJob("demo4/job/demo4-job.xml", "demo4Job", "jobLauncher",new JobParametersBuilder().addDate("date",new Date()).toJobParameters());

        System.out.println("**************第一次执行  End**************");

        System.out.println("**************第二次执行  Begin**************");

        //会报错，因为没有规定有“test”参数
        batchMain.executeJob("demo4/job/demo4-job.xml", "demo4Job", "jobLauncher",new JobParametersBuilder().addDate("date",new Date()).addString("test","test parameter").toJobParameters());

        System.out.println("**************第二次执行  End**************");
    }

    
    public void executeJob(String jobXmlPath, String jobId, String jobLauncherId, JobParameters jobParameters){
        ApplicationContext context = new ClassPathXmlApplicationContext(jobXmlPath);
        //Spring Batch的作业启动器
        JobLauncher launcher = (JobLauncher) context.getBean(jobLauncherId);
        //获取要执行的Job
        Job job = (Job) context.getBean(jobId);

        try{
            //开始执行作业
            JobExecution result = launcher.run(job,jobParameters);
            //输出执行结果
            System.out.println(result.toString());
        }catch (Exception e){
            e.printStackTrace();
        }

    }
}

JobParametersTasklet.java:

package com.xj.demo4;

import org.springframework.batch.core.StepContribution;
import org.springframework.batch.core.scope.context.ChunkContext;
import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.batch.repeat.RepeatStatus;


public class JobParametersTasklet implements Tasklet {

    @Override
    public RepeatStatus execute(StepContribution stepContribution, ChunkContext chunkContext) throws Exception {

        System.out.println("进入 Job Parameters 的 Tasklet");

        return RepeatStatus.FINISHED;
    }
}

demo4-job.xml:

demo4-jobContext.xml:

    
    

    
    

    
    
        
    

    
    

    
    
        
        
            
                date
            
        
        
        
            
                name
            
        
    

这里我们使用框架提供的DefaultJobParametersValidator校验组件，其中定义了两个参数，一个是"date",为必须参数；另一个是"name"，为可选参数。