java版电子商务springcloud分布式微服务b2b2c-SpringCloudTask

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

网站题目:java版电子商务springcloud分布式微服务b2b2c-SpringCloudTask
网页URL:http://ybzwz.com/article/gsegej.html