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{ ... @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(); } } }