异步启动Spring-Batch作业时如何获取作业执行完成状态

异步启动作业时，JobLauncher.run()方法会在作业提交后立刻返回，不会阻塞等待作业执行完成，直接读取返回时的JobExecution对象只能拿到启动阶段的状态，没法拿到最终结果，你可以用下面三种可靠方式判定执行结果：

• 基于JobExplorer轮询查询最新状态
  异步启动拿到初始JobExecution后，先记录下对应的jobExecutionId，按照你业务能接受的延迟设置轮询间隔，每次通过JobExplorer根据ID查询最新的作业执行实例，直到实例进入结束态（即isRunning()返回false，对应COMPLETED/FAILED/STOPPED/ABANDONED这几种终态），再判断具体状态即可。
  参考代码如下：

  // 提交异步作业
  JobExecution initExecution = jobLauncher.run(targetJob, jobParams);
  Long execId = initExecution.getId();
  JobExecution latestExecution = initExecution;
  // 轮询判断，生产环境记得加超时阈值，避免无限轮询
  while (latestExecution.isRunning()) {
      TimeUnit.SECONDS.sleep(1); // 轮询间隔按需调整
      latestExecution = jobExplorer.getJobExecution(execId);
  }
  // 终态判断
  if (latestExecution.getStatus() == BatchStatus.COMPLETED) {
      // 作业执行成功逻辑
  } else {
      // 作业执行失败逻辑，可通过latestExecution.getAllFailureExceptions()获取全链路异常信息
  }
  

  这里要注意的坑：绝对不要直接用启动时返回的初始JobExecution对象做状态判断，这个对象在返回后就和执行线程脱离了，后续执行过程中的状态变化不会同步更新到这个对象上，必须每次从JobExplorer拉取最新实例。
• 绑定JobExecutionListener实现回调通知
  这是生产环境最推荐的方式，不需要写轮询逻辑，没有空转性能损耗。你只需要给目标作业注册自定义的作业执行监听器，重写afterJob方法，作业无论执行成功、失败还是被终止，在执行流程结束前都会自动触发这个回调方法，方法入参里就带了最新的JobExecution对象，直接在方法里做状态判定和后续业务处理即可。
  注意如果是用@Async注解或者自定义线程池实现异步启动，监听器的回调逻辑会运行在作业实际执行的业务线程中，要做好线程安全管控。
• 直接查询Spring Batch元数据表
  Spring Batch会基于事务保证，把所有作业的执行全生命周期状态持久化到提前初始化的元数据表中，其中BATCH_JOB_EXECUTION表的STATUS字段存储作业最新的BatchStatus枚举值，EXIT_CODE存储退出标识，EXIT_MESSAGE存储异常栈信息。如果你的判定逻辑不在Spring应用上下文内，完全可以直接查询这张表的字段值判定最终状态，只要作业进入终态，表内字段一定会更新为最终值，和框架内存里的状态完全一致。

避坑提醒：不要靠判断作业执行线程是否存活来推导作业状态，实际运行中会出现线程异常终止但状态未同步、线程存活但作业已因内部异常标记为失败的场景，上面三种方式拿到的都是Spring Batch官方维护的可信状态值，判定结果不存在偏差。

内容的提问来源于stack exchange，提问作者Tom