JVM 崩溃后的 Spring Batch

Question

JVM崩溃后如何重新启 Action 业？

当我的 JVM 崩溃或系统出现故障时，我正在运行大量在 Spring Batch 框架中实现的作业。失败后如何重新启动这些作业？

Answer 1

您需要在重新启动“正在运行”的作业之前将其标记为失败，如下所示:

List<String> jobs = jobExplorer.getJobNames();
for (String job : jobs) {
    Set<JobExecution> runningJobs = jobExplorer.findRunningJobExecutions(job);

    for (JobExecution runningJob : runningJobs) {
        try {
            runningJob.setStatus(BatchStatus.FAILED);
            runningJob.setEndTime(new Date());
            jobRepository.update(runningJob);
            jobOperator.restart(runningJob.getId());
        } catch (Exception e) {
            LOG.error(e.getMessage(), e);
        }
    }
}