Spring Cloud Composed Task如何从失败作业处重启？

针对你的需求，Spring Cloud Task 2.10.1提供了内置配置支持，也可以通过自定义逻辑实现，具体如下：

一、内置配置快速实现 #

Spring Cloud Task的组合任务本身支持跳过已成功任务、从失败节点重启的能力，只需要开启对应的配置：

在你的配置文件（application.properties/application.yml）中添加：

spring.cloud.task.composite.restart.enabled=true

开启这个配置后，组合任务会自动跟踪每个子任务的执行状态（依赖Task Repository存储状态），当你重启失败的组合任务时，它会跳过所有已经执行成功的子任务，直接从第一个失败的子任务开始执行，完全符合你描述的场景。

需要注意的两个关键点：

• 必须配置持久化Task Repository：默认的内存仓库在应用重启后会丢失任务状态，生产环境一定要配置数据库（比如MySQL、PostgreSQL）来存储任务执行记录，否则重启后还是会从头执行。
• 子任务必须保证幂等性：因为失败的任务会被重新执行，要确保重复执行不会导致数据重复、状态异常等问题。

二、自定义实现（针对特殊场景） #

如果内置的重启策略无法满足你的个性化需求（比如需要更复杂的状态判断逻辑），可以通过Spring Cloud Task提供的TaskExecutionRepository手动实现状态跟踪和任务调度：

核心思路是查询已执行的子任务状态，找到第一个失败的节点，然后从该节点开始调度后续任务，示例代码如下：

@Autowired
private TaskExecutionRepository taskExecutionRepository;

public void restartCompositeTask(String compositeTaskName) {
    // 获取目标组合任务的执行记录
    Optional<TaskExecution> compositeTaskOpt = taskExecutionRepository.findByTaskName(compositeTaskName)
            .stream()
            .findFirst();
    
    if (compositeTaskOpt.isPresent()) {
        TaskExecution compositeTask = compositeTaskOpt.get();
        // 查询该组合任务下的所有子任务执行记录
        List<TaskExecution> childTasks = taskExecutionRepository.findByParentExecutionId(compositeTask.getExecutionId());
        
        // 定位第一个失败的子任务索引
        int startIndex = 0;
        for (int i = 0; i < childTasks.size(); i++) {
            TaskExecution childTask = childTasks.get(i);
            // 非0退出码表示任务失败
            if (childTask.getExitCode() != 0) {
                startIndex = i;
                break;
            }
        }
        
        // 从失败节点开始执行后续任务
        List<YourTaskDefinition> taskList = getYourCompositeTaskList();
        for (int i = startIndex; i < taskList.size(); i++) {
            executeTask(taskList.get(i));
        }
    }
}

总结 #

优先使用内置的spring.cloud.task.composite.restart.enabled=true配置，这是官方提供的标准方案，简单可靠；如果有特殊需求，再通过TaskExecutionRepository自定义实现状态跟踪和任务重启逻辑。

内容的提问来源于stack exchange，提问作者17_4088_ Subashini.S