如何使Spring批處理步驟取決於上一步？

Question

我使用Spring Batch從CSV文件中讀取一些數據並將其放入數據庫中。 我的批處理作業必須是2個的步驟化合物

1. 檢查文件（名稱，擴展，內容..）從CSV
2. 讀取行，並將它們保存在DB（ItemReader，ItemProcessor中， ItemWriter ..）

如果Step 1產生錯誤Step 2不能執行（文件不符合，文件不存在...）

僅供參考，我使用Spring Batch的XML沒有configura重刑！只有註釋： 這裏是我的工作，配置類的樣子：

@Configuration 
@EnableBatchProcessing 
public class ProductionOutConfig { 

    @Autowired 
    private StepBuilderFactory steps; 

    @Autowired 
    private JobBuilderFactory jobBuilderFactory; 


    @Autowired 
    private ProductionOutTasklet productionOutTasklet; 

    @Autowired 
    private CheckFilesForProdTasklet checkFilesForProdTasklet; 

    @Bean 
    public Job productionOutJob(@Qualifier("productionOut")Step productionOutStep, 
           @Qualifier("checkFilesForProd") Step checkFilesForProd){ 
     return jobBuilderFactory.get("productionOutJob").start(checkFilesForProd).next(productionOutStep).build(); 
    } 

    @Bean(name="productionOut") 
    public Step productionOutStep(){ 
     return steps.get("productionOut"). 
       tasklet(productionOutTasklet) 
       .build();} 

    @Bean(name = "checkFilesForProd") 
    public Step checkFilesForProd(){ 
     return steps.get("checkFilesForProd") 
       .tasklet(checkFilesForProdTasklet) 
       .build(); 
    } 
} 

Answer 1

已經是你正在尋找的，如果前面的步驟失敗將不會被執行Spring Batch的即下一步的默認行爲。要將當前步驟標記爲失敗步驟，您需要拋出未捕獲的運行時異常。

如果未處理異常，spring批處理會將該步驟標記爲失敗，並且下一步將不會執行。所以你只需要在失敗的場景中拋出異常。

對於複雜的工作流，你可能會想用 - JobExecutionDecider，Programmatic Flow Decisions

Answer 2

由於文檔指定您可以使用方法「」如果從先前的狀態，退出狀態相匹配的，其開始新狀態的轉變給定模式。

你的代碼可能是類似這樣的：

return jobBuilderFactory.get("productionOutJob") 
      .start(checkFilesForProd) 
      .on(ExitStatus.FAILED.getExitCode()).end() 
      .from(checkFilesForProd) 
      .on("*") 
      .to(productionOutStep) 
      .build();