特征

本节将详细介绍 Spring Cloud Task，包括如何使用它、如何使用以配置它，以及适当的扩展点。spring-doc.cadn.net.cn

7. Spring Cloud Task 的生命周期

在大多数情况下，现代云环境是围绕流程的执行而设计的预计不会结束。如果它们确实结束，通常会重新启动。虽然大多数平台确实有某种方式来运行一个进程，该进程在结束时不会重新启动，因此该运行的结果通常不会以消耗的方式进行维护。Spring Cloud Task 提供了在环境中执行短期进程并记录结果。这样做允许围绕短期进程的微服务架构，如以及通过消息集成任务来延长运行时间的服务。spring-doc.cadn.net.cn

虽然此功能在云环境中很有用，但在传统的部署模型也是如此。当使用调度程序，例如 cron，能够监控完成后申请。spring-doc.cadn.net.cn

Spring Cloud Task 采用 Spring Boot 应用程序可以启动和结束，仍然成功。批处理应用程序是如何处理预计会结束（而且通常是短暂的）可能会有所帮助。spring-doc.cadn.net.cn

Spring Cloud Task 记录给定任务的生命周期事件。运行时间最长以大多数 Web 应用程序为代表的进程不会保存其生命周期事件。这 Spring Cloud Task 的核心任务可以做到。spring-doc.cadn.net.cn

生命周期由单个任务执行组成。这是对 Spring Boot 应用程序配置为任务（即，它具有 Sprint Cloud 任务依赖项）。spring-doc.cadn.net.cn

在任务开始时，在任何CommandLineRunner或ApplicationRunner实现已运行，则TaskRepository记录开始事件。此事件通过SmartLifecycle#start被触发由 Spring Framework 提供。这向系统指示所有 bean 都已准备好使用，并且在运行任何CommandLineRunner或ApplicationRunner实现由 Spring Boot 提供。spring-doc.cadn.net.cn

任务的记录仅在成功引导ApplicationContext.如果上下文根本无法引导，则任务的运行不会记录。

完成所有*Runner#run来自 Spring Boot 的调用或ApplicationContext（由ApplicationFailedEvent），任务执行为在存储库中更新了结果。spring-doc.cadn.net.cn

如果应用程序需要ApplicationContext在完成任务（所有*Runner#run方法已被调用，并且任务存储库已更新），请将属性spring.cloud.task.closecontextEnabled设置为 true。

7.1. 任务执行

存储在TaskRepository在TaskExecutionclass 和由以下信息组成：spring-doc.cadn.net.cn

田描述

田	描述
`executionid`spring-doc.cadn.net.cn	任务运行的唯一 ID。spring-doc.cadn.net.cn
`exitCode`spring-doc.cadn.net.cn	从`ExitCodeExceptionMapper`实现。如果没有生成了退出代码，但`ApplicationFailedEvent`被抛出，则设置 1。否则，它是假设为 0。spring-doc.cadn.net.cn
`taskName`spring-doc.cadn.net.cn	任务的名称，由配置的`TaskNameResolver`.spring-doc.cadn.net.cn
`startTime`spring-doc.cadn.net.cn	任务启动的时间，如`SmartLifecycle#start`叫。spring-doc.cadn.net.cn
`endTime`spring-doc.cadn.net.cn	任务完成的时间，如`ApplicationReadyEvent`.spring-doc.cadn.net.cn
`exitMessage`spring-doc.cadn.net.cn	退出时可用的任何信息。这可以通过编程方式设置`TaskExecutionListener`.spring-doc.cadn.net.cn
`errorMessage`spring-doc.cadn.net.cn	如果异常是任务结束的原因（如`ApplicationFailedEvent`），则该异常的堆栈跟踪存储在此处。spring-doc.cadn.net.cn
`arguments`spring-doc.cadn.net.cn	一个`List`字符串命令行参数的参数，因为它们被传递到可执行文件中启动应用程序。spring-doc.cadn.net.cn

executionidspring-doc.cadn.net.cn

任务运行的唯一 ID。spring-doc.cadn.net.cn

exitCodespring-doc.cadn.net.cn

从ExitCodeExceptionMapper实现。如果没有生成了退出代码，但ApplicationFailedEvent被抛出，则设置 1。否则，它是假设为 0。spring-doc.cadn.net.cn

taskNamespring-doc.cadn.net.cn

任务的名称，由配置的TaskNameResolver.spring-doc.cadn.net.cn

startTimespring-doc.cadn.net.cn

任务启动的时间，如SmartLifecycle#start叫。spring-doc.cadn.net.cn

endTimespring-doc.cadn.net.cn

任务完成的时间，如ApplicationReadyEvent.spring-doc.cadn.net.cn

exitMessagespring-doc.cadn.net.cn

退出时可用的任何信息。这可以通过编程方式设置TaskExecutionListener.spring-doc.cadn.net.cn

