elastic job源码分析 - 保证分布式任务全部开始和结束

保证分布式任务全部开始和结束状态监听管理器io.elasticjob.lite.internal.guarantee.GuaranteeListenerManager会启动2个监听器：开始节点删除监听器io.elasticjob.lite.internal.guarantee.GuaranteeListenerManager.StartedNodeRemovedJobListener和完成节点删除监听器io.elasticjob.lite.internal.guarantee.GuaranteeListenerManager.CompletedNodeRemovedJobListener。

public void start() {
    addDataListener(new StartedNodeRemovedJobListener());
    addDataListener(new CompletedNodeRemovedJobListener());
}

开始节点删除监听器

开始节点删除监听器监控zk节点guarantee/started的节点删除事件。当该节点被删除时，任务实例会通知本地所有在分布式作业中只执行一次的监听器任务开始。

if (Type.NODE_REMOVED == eventType && guaranteeNode.isStartedRootNode(path)) {
    for (ElasticJobListener each : elasticJobListeners) {
        if (each instanceof AbstractDistributeOnceElasticJobListener) {
            ((AbstractDistributeOnceElasticJobListener) each).notifyWaitingTaskStart();
        }
    }
}

作业监听器：在任务执行前和执行后执行监听的方法；
每台作业节点均执行的监听：每个节点在任务执行前和执行后均执行；
分布式场景中仅单一节点执行的监听：某一次调度（分布式所有节点）只有一个节点会在任务执行前执行和任务执行后执行。

完成节点删除监听器

完成节点删除监听器监听zk节点guarantee/completed的删除事件。当该节点被删除时，任务实例会通知本地所有在分布式作业中只执行一次的监听器任务结束。

if (Type.NODE_REMOVED == eventType && guaranteeNode.isCompletedRootNode(path)) {
    for (ElasticJobListener each : elasticJobListeners) {
        if (each instanceof AbstractDistributeOnceElasticJobListener) {
            ((AbstractDistributeOnceElasticJobListener) each).notifyWaitingTaskComplete();
        }
    }
}