tbschedule3.3.3源码详解
tbschedule是出自淘宝的一个分布式任务调度框架,经过了众多大型项目的考验。了解及使用可参考官方文档 http://code.taobao.org/p/tbschedule/wiki/index/
tbschedule的数据结构
下面从tbschedule的初始化流程入手,一步步分析tbschedule的实现。
tbschedule的初始化流程——详解
1.入口TBScheduleManagerFactory
2.TBScheduleManagerFactory执行流程
说明:
1)、TBScheduleManagerFactory的init方法,创建了ZKManager和InitialThread;ZKManager主要管理和zk的连接和根目录的创建,InitialThread继承了Thread,接下来的初始化流程就有InitialThread线程完成,init方法结束。
2)、InitialThread线程调用TBScheduleManagerFactory的initialData方法完成初始化,InitialThread线程结束。initialData方法中
(1),调用zkManager.initial()创建跟路径
(2),new ScheduleDataManager4ZK(this.zkManager)
(3),new ScheduleStrategyDataManager4ZK(this.zkManager)
(4),注册调度管理器scheduleStrategyManager.registerManagerFactory(this)
(5),new ManagerFactoryTimerTask(this)并调度
ScheduleDataManager4ZK主要负责RootPath/baseTaskType路径下节点和数据的维护
ScheduleStrategyDataManager4ZK负责RootPath/strategy和RootPath/factory路径下节点的维护
registerManagerFactory方法主要是创建this.PATH_ManagerFactory/IP$HOSTNAME$uuid$sqe-num和this.PATH_Strategy/StrategyName/IP$HOSTNAME$uuid$sqe-num,即机器的数量和能处理此策略的机器数量
ManagerFactoryTimerTask的功能是定时的刷新任务调度器的数据,计算每台机器需要的线程组数,并启动相应数量的线程组(TBScheduleManagerStatic)
3)、ManagerFactoryTimerTask调用TBScheduleManagerFactory的refresh方法,refresh中调用reRegisterManagerFactory,reRegisterManagerFactory方法的主要流程是调用registerManagerFactory,assignScheduleServer和reRunScheduleServer方法。ManagerFactoryTimerTask一个运行周期结束。