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:
         * <ul>
         *     <li>{@link ContextRefreshedEvent} - Start of a task</li>
         *     <li>{@link ApplicationReadyEvent} - Successful end of a task</li>
         *     <li>{@link ApplicationFailedEvent} - Failure of a task</li>
         * </ul>
         *
         * @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();
            }
        }
        }