异常处理——restart重启

本文主要是介绍异常处理——restart重启，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

当spring batch批处理时遇到异常，可以采用如下方式

一、restart

1、在job中阻止重启

    //job//在job中设置了preventRestart会阻止job重启，第一次不管执行成功还是失败，都不会重启第二次@Beanpublic Job fileReaderJob(){return jobBuilderFactory.get("fileReaderJob").start(chunkStep()).preventRestart() //阻止重启.build();}//step@Beanpublic Step chunkStep(){return stepBuilderFactory.get("chunkStep").chunk(3)                                           .reader(fileItemReader())                           .writer(list -> list.forEach(System.out::println)).build();}

如果第二次重启job，会报job实例存在的错误

JobInstance already exists and is not restartable

2、在step中阻止重启

如果Job允许重启，但step不允许重启，当重启job后，会跳过不允许重启的step，不会报错

    //job@Beanpublic Job fileReaderJob(){return jobBuilderFactory.get("fileReaderJob").start(chunkStep()).build();}//step*/@Beanpublic Step chunkStep(){return stepBuilderFactory.get("chunkStep").chunk(3)                                           .reader(fileItemReader())                           .writer(list -> list.forEach(System.out::println)).allowStartIfComplete(false).build();}

当重启Job后，在日志表中可以看到job的status是COMPLETED，exit_code是NOOP，exit_message是 All steps already completed or no steps configured for this job.

3、在step中限制重启的次数

    //job@Beanpublic Job fileReaderJob(){return jobBuilderFactory.get("fileReaderJob").start(chunkStep()).build();}//step*/@Beanpublic Step chunkStep(){return stepBuilderFactory.get("chunkStep").chunk(3)                                           .reader(fileItemReader())                           .writer(list -> list.forEach(System.out::println)).startLimit(3) //设置有异常时，重启次数是3次，如果没异常，不重启.build();}

当该job作业没有异常时，job不管运行多少次，step都只在第一次运行；如果该job作业有异常，当job执行第一次在step中抛出异常后，当后面重启job后，step从上次异常中断的地方重启，如果还是异常，一直到3次后，就不再重启，提示已经超过最大执行次数：Maximum start limit exceeded for step: chunkStep1StartMax: 3 。

4、即使job成功后，也允许重启
前三种都是当job出现异常，重启后，从抛出异常的地方继续执行。而下面情况，每次重启job后，都是从开始的地方执行。

    //job@Beanpublic Job fileReaderJob(){return jobBuilderFactory.get("fileReaderJob").start(chunkStep()).build();}//step*/@Beanpublic Step chunkStep(){return stepBuilderFactory.get("chunkStep").chunk(3)                                           .reader(fileItemReader())                           .writer(list -> list.forEach(System.out::println)).allowStartIfComplete(true).build();}