Sptring批处理：在初始化Spring Boot上下文期间处理异常

Question

在Spring Boot上下文的初始化过程中，有什么方法可以处理异常吗？

我的案例是在作业执行过程中处理错误，并根据发生的异常做一些工作。

例如，我有一个由读者和作家组成的工作。读取器和写入器使用以下属性初始化：rootFolder、inFolder、outfolder。这个简单的作业从/rootfolder/infolder/test.txt读取文件，并将数据写入rootfolder/outfolder/test.txt。

有没有办法添加通用侦听器来拦截和分析错误？

代码示例配置类：

@Configuration
public class JobConfiguration {

   @Autowired
   public JobConfiguration(JobSpecificProperties properties) {
       this.properties = properties;
   }

   private final JobSpecificProperties properties;

   @Bean
   public Job job(JobBuilderFactory jobBuilderFactory, Step step) {
       return jobBuilderFactory.get("jobName")
               .incrementer(new RunIdIncrementer())
               .listener(new SystemExitOnFailureJobExecutionListener())
               .start(step)
               .build();
   }

   @Bean
   public Step step(StepBuilderFactory stepBuilderFactory,
                 ItemReader<String> itemReader,
                 ItemWriter<String> itemWriter) {
       return stepBuilderFactory.get("stepName")
               .<String, String>chunk(Integer.MAX_VALUE)
               .reader(itemReader)
               .writer(itemWriter)
               .build();
   }

   @Bean
   public ItemReader<String> itemReader() {
       FlatFileItemReader<String> reader = new FlatFileItemReader<>();
       reader.setStrict(false);
       reader.setLineMapper((string, index) -> string);
       reader.setResource(new FileSystemResource(Paths.get(properties.getRootFolder(), properties.getInFolder()).resolve("test.txt").toString()));

       return reader;
   }

   @Bean
   public ItemWriter<String> itemWriter() {
       FlatFileItemWriter<String> writer = new FlatFileItemWriter<>();
       writer.setLineAggregator(string -> string);
       writer.setResource(new FileSystemResource(Paths.get(properties.getRootFolder(), properties.getOutFolder()).resolve("test.txt").toString()));

       return writer;
   }
}

代码示例侦听器类：

@Slf4j
public class SystemExitOnFailureJobExecutionListener extends JobExecutionListenerSupport {
    @Override
    public void afterJob(JobExecution jobExecution) {
        if (jobExecution.getStatus() == BatchStatus.FAILED) {
            if (jobExecution.getAllFailureExceptions().get(0) instanceof NullPointerException){
                log.error("some_message_1");
                //TODO: Do something
                System.exit(2);
            } else if (jobExecution.getAllFailureExceptions().get(0) instanceof InvalidPathException){
                log.error("some_message_2");
                //TODO: Do something
                System.exit(3);
            }

            //TODO: Do something by default
            System.exit(1);
        }
   }
}

@Getter
@Setter
@ConfigurationProperties("job.parameter")
public class JobSpecificProperties {
    private String rootFolder;
    private String outFolder;
    private String inFolder;
}

@SpringBootApplication
@EnableBatchProcessing
@EnableConfigurationProperties(JobSpecificProperties.class)
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

Answer 1

我希望扩展类AlwaysSkipItemSkipPolicy在作业/步骤级别使用该类。

@Override
public boolean shouldSkip(java.lang.Throwable t, int skipCount){
     if(t instanceof NonSkippableReadException){
                return true;
     }
     return false;
}

有关处理零件的更多信息，请参阅

https://docs.spring.io/spring-batch/4.1.x/reference/html/step.html

public interface SkipListener<T,S> extends StepListener {

    void onSkipInRead(Throwable t);
    void onSkipInProcess(T item, Throwable t);
    void onSkipInWrite(S item, Throwable t);

}

@onskipinread

@onskipinwrite

@OnSkipInProcess