美文网首页Nacos源码系列
nacos 源码解析系列(五)

nacos 源码解析系列(五)

作者: 逗逼程序员 | 来源:发表于2020-07-17 15:02 被阅读0次

    TaskManager 任务管理的使用

    nacos 中很多地方使用了TaskManager ,所以我们得先了解下这个类是干啥的,方便后面阅读不吃力。

    先说结论,TaskManager 可以看作是一个待执行任务的集合,用于处理一定要执行成功的任务单线程的处理任务,保证任务一定被执行成功;如果执行失败了,任务会被重新放入集合中等待下一次的消费。

    AbstractTask

    AbstractTask 是个抽象类,所有需要被执行的任务都会继承这个类,这个类主要提供执行任务所需要的数据和方法;例如:

       /**
         * Task time interval between twice processing, unit is millisecond.
         */
        private long taskInterval;
        
        /**
         * The time which was processed at last time, unit is millisecond.
         */
        private long lastProcessTime;
    
      public boolean shouldProcess() {
            return (System.currentTimeMillis() - this.lastProcessTime >= this.taskInterval);
        }
    

    TaskProcessor任务处理器

    TaskProcessor 是任务处理器接口,它有个方法

      boolean process(String taskType, AbstractTask task);
    

    用于执行对应的AbstractTask任务类; 不同的任务类型,可以实现自己的执行任务逻辑;

    TaskManager任务管理类

    TaskManager 是个任务管理类;

    它里面有两个属性保存了待消费的任务AbstractTask,和任务执行需要的TaskProcessor;

    如果taskProcessors中没有找到对应的任务执行器,那么它里面有一个默认执行器会执行

     private TaskProcessor defaultTaskProcessor;
    

    使用用例

    nacos 配置中心模块很重要的一个功能就是,在初始化的时候以及每隔一段时间就回去数据库中把所有数据Dump到磁盘中;Dump就是一个任务类 AbstractTask;我们上面说过,AbstractTask 就是一个信息承载对象,主要给TaskProcessor 提供所需要的数据,我们看看DumpTask :

    DumpTask

     public DumpTask(String groupKey, long lastModified, String handleIp) {
            this.groupKey = groupKey;
            this.lastModified = lastModified;
            this.handleIp = handleIp;
            this.isBeta = false;
            this.tag = null;
            // retry interval: 1s
            setTaskInterval(1000L);
        }
    

    既然有DumpTask任务类,那肯定就有对应的任务处理器类DumpProcessor;

    DumpProcessor

    DumpProcessor 是DumpTask任务的执行器;执行器中的方法

      public boolean process(String taskType, AbstractTask task) {}
    

    代码太长就不在这里分析了,它里面主要做的操作就是 保存配置文件到本地磁盘中,并缓存md5详细可以参考后面文章DumpService如何将配置文件全部Dump到磁盘中

    相关文章

      网友评论

        本文标题:nacos 源码解析系列(五)

        本文链接:https://www.haomeiwen.com/subject/yvmghktx.html