Spring Batch 查找开始作业执行

Question

我有一个带有一份工作的 Spring Batch 应用程序。作业执行顺序对我来说很重要，所以JobLauncher 配置为单线程作业池。换句话说，如果触发的执行很少，一个执行将运行，另一个将在队列中等待。

作业执行表如下所示：

        ╒═════╤═════════════════════╤════════════╤════════════╤═════╕
        │ ... │ START_TIME          │ END_TIME   │ STATUS     │ ... │
        ╞═════╪═════════════════════╪════════════╪════════════╪═════╡
        │ ... │ 2019-07-11 11:03:08 │ NULL       │ STARTED    │ ... │
        ├─────┼─────────────────────┼────────────┼────────────┼─────┤
        │ ... │ NULL                │ NULL       │ STARTING   │ ... │
        └─────┴─────────────────────┴────────────┴────────────┴─────┘

如果 JVM 崩溃，我需要从该状态中恢复并进行一些审计，因此我需要找到所有 STARTED 和 STARTING 执行。

发现第一个没问题，我可以用JobExplorer：

Set<JobExecution> executions = jobExplorer.findRunningJobExecutions("jobName");

它只会给我STARTED 执行当前START_TIME。但是如何找到所有STARTING 处决？

到目前为止，我发现的唯一方法是遍历作业实例，然后为每个实例找到 STARTING 执行。像这样的：

        jobExplorer.findJobInstancesByJobName("jobName", 0, 100)
                .forEach(jobInstance -> {
                    jobExplorer.getJobExecutions(jobInstance)
                            .stream()
                            .filter(execution -> STARTING.equals(execution.getStatus()))
                            .forEach(execution -> {
                                // do the job
                            });
                });

这里的问题是，您总是在有限制的情况下进行全面扫描（我指定了 100）。 Spring Batch 中有没有像jobExplorer.findStartingJobExecutions("jobName") 这样更好的方法？

Answer 1

我没有看到任何公共 API 可以按状态获取作业执行。你可以做的是（在伪代码中）：

JobInstance jobInstance = jobInstanceDao.getJobInstance(jobName, jobParameters);
List<JobExecution> jobExecutions =  jobExplorer.findJobExecutions(jobInstance);
// iterate over job execution and filter by status

这将避免加载所有作业实例（一次一百个）。

也就是说，我认为JobRepository 接口可以添加一个方法来通过名称和参数获取作业实例（类似于isJobInstanceExists）以避免使用jobInstanceDao，如我之前的sn-p 所示。

编辑：

我猜您最初的要求是将作业执行标记为无法重新启动它。为此，您可以手动将作业执行的状态（及其步骤执行）更改为FAILED，并将其END_TIME 设置为非空值（此处解释：https://docs.spring.io/spring-batch/4.1.x/reference/html/job.html#aborting-a-job）。这样，您将能够重新启动失败的执行。