我正在尝试实现2个Spring Batch作业,这些作业将在使用端点时运行.由于JobLauncher方法对于这两个方法都是相同的,您如何选择要执行的方法?
@Autowired
private JobLauncher jobLauncher;
@Autowired
private Job job;
@RequestMapping(
value = "/expired",method = RequestMethod.GET,produces = MediaType.APPLICATION_JSON_UTF8_VALUE,params = {"expireDate"}
)
@ResponseBody
public 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",produces = MediaType.APPLICATION_JSON_UTF8_VALUE
)
@ResponseBody
public ResponseDTO rciplusJob() throws BusinessException,Exception {
JobParameters jobParameters = new JobParameters();
jobLauncher.run(job,jobParameters);
ResponseDTO responseDTO = new ResponseDTO();
return responseDTO;
}
最佳答案
您可以像我一样以这种方式进行操作.
我假设您为每个作业都有一个春季批处理作业配置.例如.:
@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);
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。