powerjob-server
2020-07-27 16:56:27 12 举报powerjob-server
作者其他创作
大纲/内容
swagger uiSwaggerConfig
通过服务器ip创建IdGenerateService用于分配分布式唯一ID
OmsScheduleService#timingSchedule任务调度执行服务 固定频率 15S运行一次SCHEDULE_RATE = 15000
读取oms-server.akka.conf
创建ServerTroubleshootingActor容器处理server的异常信息
读取oms.akka.port本地IP NetUtils.getLocalHost()
taskScheduler用于定时调度的线程池
omsTimingPool执行定时任务的线程池
InstanceLogService#sync将本地的任务实例运行日志同步到 mongoDB 存储，在任务执行结束后异步执行
omsCommonPool执行普通任务的线程池
邮件通知服务DefaultMailAlarmService
创建ActorSystem运行Actor容器并管理生命周期
删除10分钟之前的秒级任务日志
启动webscoket服务/container/deploy/{id}用于容器部署
创建ServerActor容器处理Worker请求span style=\"font-size: inherit;\
对外提供服务: 端口7700
任务实例和工作流实例发现异常重试
OnMyServer.init
pre();删除历史遗留的 H2 数据库文件
初始化线程池配置ThreadPoolConfig
SpringApplication.Run
CleanService#timingClean定时清理服务 cron 每日3点
InstanceLogService#timingCheck任务日志清除 固定延迟 60S运行一次
omsBackgroundPool执行后台任务的线程池
InstanceStatusCheckService#timingStatusCheck检查实例状态 固定频率 10S运行一次
创建FriendActor容器处理服务器与服务器之间的通信1.发ping 检测机器是否存活2.查询Worker集群状态
收藏
收藏
0 条评论
下一页
