spring batch提供作业执行状态和步骤信息

Question

我有一个应用程序，客户机发送HTTP请求，这些请求被翻译成Spring批处理作业参数并触发一个作业。我为响应和作业执行的结果生成CorrelationID。

此时，我无法获得正在运行的作业的job_execution_id。

获取它的方法是查询batch_job_execution_param表，该表以correlationID作为键/值，因此我使用条件进行查询：

从这里开始，我希望向客户提供正在运行/或正在运行的作业的全部详细信息，包括当前步骤及其状态的详细信息。所以json有效负载应该如下所示：

{
  "correlationId": "2ae16a63-7e91-4e37-942a-cf7f66117014",
  "jobDetails": {
    "id": 1,
    "jobId": 1,
    "jobName": "BLA BLA",
    "startTime": "2018-12-23T18:19:13.185",
    "endTime": "2018-12-23T18:19:13.223",
    "exitCode": "COMPLETED",
    "exitDescription": "",
    "status": "COMPLETED",
    "exceptions": [],
    "currentStep": "copyingAFile",
    "currentStepStatus": "RUNNING"
  },
  "_links": {
    "self": {
      "href": "http://localhost:8080/status/2ae16a63-7e91-4e37-942a-cf7f66117014"
    }
  }
}

我知道spring batch中有一些DAO类用于JobExection和StepExecution。我想知道的是，是否有一种方法可以通过自定义查询或已经存在于spring batch框架中的dao方法一次性获取作业执行和当前步骤执行的细节，并插入到响应中？所有这些都来自一个简单的correlationId，客户端在endpointGET/status/{correlationId}中调用该ID

这个链接给了我一些知识，但是我正在用我的客户机没有的作业执行id查询，而且也没有关于currentstep及其状态的信息

我不是通过作业执行id来驱动所有这些，因为我的作业可以异步激发，我需要立即用CorrelationID来响应。

Answer 1

我相信您不需要CorrelationID。如果在作业启动器上设置了异步任务执行器，则作业启动器将立即返回一个带有id的作业执行，您可以将该id返回给客户端，请参见从Web容器中运行作业。

现在，使用从get/status/{jobExecutionId}获得的作业执行Id，您可以使用jobexplorer#getjobexecution获取jobexecution及其步骤执行（使用jobexecution#getstepexecution()，并通过stepexecution.getstatus().isrunning()查找当前正在运行的步骤。