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

elastic job作业初始化

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

elastic job作业初始化

elastic job通过下面代码启动作业:

new JobScheduler(createRegistryCenter(), createJobConfiguration()).init();

启动作业过程中,首先会更新作业配置:

LiteJobConfiguration liteJobConfigFromRegCenter = schedulerFacade.updateJobConfiguration(liteJobConfig);

该方法会做两件事情:
1、当前实例作业配置持久化到zk;
2、从zk重新加载作业配置覆盖当前实例作业配置。

持久化配置
configService.persist(liteJobConfig);

持久化配置时首先会校验作业配置信息:判断zk是否包含当前作业配置,如果存在且实现类不一致时,抛出异常:

throw new JobConfigurationException("Job conflict with register center. The job '%s' in register center's class is '%s', your job class is '%s'", liteJobConfig.getJobName(), liteJobConfigFromZk.get().getTypeConfig().getJobClass(), liteJobConfig.getTypeConfig().getJobClass());

校验通过后,以下两种情况会已当前实例作业配置覆盖zk作业配置:

zk不存在该作业配置;
zk存在,但作业配置包含需要覆盖zk作业配置属性(overwrite = true)

if (!jobNodeStorage.isJobNodeExisted(ConfigurationNode.ROOT) || liteJobConfig.isOverwrite()) {    // 覆盖zk作业配置
}

持久化作业配置即把LiteJobConfiguration对象转换为json格式,然后创建zk节点jobName/config,值为转换后的json数据。

重新加载配置

持久化作业配置后,当前实例会重新从zk服务器加载最新的作业配置信息,且不使用缓存。

configService.load(false);

该方法会直接从zk节点jobName/config获取数据(json格式),而后把原始数据转换为LiteJobConfiguration对象,并覆盖本地配置。

流程图

更新作业配置



作者:耶也夜
链接:https://www.jianshu.com/p/c584aeee2077


转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/245464.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

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

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