errorMessagespring-doc.cadn.net.cn

如果异常是任务结束的原因（如ApplicationFailedEvent），则该异常的堆栈跟踪存储在此处。spring-doc.cadn.net.cn

argumentsspring-doc.cadn.net.cn

一个List字符串命令行参数的参数，因为它们被传递到可执行文件中启动应用程序。spring-doc.cadn.net.cn

7.2. 映射退出代码

任务完成后，它会尝试将退出代码返回给作系统。如果我们看一看在我们最初的例子中，我们可以看到我们是不控制我们应用程序的这方面。因此，如果抛出异常，JVM 返回一个代码，该代码可能对调试有任何用处，也可能没有用处。spring-doc.cadn.net.cn

因此，Spring Boot 提供了一个接口，ExitCodeExceptionMapper，这可以让您将未捕获的异常映射到退出代码。这样做可以让您在退出级别指示代码，出了什么问题。此外，通过以这种方式映射退出代码，Spring Cloud Task 记录返回的退出代码。spring-doc.cadn.net.cn

如果任务以 SIG-INT 或 SIG-TERM 终止，则退出代码为零，除非否则在代码中指定。spring-doc.cadn.net.cn

当任务运行时，退出代码将作为空存储在存储库中。任务完成后，将根据所述指南存储适当的退出代码在本节前面。

8. 配置

Spring Cloud Task 提供了一个即用型配置，如DefaultTaskConfigurer和SimpleTaskConfiguration类。本节将介绍默认值以及如何根据您的需要自定义 Spring Cloud Task。spring-doc.cadn.net.cn

8.1. 数据源

Spring Cloud Task 使用数据源来存储任务执行的结果。由默认情况下，我们提供了一个 H2 的内存实例来提供一个简单的方法引导开发。但是，在生产环境中，您可能希望配置您自己的DataSource.spring-doc.cadn.net.cn

如果您的应用程序仅使用单个DataSource这既是您的业务 schema 和任务存储库，您需要做的就是提供任何DataSource（这最简单的方法是通过 Spring Boot 的配置约定）。这DataSource被 Spring Cloud Task 自动用于存储库。spring-doc.cadn.net.cn

如果您的应用程序使用多个DataSource，您需要配置任务存储库，其中包含适当的DataSource.这种自定义可以通过实现TaskConfigurer.spring-doc.cadn.net.cn

8.2. 表前缀

一个可修改的属性TaskRepository是任务表的表前缀。由默认，它们都以TASK_.TASK_EXECUTION和TASK_EXECUTION_PARAMS是两个例子。但是，修改此前缀有潜在的原因。如果 schema name 需要附加到表名称前面，或者如果多组任务 tables 需要，则必须更改表前缀。你可以这样做通过将spring.cloud.task.tablePrefix到您需要的前缀，如下所示：spring-doc.cadn.net.cn

spring.cloud.task.tablePrefix=yourPrefixspring-doc.cadn.net.cn

通过使用spring.cloud.task.tablePrefix，用户承担责任创建满足任务表架构条件但对用户的业务需求进行修改。在创建自己的任务 DDL 时，您可以利用 Spring Cloud 任务模式 DDL 作为指南，如此处所示。spring-doc.cadn.net.cn

8.3. 启用/禁用表初始化

如果您正在创建任务表并且不希望 Spring Cloud Task 在任务启动时创建它们，将spring.cloud.task.initialize-enabled属性设置为false如下：spring-doc.cadn.net.cn

spring.cloud.task.initialize-enabled=falsespring-doc.cadn.net.cn

它默认为true.spring-doc.cadn.net.cn

该物业spring.cloud.task.initialize.enable已被弃用。

8.4. 外部生成的任务 ID

在某些情况下，您可能希望允许任务之间的时间差请求以及基础设施实际启动它的时间。Spring Cloud Task 允许您创建一个TaskExecution请求任务时。然后将生成TaskExecution添加到任务，以便它可以更新TaskExecution通过任务的生命周期。spring-doc.cadn.net.cn

一个TaskExecution可以通过调用createTaskExecution方法实现TaskRepository引用包含这TaskExecution对象。spring-doc.cadn.net.cn

为了将任务配置为使用生成的TaskExecutionId，将以下属性：spring-doc.cadn.net.cn

spring.cloud.task.executionid=yourtaskIdspring-doc.cadn.net.cn

8.5. 外部任务 ID

Spring Cloud Task 允许您为每个TaskExecution.这方面的一个示例是由 Cloud Foundry 在平台上启动任务时。为了将任务配置为使用生成的TaskExecutionId，将以下属性：spring-doc.cadn.net.cn

spring.cloud.task.external-execution-id=<externalTaskId>spring-doc.cadn.net.cn

8.6. 父任务 ID

