SpringCloud分布式微服务云架构-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();
            }
        }
        }