Spring Batch查找开始作业执行

Question

我有一份Spring批量申请，只有一份工作。作业执行顺序对我来说至关重要，因此JobLauncher配置为单线程作业池。换句话说，如果触发的执行很少，则一个执行正在运行，另一个将在队列中等待。

作业执行表将如下所示：

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

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

找到第一个不是问题，我可以用JobExplorer做到：

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

它只会给我START执行当前START\u时间。但是如何找到所有开始执行的？

到目前为止，我找到的唯一方法是迭代作业实例，然后为每个实例找到开始执行的。类似这样：

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

这里的问题是，你总是做一个有限制的完整扫描（我指定了100）。有没有更好的方法，比如jobExplorer。在Spring批处理中查找启动作业执行（“作业名称”）？




Answer 1

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

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

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

这就是说，我认为JobRepository界面可以添加一个方法，通过名称和参数（类似于isJobInstanceExists）获取作业实例，以避免使用jobInstanceDao，如我之前的代码片段所示。

编辑：

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