我有一個現有的春季批處理項目，該項目有多個步驟。我想修改一個步驟，以便我可以停止作業：。jobExecution.getStatus() == STOPPED我的步驟 ：@Autowiredpublic StepBuilderFactory stepBuilderFactory;@Autowiredprivate StepReader reader;@Autowiredprivate StepProcessor processor;@Autowiredprivate StepWriter writer;@Autowiredpublic GenericListener listener;@Bean@JobScope@Qualifier("mystep")public Step MyStep() throws ReaderException { return stepBuilderFactory.get("mystep") .reader(reader.read()) .listener(listener) .processor(processor) .writer(writer) .build();}GenericListener在基本上寫入日志的方法之前和之后實現和重寫。ItemReadListener, ItemProcessListener, ItemWriteListener這里的重點是返回的類及其方法：StepReaderread()FlatFileItemReader@Componentpublic class StepReader { public static final String DELIMITER = "|"; @Autowired private ClassToAccessProperties classToAccessProperties; private Logger log = Logger.create(StepReader.class); @Autowired private FlatFileItemReaderFactory<MyObject> flatFileItemReaderFactory; public ItemReader<MyObject> read() throws ReaderException { try { String csv = classToAccessProperties.getInputCsv(); FlatFileItemReader<MyObject> reader = flatFileItemReaderFactory.create(csv, getLineMapper()); return reader; } catch (ReaderException | EmptyInputfileException | IOException e) { throw new ReaderException(e); } catch (NoInputFileException e) { log.info("Oh no !! No input file"); // Here I want to stop the job return null; } }我試圖實現，但沒有運氣，我認為是因為方法期望從方法中得到一個，它不關心類的其余部分。StepExecutionListenerStepReaderreaderStepBuilderFactoryItemReaderreader.read()我正在尋找想法或解決方案，以便能夠在被捕獲時停止整個工作（而不是失敗）。NoInputFileException爪哇島春天彈簧批次
1 回答
呼啦一陣風
TA貢獻1802條經驗 獲得超6個贊
我正在尋找一些想法或解決方案，以便在捕獲到無輸入文件異常時能夠停止整個作業（而不是失敗）。
這是一種常見的模式，在參考文檔的“找不到輸入時處理步驟完成”部分中進行了詳細介紹。該部分中的示例顯示了如何在找不到輸入文件時使作業失敗，但由于您希望停止作業而不是失敗，因此可以在偵聽器中使用，并且您的作業將以狀態 結束。在您的示例中，您將向該步驟添加該偵聽器。StepExecution#setTerminateOnly();STOPPEDMyStep
但是，我建議添加一個預驗證步驟，如果沒有文件，則停止作業。下面是一個快速示例：
import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
@EnableBatchProcessing
public class MyJob {
@Autowired
private JobBuilderFactory jobs;
@Autowired
private StepBuilderFactory steps;
@Bean
public Step fileValidationStep() {
return steps.get("fileValidationStep")
.tasklet((contribution, chunkContext) -> {
// TODO add code to check if the file exists
System.out.println("file not found");
chunkContext.getStepContext().getStepExecution().setTerminateOnly();
return RepeatStatus.FINISHED;
})
.build();
}
@Bean
public Step fileProcessingStep() {
return steps.get("fileProcessingStep")
.tasklet((contribution, chunkContext) -> {
System.out.println("processing file");
return RepeatStatus.FINISHED;
})
.build();
}
@Bean
public Job job() {
return jobs.get("job")
.start(fileValidationStep())
.next(fileProcessingStep())
.build();
}
public static void main(String[] args) throws Exception {
ApplicationContext context = new AnnotationConfigApplicationContext(MyJob.class);
JobLauncher jobLauncher = context.getBean(JobLauncher.class);
Job job = context.getBean(Job.class);
JobExecution jobExecution = jobLauncher.run(job, new JobParameters());
System.out.println("Job status: " + jobExecution.getExitStatus().getExitCode());
}
}
該示例打?。?/p>
file not found
Job status: STOPPED
希望這有幫助。
添加回答
舉報
0/150
提交
取消