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.啟動調度器----------------------------------------------------------------------