java版电子商务spring cloud分布式微服务b2b2c-Spring Cloud Task

Spring Cloud Task的目标是为Spring Boot应用程序提供创建短运行期微服务的功能。

在Spring Cloud Task中，我们可以灵活地动态运行任何任务，按需分配资源并在任务完成后检索结果。Tasks是

Spring Cloud Data Flow中的一个基础项目，了解springcloud架构可以加求求：三五三六二四七二五九，允许用户

将几乎任何Spring Boot应用程序作为一个短期任务执行。

Spring Cloud Task的生命周期

现代的云平台都是围绕着长生命周期的服务而设计的，如web应用，一经启用，除非手动去重启应用，否则就会没有

终点的持续运行。虽然大多数平台都有方法在不重启应用的情况下，将服务的生命周期推向终点，但每个服务的处理

结果难以以可重用的方式来维护。Spring Cloud Task可以在平台环境中执行短生命周期的应用，并记录这些应用的

结果，经由通过消息通知的机制来集成各个tasks。通过这特性就可以实现让短生命周期的应用像长生命周期的应用一

样组成微服务架构。

Spring Task Cloud的方式对现代的云环境是非常有用的，但它也在部署应用方面带来新问题。如使用调度器(如corn)

来执行Spring Boot应用时，如何在应用结束后监控到其执行结果？

Spring Cloud Task采用的方法是，将Spring Boot应用分为开始、结束、以及正在运行等状态。如批处理任务就是一个

清晰的短生命周期应用，Spring Cloud Task会监控指定任务的所有生命周期事件。

生命周期是一个任务task实例运行的全过程，也是一个被配置为task的Spring Boot应用被执行的过程(通过 添加@

EnableTask注解配置)。

在task刚刚开始运行时(CommandLineRunner或ApplicationRunner及其子类的实例被执行之前)TaskRespository会

创建一条task纪录并将其标记为start状态。start事件由spring框架的SmartLifecycle#start触发。开始事件被触发说明

了系统已经做好了执行CommandLineRunner或ApplicationRunner及其子类的实例的准备。

任务纪录只有在 ApplicationContext被成功启动后才会被纪录。如果ApplicationContext没有被成功启动，那么task

的相关信息也不会被纪录。

当Spring Boot应用的所有*Runner#run接口都被调用后，或者在ApplicationContext发生了失败(由

ApplicationFailedEvent来表现)，任务仓库中此任务的执行结果都会被更新。

task 完成之后(*Runner#run方法被执行完)默认情况下会被关闭ApplicationContext。这个特性可以在配置文件中

设置spring.cloud.task.closecontext_enable属性为false来更改。

其实现原理如下面代码所示:

 public class TaskLifecycleListener{        ...        /**         * 在发生task相关的事件后，会自动调用这个方法         * Utilizes {@link ApplicationEvent}s to determine the start, end, and failure of a         * task.  Specifically:         * 
         *     
{@link ContextRefreshedEvent} - Start of a task
         *     
{@link ApplicationReadyEvent} - Successful end of a task
         *     
{@link ApplicationFailedEvent} - Failure of a task
         * 
         *         * @param applicationEvent The application being listened for.         */        @Override        public void onApplicationEvent(ApplicationEvent applicationEvent) {            if(applicationEvent instanceof ApplicationFailedEvent) {                this.applicationFailedEvent = (ApplicationFailedEvent) applicationEvent;                doTaskEnd();            }            else if(applicationEvent instanceof ExitCodeEvent){                this.exitCodeEvent = (ExitCodeEvent) applicationEvent;            }            else if(applicationEvent instanceof ApplicationReadyEvent) {                doTaskEnd();            }        }        }