本文共 7887 字，大约阅读时间需要 26 分钟。
– Start
Spring 支持如下监听器。
| 监听器 | 说明 |
| JobExecutionListener | 在 Job 开始之前(beforeJob)和之后(afterJob)触发 |
| StepExecutionListener | 在 Step 开始之前(beforeStep)和之后(afterStep)触发 |
| ChunkListener | 在 Chunk 开始之前(beforeChunk)，之后(afterChunk)和错误后(afterChunkError)触发 |
| ItemReadListener | 在 Read 开始之前(beforeRead)，之后(afterRead)和错误后(onReadError)触发 |
| ItemProcessListener | 在 Read 开始之前(beforeProcess)，之后(afterProcess)和错误后(onProcessError)触发 |
| ItemWriteListener | 在 Read 开始之前(beforeWrite)，之后(afterWrite)和错误后(onWriteError)触发 |
| SkipListener | 在 Read 开始之前(beforeWrite)，之后(afterWrite)和错误后(onWriteError)触发 |
来看个简单的例子。
package shangbo.springbatch.example6;import org.springframework.batch.core.JobExecution;import org.springframework.batch.core.JobExecutionListener;public class SimpleJobExecutionListener implements JobExecutionListener { @Override public void beforeJob(JobExecution jobExecution) { System.out.println("SimpleJobExecutionListener.beforeJob"); } @Override public void afterJob(JobExecution jobExecution) { System.out.println("SimpleJobExecutionListener.afterJob"); }} package shangbo.springbatch.example6;import org.springframework.batch.core.ExitStatus;import org.springframework.batch.core.StepExecution;import org.springframework.batch.core.StepExecutionListener;public class SimpleStepExecutionListener implements StepExecutionListener { @Override public void beforeStep(StepExecution stepExecution) { System.out.println("SimpleStepExecutionListener.beforeStep"); } @Override public ExitStatus afterStep(StepExecution stepExecution) { System.out.println("SimpleStepExecutionListener.afterStep"); return stepExecution.getExitStatus(); }} package shangbo.springbatch.example6;import org.springframework.batch.core.ChunkListener;import org.springframework.batch.core.scope.context.ChunkContext;public class SimpleChunkListener implements ChunkListener { @Override public void beforeChunk(ChunkContext context) { System.out.println("SimpleChunkListener.beforeChunk"); } @Override public void afterChunk(ChunkContext context) { System.out.println("SimpleChunkListener.afterChunk"); } @Override public void afterChunkError(ChunkContext context) { System.out.println("SimpleChunkListener.afterChunkError"); }} package shangbo.springbatch.example6;import org.springframework.batch.core.ItemReadListener;public class SimpleItemReadListener implements ItemReadListener { @Override public void beforeRead() { System.out.println("SimpleItemReadListener.beforeRead"); } @Override public void afterRead(People item) { System.out.println("SimpleItemReadListener.afterRead -- " + item.getName()); } @Override public void onReadError(Exception ex) { System.out.println("SimpleItemReadListener.onReadError"); }}
package shangbo.springbatch.example6;import org.springframework.batch.core.ItemProcessListener;public class SimpleItemProcessListener implements ItemProcessListener { @Override public void beforeProcess(People item) { System.out.println("SimpleItemProcessListener.beforeProcess"); } @Override public void afterProcess(People item, People result) { System.out.println("SimpleItemProcessListener.afterProcess -- " + result.getName()); } @Override public void onProcessError(People item, Exception e) { System.out.println("SimpleItemProcessListener.onProcessError"); }}
package shangbo.springbatch.example6;import java.util.List;import org.springframework.batch.core.ItemWriteListener;public class SimpleItemWriteListener implements ItemWriteListener { @Override public void beforeWrite(List items) { System.out.println("SimpleItemWriteListener.beforeWrite"); } @Override public void afterWrite(List items) { System.out.println("SimpleItemWriteListener.afterWrite"); } @Override public void onWriteError(Exception exception, List items) { System.out.println("SimpleItemWriteListener.onWriteError"); }}
package shangbo.springbatch.example6;import org.springframework.batch.core.SkipListener;public class SimpleSkipListener implements SkipListener { @Override public void onSkipInRead(Throwable t) { System.out.println("SimpleSkipListener.onSkipInRead"); } @Override public void onSkipInWrite(People item, Throwable t) { System.out.println("SimpleSkipListener.onSkipInWrite"); } @Override public void onSkipInProcess(String item, Throwable t) { System.out.println("SimpleSkipListener.onSkipInProcess"); }}
header footer
package shangbo.springbatch.example6;public class People implements java.io.Serializable{ private static final long serialVersionUID = 8904705906008476310L; private Integer id; private String name; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; }} package shangbo.springbatch.example6;import java.util.HashMap;import java.util.Map;import org.springframework.batch.core.Job;import org.springframework.batch.core.JobParameter;import org.springframework.batch.core.JobParameters;import org.springframework.batch.core.JobParametersInvalidException;import org.springframework.batch.core.launch.JobLauncher;import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;import org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;import org.springframework.batch.core.repository.JobRestartException;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;public class App { public static void main(String[] args) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException, JobParametersInvalidException { ApplicationContext context = new ClassPathXmlApplicationContext("shangbo/springbatch/example6/LoadFileJob.xml"); // job 和 job 参数 Map parameters = new HashMap<>(); parameters.put("business_date", new JobParameter("20170704")); JobParameters jobParameters = new JobParameters(parameters); Job job = context.getBean(Job.class); // 运行 job JobLauncher jobLauncher = context.getBean(JobLauncher.class); jobLauncher.run(job, jobParameters); }} 信息: Job: [FlowJob: [name=loadFileJob]] launched with the following parameters: [{business_date=20170705}]SimpleJobExecutionListener.beforeJob七月 22, 2017 8:35:22 下午 org.springframework.batch.core.job.SimpleStepHandler handleStep信息: Executing step: [loadFileStep]SimpleStepExecutionListener.beforeStepSimpleChunkListener.beforeChunkSimpleItemReadListener.beforeReadSimpleItemReadListener.afterRead -- zhangsanSimpleItemReadListener.beforeReadSimpleItemReadListener.afterRead -- lisiSimpleItemReadListener.beforeReadSimpleItemReadListener.afterRead -- wangwuSimpleItemReadListener.beforeReadSimpleItemProcessListener.beforeProcessSimpleItemProcessListener.afterProcess -- zhangsanSimpleItemProcessListener.beforeProcessSimpleItemProcessListener.afterProcess -- lisiSimpleItemProcessListener.beforeProcessSimpleItemProcessListener.afterProcess -- wangwuSimpleItemWriteListener.beforeWriteSimpleItemWriteListener.afterWriteSimpleChunkListener.afterChunkSimpleStepExecutionListener.afterStepSimpleJobExecutionListener.afterJob –
– 声 明：转载请注明出处
– Last Updated on 2017-07-22
– Written by ShangBo on 2017-07-22
– End