xxljob执行源码分析
已包含中文注释的源码压缩包：
xxl-job-master.zip
(7.8 MB)
分析流程：
xxljob直播.xmind
(493 KB)
1.架构分析
2.执行源码
核心代码位置如下：
1-initI18n()
初始化国际化资源，对应配置文件：resources：i18n
2-JobTriggerPoolHelper.toStart()
触发器线程池：创建快慢线程池，提升任务执行效率
如果一个任务在1min内超过10次提交，就默认是慢任务，为了防止慢任务影响系统吞吐量，将其放在慢线程池中运行
快线程池定义：最大线程数=200，等待队列=1000
慢线程池定义：最大线程数=100，等待队列=2000
addTrigger方法
默认选择快线程池，如果任务在1min内超过10次提交，就是慢线程池
真正的触发器操作代码
3-JobRegistryHelper.getInstance().start()
任务注册器线程池：将上线机器刷新(最近90s有心跳)，将下线机器移除(90s内没心跳)，更新执行组
初始化服务上线/下线线程池：将新增的IP添加到组中，将断线的IP及时清理(因为执行器会上下线，xxl-job会保证及时更新当前在线的执行器)
初始化心跳检测的线程池：xxl-job会把心跳信息保存在xxl_job_registry，借助心跳检测机制，保证机器下线能够及时清楚，机器上线及时发现
4-JobFailMonitorHelper.getInstance().start()
重试报警机制：因为任务是异步调用，需要有一个进程持续监听执行结果，主要做的是：读取本地数据，更新数据状态，未达到失败次数就重试，达到失败次数就告警
借助mybatis查询本地数据库执行失败、且告警状态=0[未告警]的数据日志ID，读取表：xxl_job_log
更新告警状态=-1[锁定，避免多线程并发干扰]，0-默认、-1=锁定状态、1-无需告警、2-告警成功、3-告警失败
基于日志ID取出完整的日志信息，读取表：xxl_job_log
基于ID获取失败日志对应的任务信息，读取表：xxl_job_info
如果失败任务可充实次数大于0，表示还能重试，就继续重试
如果配置了告警信息，就实现报警
报警后更新本地告警状态，2或3
5-JobCompleteHelper.getInstance().start()
调度系统调度执行器后，执行器突然宕机，调度系统就可以根据这个线程感知任务到底执行成功还是失败
任务结果丢失处理：调度记录停留在 "运行中" 状态超过10min，且对应执行器心跳注册失败不在线，则将本地调度主动标记失败；
6-JobLogReportHelper.getInstance().start()
清理过期日志，没什么需要详细讲解的
7-JobScheduleHelper.getInstance().start()
从xxl_job_info表中找出当前时间+5s的所有执行器数据，然后根据其调度时间判断立即调度还是加入时间戳
取出当前时间 + 5s内所有待执行的执行器数据(避免循环本身导致错过执行时间)
建立数据库链接
关闭事务的自动提交
悲观锁，锁定数据
过期处理策略
可能过期的原因：服务重启；调度线程被阻塞，线程被耗尽；上次调度持续阻塞，下次调度被错过
从数据库取出当前时间+5s的所有任务
当前时间：超过调度时间+5s
判断任务执行状态是否是：FIRE_ONCE_NOW，如果是就立马调度一次
刷新调度时间，避免下一次再错过
当前时间：超过调度时间，但还没超过5s
调度一次
更新调度时间，避免下一次再错过
当前时间：没超过调度时间，把调度时间加入到时间轮中
获取调度时间的秒
将调度时间作为key，任务id作为value，放进调度任务时间轮的map中(其执行代码在：238行)
刷新下一次调度时间(这里就不是new Date()了，而是真实的执行时间)
更新每一个任务的最近一次执行时间、下一次执行时间、执行状态
时间轮执行原理
时间轮执行原理：com.xxl.job.admin.core.thread.JobScheduleHelper#ringThread
先延迟0-1秒，以保证加载所有数据
获取当前时间对应的秒数
避免处理耗时太长，跨过刻度，向前校验一个刻度
这里的ringData就是上面场景3中添加进去的数据，当前文件代码：149行
当前秒+1是为了防止时间轮中的任务由于意外没有执行，从而有一个补偿机制
调度任务
清空已处理数据
