XXL-JOB原理
2022-06-13 10:57:29 3 举报详细可看B站视频https://www.bilibili.com/video/BV1HU4y1H7Aw/
作者其他创作
大纲/内容
任务管理
启动执行器服务
启动了一个回调线程
10:00:03jobId:3
2、任务时间
3、任务执行前：任务队列
任务3:handler
09:59:58jobId:3
线程
初始化Admin服务
09:59:52jobId:7
执行
任务2:handler
注册方法
启动了一个日志线程
执行器管理
09:59:56jobId:4
09:59:55jobId:2
Container
生成JobLog日志入库
Admin系统
任务5:handler
启动注册心跳检测线程
直接舍弃
10:00:01jobId:4
09:59:57jobId:5
4、任务执行中
10:00:02jobId:5
回调线程
更新Log状态
09:59:59jobId:1
开启回调线程
执行器服务本体
获取Admin服务
服务
1、执行器注册流程
回调队列
10:00:00jobId:2
账号管理
任务超时时间判断
回调服务
TriggerCallbackThread批量从回调队列中获取数据
预读5秒，存入时间轮中
开启了一个执行器自己的NettHttp服务
任务6:handler
停止
编辑任务参数
09:59:53jobId:6
执行器本体（AppName)
将任务放入触发器线程池
调用execute方法
顺序拉取
调度器
快慢线程池选择
启动了一个注册线程
日志管理
回调方法
09:59:54jobId:1
任务4:handler
JobThread顺序从队列中获取数据
执行器AppName
大于当前时间，直接存入时间轮中
获得了一个Admin的代理服务
任务1:handler
获取任务执行线程JobThread
将结果插入回调队列中
执行器Run方法
注册服务
任务请求插入度队列中
管理
失败
进入任务触发器
执行器本体
任务状态
管理功能
任务服务2
队列
启动执行器注册线程（30s)
10:00:00jobId:8
获取执行器服务
开启日志清理线程
成功
立马执行
10:00:04jobId:7
日志查看
任务时间选中任务
任务服务1
90秒未更新直接删除
路由策略选择执行器
任务请求队列
时间超时该任务直接置为失败
5、任务执行后
批量拉取
任务阻塞策略
获取对应的Log日志
0 条评论
下一页
