如何避免在Spring Cloud Data Flow上运行任务状态时重新启动任务

Question

我已经在Spring Cloud Data Flow上部署了一个Spring Batch项目作为任务。

我第一次启动任务（它将运行大约5分钟，这使得任务的状态为“正在运行”）。然而，我已经第二次重新启动了这个任务，当它的状态为运行时，它再次工作。

1)如何配置任务直到最后一次处于完成状态才能重新启动？2)此外，我发现当停止作业时，它会一直执行，直到完成当前步骤(我的作业有2个步骤，第二个步骤没有执行)。但是，当我停止作业时，有什么方法可以立即关闭它(步骤1)吗？

Answer 1

您可以使用 JobExplorer 类来检查正在运行的作业，请参阅 jobExplorer.findRunningJobExecutions（jobName） 方法。

在JobLauncher类中，您可以像这样:

@Component
public class MyJobLauncher {

    private static final Logger LOG = LoggerFactory.getLogger(MyJobLauncher.class);

    private final Job job;

    private final JobLauncher jobLauncher;

    private final JobExplorer jobExplorer;

    @Autowired
    public MyJobLauncher(@Qualifier("myJob") Job job, JobLauncher jobLauncher, JobExplorer jobExplorer) {
        this.job = job;
        this.jobLauncher = jobLauncher;
        this.jobExplorer = jobExplorer;
    }

    public void launchJob() throws JobParametersInvalidException, JobExecutionAlreadyRunningException,
            JobRestartException, JobInstanceAlreadyCompleteException, IOException {

        if (jobExplorer.findRunningJobExecutions("myJob").isEmpty()) {
            LOG.info("Starting myJob");
            jobLauncher.run(job, new JobParameters());
            LOG.info("Stopping myJob");
        }
    }
}

要关闭作业，请检查 JobExecution.stop（） 方法，该方法可以从 jobExplorer.getJobExecution（） 方法获取。

Answer 2

如何避免在Spring Cloud Data Flow上运行任务状态时重新启动任务

Spring Cloud Task 2.0.0添加了一项功能，允许您阻止任务并发运行。请参阅https://spring.io/blog/2018/05/07/spring-cloud-task-2-0-0-release-is-now-available#restricting-concurrent-task-execution

您需要激活spring.cloud.看作属性。

您可以在限制Spring Cloud任务实例一节中找到更多细节。