我正在嘗試實現 2 個 Spring Batch 作業，這些作業將在使用端點時運行。既然 JobLauncher 方法對它們來說都是一樣的，那么你如何選擇要執行哪一個呢？@Autowiredprivate JobLauncher jobLauncher;@Autowiredprivate Job job;@RequestMapping( value = "/expired", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_UTF8_VALUE, params = {"expireDate"})@ResponseBodypublic ResponseDTO expiredJob(@RequestParam(value = "expireDate") String expireDate) throws BusinessException, Exception { if (!DateValidator.isDateFormatValid(expireDate)) { throw new BusinessException(ExceptionCodes.DATE_FORMAT_ERROR); } JobParameters jobParameters = new JobParametersBuilder().addString("expireDate", expireDate).toJobParameters(); jobLauncher.run(job, jobParameters); ResponseDTO responseDTO = new ResponseDTO(); return responseDTO;}@RequestMapping( value = "/lucky", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)@ResponseBodypublic ResponseDTO rciplusJob() throws BusinessException, Exception { JobParameters jobParameters = new JobParameters(); jobLauncher.run(job, jobParameters); ResponseDTO responseDTO = new ResponseDTO(); return responseDTO;}
1 回答
慕容708150
TA貢獻1831條經驗 獲得超4個贊
你可以像我一樣這樣做。
我假設您為每個作業都有一個春季批處理作業配置。例如：
@Bean(name = "job1")
public Job job1() {
return jobBuilders.get("job1")
.incrementer(new RunIdIncrementer())
.flow(step1())
.end()
.build();
}
和job2一樣：
@Bean(name = "job2")
public Job job2() {
return jobBuilders.get("job2")
.incrementer(new RunIdIncrementer())
.flow(step2())
.end()
.build();
}
現在在您的控制器中，您只需自動連接兩個作業：
@Autowired
@Qualifier("job1")
private Job job1;
@Autowired
@Qualifier("job2")
private Job job2;
要啟動它們中的每一個，您可以這樣做：
final JobExecution jobExecution = jobLauncher.run(job, jobParameters);
添加回答
舉報
0/150
提交
取消