DataX-web调度代码时序图
2021-12-07 15:12:42 0 举报
登录查看完整内容
为你推荐
查看更多
DataX-web调度代码时序图
作者其他创作
大纲/内容
传递参数，netty服务端，反序列化传参数，反射执行executor节点的ExecutorBizImpl类的run方法run()
channel()
processTriger()
NettyHttpServerHandler
new
JobScheduler
initJobHandlerMethodRepository()获取applicationContext中标注XxlJob的处理类，并反射实例化进缓存jobHandlerRepository
初始化日志统计线程start()
trigger()
作业调度trigger()
start()
server.newInstance()
serviceRegistry.newInstanc()
JobTriggerPoolHelper
初始化作业调度线程start()
获取Proxy动态代理对象getExecutorBiz()
调度执行器runExecutor()
ExecutorBiz
group()
JobRegistryHelper
XxlRpcProviderFactory
writeResponse()
初始化失败作业处理线程start()
JobTrigger
初始化任务结果丢失处理线程start()
初始化admin节点客户端initAdminBizList()
ExecutorBizImpl
初始化init()
JobLogReportHelper
在服务端启动回调里面向admin节点注册executor信息ExecutorRegistryThread.getInstance().start()
启动执行器start()
addLast()
初始化调度线程池toStart()
JobScheduleHelper
初始化admin/executor注册与监控线程start()
射调用admin节点传过来的方法invokeService（）
startServer
TriggerCallbackThread
日志文件清理线程JobLogFileCleanThread.getInstance().start()
ExecutorServiceRegistry
JobCompleteHelper
作业回调处理线程TriggerCallbackThread.getInstance().start()
childHandler()
channelRead0()
process()
JobLogFileCleanThread
AbstractServer
addTrigger()
onStart()
启动netty服务端包装服务start()
JobSpringExecutor
JobFailMonitorHelper
JobExecutor
ServerBootstrap
初始化executor节点initRpcProvider()
0 条评论
回复 删除
下一页
