nacos 源码解析系列（五）

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到磁盘中