zoukankan      html  css  js  c++  java
  • Elastic-Job-Lite分析——作业调度器 JobScheduler 的创建过程

    -----------------------------------1. 创建注册中心的对象-------------------------------------------------------------
    ZookeeperConfiguration zkConfig = new ZookeeperConfiguration(ZOOKEEPER_CONNECTION_STRING, JOB_NAMESPACE);
    CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(zkConfig);
    regCenter.init();
    -----------------------------------2. 作业事件配置--------------------------------------------------------------------
    BasicDataSource dataSource = new BasicDataSource(); //创建数据源
    ................... //数据源的设置
    //作业数据库事件配置
    JobEventConfiguration jobEventConfig = new JobEventRdbConfiguration(dataSource);
     
     
     
    ------------------------------------3.创建作业核心配置--------------------------------------------------------------
    //创建简单作业配置构建器.
    JobCoreConfiguration.Builder builder = JobCoreConfiguration.newBuilder("javaSimpleJob", "0/5 * * * * ?", 3) ;
    //设置分片参数
    builder.shardingItemParameters("0=Beijing,1=Shanghai,2=Guangzhou") ;
     
    //创建作业核心配置
    JobCoreConfiguration coreConfig = builder.build() ;
     
    ------------------------------------4.创建作业类型配置-------------------------------------------------------------
    //创建作业类型配置
    SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(coreConfig, JavaSimpleJob.class.getCanonicalName());
     
    ------------------------------------5.创建 Lite作业配置---------------------------------------------------------------
    LiteJobConfiguration.Builder jobBuilder = LiteJobConfiguration.newBuilder(simpleJobConfig) ;
    LiteJobConfiguration liteJobConfiguration jobBuilder.build() ;
     
    -----------------------------------6.创建调度器-----------------------------------------------------------------------
    JobScheduler jobScheduler = new JobScheduler(regCenter, liteJobConfiguration , jobEventConfig) ;
     
    -----------------------------------7.启动调度器----------------------------------------------------------------------
  • 相关阅读:
    Apache虚拟目录的建立
    自制户外登山地图傻瓜书
    经纬度与高克投影转换代码(VB)
    2000国家大地坐标系
    js格式化 Thu Mar 07 2019 12:00:00 GMT+0800 (中国标准时间) 及相互转化
    Javascript农历与公历相互转换
    Numpy
    日期多选插件Kalendae.js
    Scrapy项目实战
    bootstrapdatetimepicker添加支持显示农历节假日信息。
  • 原文地址:https://www.cnblogs.com/hzhuxin/p/6811808.html
Copyright © 2011-2022 走看看