【发布时间】:2018-03-04 10:50:03
【问题描述】:
我的 Spring-Batch 作业是这样设置的:
@Bean
Job myJob(JobBuilderFactory jobBuilderFactory,
@Qualifier("stepA") Step stepA,
@Qualifier("s"tepB) Step stepB) {
return jobBuilderFactory.get("myJob")
.incrementer(new RunIdIncrementer())
.start(stepA)
.next(stepB)
.build();
}
这是我的启动器:
@Autowired
JobLauncher(@Qualifier("myJob") Job job, JobLauncher jobLauncher) {
this.job = job;
this.jobLauncher = jobLauncher;
}
@Scheduled(fixedDelay=5000)
void launcher() throws JobParametersInvalidException, JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException {
jobLauncher.run(job, newExecution());
}
private JobParameters newExecution() {
Map<String, JobParameter> parameters = new HashMap<>();
this.dateTime = new DateTime(DateTimeZone.UTC);
this.dateTimeString = this.dateTime.toString(ISODateTimeFormat.dateTime());
JobParameter parameter = new JobParameter(this.dateTimeString);
parameters.put("currentTime", parameter);
return new JobParameters(parameters);
}
如您所见,我的作业计划每 5 秒启动一次。 但是,第一次启动后,它并没有结束;它继续下一次执行。 这项工作就像一个循环。我希望它在 5 秒后停止并重新启动。
【问题讨论】:
标签: java spring-batch