Spring Cloud Task 允许您为每个TaskExecution.示例这将是执行另一个或多个任务的任务，并且您想要记录哪个任务启动每个子任务。为了将任务配置为设置父级TaskExecutionId在子任务上添加以下属性：spring-doc.cadn.net.cn

spring.cloud.task.parent-execution-id=<parentExecutionTaskId>spring-doc.cadn.net.cn

8.7. 任务配置器

这TaskConfigurer是一个策略接口，可让您自定义组件的方式 Spring Cloud Task 已配置。默认情况下，我们提供DefaultTaskConfigurer那提供逻辑默认值：Map-基于内存中的组件（如果没有，则对开发有用DataSource）和基于 JDBC 的组件（如果有DataSource可用）。spring-doc.cadn.net.cn

这TaskConfigurer允许您配置三个主要组件：spring-doc.cadn.net.cn

元件描述默认值（由DefaultTaskConfigurer)

元件	描述	默认值（由`DefaultTaskConfigurer`)
`TaskRepository`spring-doc.cadn.net.cn	的实现`TaskRepository`待使用。spring-doc.cadn.net.cn	`SimpleTaskRepository`spring-doc.cadn.net.cn
`TaskExplorer`spring-doc.cadn.net.cn	的实现`TaskExplorer`（用于对任务进行只读访问的组件存储库）以使用。spring-doc.cadn.net.cn	`SimpleTaskExplorer`spring-doc.cadn.net.cn
`PlatformTransactionManager`spring-doc.cadn.net.cn	运行任务更新时要使用的事务管理器。spring-doc.cadn.net.cn	`DataSourceTransactionManager`如果`DataSource`被使用。`ResourcelessTransactionManager`如果不是。spring-doc.cadn.net.cn

TaskRepositoryspring-doc.cadn.net.cn

的实现TaskRepository待使用。spring-doc.cadn.net.cn

SimpleTaskRepositoryspring-doc.cadn.net.cn

TaskExplorerspring-doc.cadn.net.cn

的实现TaskExplorer（用于对任务进行只读访问的组件存储库）以使用。spring-doc.cadn.net.cn

SimpleTaskExplorerspring-doc.cadn.net.cn

PlatformTransactionManagerspring-doc.cadn.net.cn

运行任务更新时要使用的事务管理器。spring-doc.cadn.net.cn

DataSourceTransactionManager如果DataSource被使用。ResourcelessTransactionManager如果不是。spring-doc.cadn.net.cn

您可以通过创建自定义实现TaskConfigurer接口。通常，将DefaultTaskConfigurer（如果TaskConfigurer未找到）和覆盖所需的 getter 就足够了。但是，从头开始实现自己的可能需要。spring-doc.cadn.net.cn

用户不应直接使用TaskConfigurer径直除非他们使用它来提供要作为 Spring Beans 公开的实现。

8.8. 任务名称

在大多数情况下，任务的名称是在 Spring 中配置的应用程序名称靴子。但是，在某些情况下，您可能希望将任务的运行映射到不同的名称。Spring Cloud Data Flow 就是一个例子（因为您可能想要要运行的任务，并带有任务定义的名称）。因此，我们提供能够通过TaskNameResolver接口。spring-doc.cadn.net.cn

默认情况下，Spring Cloud Task 提供SimpleTaskNameResolver，它使用以下选项（按优先级顺序）：spring-doc.cadn.net.cn

调用的 Spring Boot 属性（以 Spring Boot 允许的任何方式配置）spring.cloud.task.name.spring-doc.cadn.net.cn
使用 Spring Boot 的规则解析的应用程序名称（通过ApplicationContext#getId).spring-doc.cadn.net.cn

8.9. 任务执行监听器

TaskExecutionListener允许您为期间发生的特定事件注册侦听器任务生命周期。为此，请创建一个实现TaskExecutionListener接口。实现TaskExecutionListener接口会收到以下事件的通知：spring-doc.cadn.net.cn

onTaskStartup：在存储之前TaskExecution进入TaskRepository.spring-doc.cadn.net.cn
onTaskEnd：在更新TaskExecution在TaskRepository和标记任务的最终状态。spring-doc.cadn.net.cn
onTaskFailed：在onTaskEnd当未处理的异常。spring-doc.cadn.net.cn

Spring Cloud Task 还允许您将TaskExecutionbean 中方法的侦听器通过使用以下方法注释：spring-doc.cadn.net.cn

@BeforeTask：在存储之前TaskExecution进入TaskRepositoryspring-doc.cadn.net.cn
@AfterTask：在更新TaskExecution在TaskRepository标记任务的最终状态。spring-doc.cadn.net.cn
@FailedTask：在@AfterTask当未处理的异常。spring-doc.cadn.net.cn

