栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Hzero调度服务 主要功能点源码分析

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Hzero调度服务 主要功能点源码分析

HZERO版本:1.0.0.RELEASE

调度结果和客户端执行结果回写逻辑
发起调度
org.hzero.scheduler.infra.job.MyJob#execute

客户端执行
org.hzero.boot.scheduler.app.service.impl.JobExecuteServiceImpl#jobExecute
串行任务和lockTime配置
参数设置
org.hzero.scheduler.domain.service.impl.JobServiceImpl#getMap

逻辑调用
org.hzero.scheduler.infra.job.MyJob#execute
if (Objects.equals(serial, Flag.YES) && !JobLock.addLock(jobId)) {
        logger.info(" Scheduler Job Locked.  JobId : {} ", jobId);
    }
IJobHandler原理 & Job IJobHandler
org.hzero.boot.scheduler.infra.init.ExecutorInit#scanJobHandler

org.hzero.boot.scheduler.app.service.impl.JobExecuteServiceImpl#jobExecute
Job

QuartzSchedulerThread通过ThreadPool来执行封装Job的JobRunShell;

Job接口是要实现execute方法的.JobRunShell run方法会实例化job实现类,然后调用execute.run方法

org.quartz.core.QuartzSchedulerThread#run

org.quartz.core.JobRunShell#run
失败处理策略 & 重试次数
org.hzero.scheduler.infra.job.MyJob#failureStrategy
执行器 & 执行器策略
org.hzero.scheduler.domain.service.impl.UrlServiceImpl#getUrl
报警邮件
org.hzero.scheduler.infra.job.MyJob#failCallback
任务参数
设置参数
org.hzero.scheduler.infra.job.MyJob#execute

转化参数
org.hzero.boot.scheduler.app.service.impl.JobExecuteServiceImpl#jobRun
Cron & 周期性 & 有效时间
org.hzero.scheduler.domain.service.impl.JobServiceImpl#buildTrigger
自动初始化
org.hzero.scheduler.infra.init.SchedulerServiceInit#run
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/684397.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号