从Spring Batch Tasklet获取进度信息

Question

我正在尝试设置和检索当前正在运行的spring batch tasklet的进度信息。

例如，我有一个基于一个步骤的简单的春季批处理作业

   public Step jobStep() {
        return stepBuilderFactory.get(JOB_STEP_1)
                .tasklet((contribution, chunkContext) -> {
...
                }).build();
   }

tasklet是一个执行某些操作的简单循环，可能会花费很多时间。

在循环中的每次迭代之后，我都会在JobExecutionContext中设置一些进度信息，例如

chunkContext.getStepContext().getStepExecution().getJobExecution().getExecutionContext().put("myJobStatus", "10 of 100 finished");

从另一个线程（例如，休息服务），我想检查实际任务的进度，为此我使用JobExplorer

String status = (String)jobExplorer.getJobExecution(jobId).getExecutionContext().get("myJobStatus");

[不幸的是，仅在步骤或作业完成时才设置myJobStatus属性。我什至尝试将简单的循环替换为步骤循环，但结果相同。

还有另一种方法来设置和访问当前正在运行的作业的进度信息吗？

我正在将DefaultBatchConfigurer与基于JDBC的JobRepository等一起使用

Answer 1

此步骤听起来像是一个很好的候选者，可以重构为更多的Reader->Writer步骤，而不是Tasklet中的循环。在每X个项目块之后，Spring Batch框架将使用最新的读/写计数来更新步骤执行。

对于长时间运行的步骤，这还具有对每个块进行提交的优点，这使得可重新启动性的负担减轻了，而不是等到Tasklet发出一个大的提交之前等所有工作都完成。

Answer 2

您的问题是，您正在将进度信息保存在作业执行上下文中，该信息将在完成步骤后保存在作业存储库中。您需要使用步骤执行上下文，因为它保存在Tasklet的每次提交中。这是参考文档中Execution context部分的摘录：

它们是两个不同的ExecutionContext。作用域为步骤的一个保存在步骤的每个提交点，而作用域为作业的一个保存在每次执行步骤之间。

因此，如果将进度信息存储在步骤执行上下文（而不是作业执行上下文）中，则应该能够使用作业浏览器从另一个线程获取进度信息。我假设您的tasklet做了一些工作，将进度保存在步骤执行上下文中，然后返回CONTINUABLE，直到不再有要做的工作并在此时返回FINISHED。我在this repo中有一个示例。