以下示例显示了正在使用的三个注释：spring-doc.cadn.net.cn

 public class MyBean {

    @BeforeTask
    public void methodA(TaskExecution taskExecution) {
    }

    @AfterTask
    public void methodB(TaskExecution taskExecution) {
    }

    @FailedTask
    public void methodC(TaskExecution taskExecution, Throwable throwable) {
    }
}

插入ApplicationListener链中早于TaskLifecycleListener存在可能会造成意想不到的效果。

8.9.1. 任务执行监听器抛出的异常

如果异常是由TaskExecutionListener事件处理程序、所有侦听器该事件处理程序的处理停止。例如，如果三个onTaskStartup听众已开始，第一个onTaskStartup事件处理程序抛出异常，另一个二onTaskStartup方法。但是，其他事件处理程序（onTaskEnd和onTaskFailed）的TaskExecutionListeners被调用。spring-doc.cadn.net.cn

由TaskExecutionListener事件处理程序是 ExitCodeEvent 报告的退出代码。如果没有ExitCodeEvent发出时，将评估抛出的异常以查看如果它是 ExitCodeGenerator 类型。如果是这样，它会从ExitCodeGenerator.否则1被返回。spring-doc.cadn.net.cn

如果在onTaskStartup方法，应用程序的退出代码将为1. 如果在任一onTaskEnd或onTaskFailed方法时，应用程序的退出代码将是使用上面列举的规则建立的退出代码。spring-doc.cadn.net.cn

如果在onTaskStartup,onTaskEnd或onTaskFailed您无法使用ExitCodeExceptionMapper.

8.9.2. 退出消息

您可以使用TaskExecutionListener. 这是通过设置TaskExecution’s exitMessage, 然后将其传递给TaskExecutionListener. 以下示例显示了使用@AfterTask ExecutionListener:spring-doc.cadn.net.cn

@AfterTask
public void afterMe(TaskExecution taskExecution) {
    taskExecution.setExitMessage("AFTER EXIT MESSAGE");
}

一ExitMessage可以在任何侦听器事件（onTaskStartup,onTaskFailed和onTaskEnd). 三个侦听器的优先级如下：spring-doc.cadn.net.cn

onTaskEndspring-doc.cadn.net.cn
onTaskFailedspring-doc.cadn.net.cn
onTaskStartupspring-doc.cadn.net.cn

例如，如果您将exitMessage对于onTaskStartup和onTaskFailedlisteners 的 Listeners，任务结束时不会失败，exitMessage从onTaskStartup存储在存储库中。否则，如果发生故障，则exitMessage从这onTaskFailed被存储。此外，如果您将exitMessage使用onTaskEndlistener，则exitMessage从onTaskEnd取代来自onTaskStartup和onTaskFailed.spring-doc.cadn.net.cn

8.10. 限制 Spring Cloud 任务实例

Spring Cloud Task 允许您建立一次只能运行一个具有给定任务名称的任务。为此，您需要建立任务名称并将spring.cloud.task.single-instance-enabled=true对于每个任务执行。虽然第一个任务执行正在运行时，当您尝试运行具有相同任务名称和'spring.cloud.task.single-instance-enabled=true'的任务时，则任务失败，并显示以下错误消息：Task with name "application" is already running.的默认值spring.cloud.task.single-instance-enabled是false.这以下示例演示如何设置spring.cloud.task.single-instance-enabled自true:spring-doc.cadn.net.cn

spring.cloud.task.single-instance-enabled=true or falsespring-doc.cadn.net.cn

要使用此功能，您必须将以下 Spring Integration 依赖项添加到应用：spring-doc.cadn.net.cn

<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-core</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-jdbc</artifactId>
</dependency>

如果任务失败，应用程序的退出代码将为 1，因为此功能已启用，并且另一个任务正在运行具有相同任务名称。

8.11. 禁用 Spring Cloud 任务自动配置

如果不应为实现自动配置 Spring Cloud Task，您可以禁用 Task 的自动配置。这可以通过向任务应用程序添加以下注释来完成：spring-doc.cadn.net.cn

@EnableAutoConfiguration(exclude={SimpleTaskAutoConfiguration.class})

您还可以通过设置spring.cloud.task.autoconfiguration.enabled属性设置为false.spring-doc.cadn.net.cn

8.12. 关闭上下文

如果应用程序需要ApplicationContext在完成任务（所有*Runner#run方法已被调用，并且任务存储库已更新），请将属性spring.cloud.task.closecontextEnabled自true.spring-doc.cadn.net.cn

关闭上下文的另一种情况是任务执行完成，但应用程序不会终止。在这些情况下，上下文保持打开状态，因为已分配线程（例如：如果您使用的是 TaskExecutor）。在这些情况下将spring.cloud.task.closecontextEnabled属性设置为true启动任务时。这将在任务完成后关闭应用程序的上下文。从而允许应用程序终止。spring-doc.cadn.net.cn