如何追踪Spring Cloud Task执行结果？是否有状态查询REST API及故障恢复方案？

一、任务状态的基础存储 #

Spring Cloud Task 默认会将任务执行元数据（任务ID、启动/结束时间、执行状态、异常信息等）持久化到关系型数据库（如MySQL、PostgreSQL），核心依赖spring-cloud-task-core，只需配置共享数据源即可自动生成task_execution、task_execution_params等表，所有任务的执行详情都会存在这里。

二、自定义REST API实现状态查询与业务上报 #

Spring Cloud Task 没有提供开箱即用的REST API，但可以基于其内置的API快速实现：

• 状态自动上报：任务执行结束时，Spring Cloud Task 会自动将执行状态（成功/失败、退出码、异常栈）写入数据库，无需额外手动上报。如果需要追踪业务层面的结果（如资源创建是否完成），可以在任务逻辑中把业务状态写入自定义业务表，并关联task_execution_id。
• 状态查询接口：使用Spring Cloud Task 提供的TaskExplorer编写REST接口，供发起任务的应用查询状态：

@RestController
@RequestMapping("/task/status")
public class TaskStatusController {

    private final TaskExplorer taskExplorer;

    public TaskStatusController(TaskExplorer taskExplorer) {
        this.taskExplorer = taskExplorer;
    }

    @GetMapping("/{taskId}")
    public ResponseEntity<TaskExecution> getTaskStatus(@PathVariable Long taskId) {
        TaskExecution execution = taskExplorer.getTaskExecution(taskId);
        if (execution == null) {
            return ResponseEntity.notFound().build();
        }
        return ResponseEntity.ok(execution);
    }

    // 按业务标识查询（比如资源ID）
    @GetMapping("/by-resource/{resourceId}")
    public ResponseEntity<List<TaskExecution>> getTasksByResource(@PathVariable String resourceId) {
        List<TaskExecution> tasks = taskExplorer.findTaskExecutionsByParam("resourceId", resourceId);
        return ResponseEntity.ok(tasks);
    }
}

发起任务的服务器A可以定期调用这些接口，通过exitCode判断任务结果（0为成功，非0为失败），通过endTime判断任务是否完成。

三、服务器宕机后的恢复机制 #

要实现宕机后恢复查询，核心是保证任务数据的共享持久化：

1. 使用共享数据库：配置Spring Cloud Task 的数据源为集群共享的数据库（而非服务器A本地库），这样服务器A重启后或其他节点都能从数据库读取任务历史。
2. 绑定业务标识：启动任务时，通过TaskLaunchRequest传递业务标识（如资源ID）作为任务参数，参数会自动存入task_execution_params表：

TaskLaunchRequest launchRequest = TaskLaunchRequestBuilder.withTaskName("resource-create-task")
        .addParameter("resourceId", "res-1001")
        .build();
taskLauncher.launch(launchRequest);

服务器A重启后，可通过业务标识查询对应任务的执行记录，恢复状态追踪。
3. 本地状态同步：服务器A重启时，从数据库加载所有未完成的任务记录，重新启动定时检查逻辑，同步更新本地存储的资源状态。

四、重试机制的适配 #

如果需要任务失败重试，可以：

• 利用Spring Cloud Task 结合Spring Retry 实现任务级别的重试；
• 在服务器A的检查逻辑中，发现任务失败且未达到重试次数上限时，重新发起任务启动请求，并在业务表中记录重试次数，避免重复触发。

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