1 ElasticJob 分布式定时任务调度系统的简介

1.1 项目介绍

Elastic-Job是由当当网基于Quartz 二次开发之后的分布式调度解决方案，是一个分布式调度解决方案，由 2 个相互独立的子项目 ElasticJob-Lite 和 ElasticJob-Cloud 组成。

ElasticJob-Lite 定位为轻量级无中心化解决方案，使用jar的形式提供分布式任务的协调服务。

ElasticJob-Cloud 使用 Mesos 的解决方案，额外提供资源治理、应用分发以及进程隔离等服务。

Elastic-Job 的各个产品使用统一的作业 API，开发者仅需要一次开发，即可随意部署。Elastic-Job开发在停滞数年后，2020年，Elastic-Job 携首个 Apache 版本 3.0.0-alpha 回归！2020年6月，经过Apache ShardingSphere社区投票，接纳Elastic-Job为其子项目。目前ElasticJob的四个子项目已经正式迁入Apache仓库。并更名为shardingsphere-elasticjob。对于功能强大的分布式调度系统elastic-job很多优秀的分布式设计思想值得学习，接下来本系列文章会针对Elastic-Job版本2.1.5的核心源码与原理进行分析讲解。

1.2 分布式弹性调度系统特征

（1） 弹性调度
支持任务在分布式场景下的分片和高可用。
能够水平扩展任务的吞吐量和执行效率。

任务处理能力随资源配备弹性伸缩。

（2）资源分配

在适合的时间将适合的资源分配给任务并使其生效。

相同任务聚合至相同的执行器统一处理。

动态调配追加资源至新分配的任务 。

（3）作业治理

失效转移执行。

错过执行作业重新触发。

自诊断并修复分布式不稳定造成的问题。

支持并行调度。

作业调度。

幂等执行。

（4）作业依赖（2.x 目前未实现功能TODO，迁移后的项目后期会实现）

基于有向无环图（DAG）的作业间依赖。

基于有向无环图（DAG）的作业分片间依赖。

（5）作业开放生态

可扩展的作业类型统一接口。

丰富的作业类型库，如数据流、脚本、HTTP、文件、大数据等

易于对接业务作业，能够与 Spring 依赖注入无缝整合。

（6）可视化管控端

作业管控端。

作业执行历史数据追踪。

注册中心管理。

作业编排管理。

2 Elastic-Job的使用

2.1 使用Java代码创建第一个调度例子

（1）导入Maven包

  1. <dependency>
  2.   <groupId>com.dangdang</groupId>
  3.  <artifactId>elastic-job-lite-core</artifactId>
  4.  <version>2.1.5</version>
  5. </dependency>

（2）手动启动一个简单的调度例子
实现作业接口，重写作业执行方法，编写作业执行业务逻辑。

Zookeeper注册中心的配置与初始化。

作业属性的配置初始化。

作业调度器对象的创建与初始化。

触发作业。

具体流程如下图所示：
图片

图2.1 ElasticJob作业初始化过程

（3）示例代码
实现一个简单定时任务

  1. public class JavaSimpleJob implements SimpleJob {
  3.  @Override
  4.  public void execute(final ShardingContext shardingContext) {
  5.   System.out.println("Hello Job”);
  6.  }
  7. }

初始化一个定时任务

  1. public class JobDemo {
  2.  public static void main(String[] args) {
  3.     //注册中心地址
  4.   String serverList = "127.0.0.1:2181";
  5.     //调度作业注册中心命名空间名字
  6.   String namespace = "elastic-job-lite-demo";
  7.     //作业执行的cron表达式
  8.   String cron = "* * * * * ?";
  9.     //作业进行分片执行的分片总数
  10.   int shardingTotalCount = 3;
  11.     //分片项参数
  12.   String shardingItemParameters = "0=Beijing,1=Shanghai,2=Guangzhou";
  14.   //Zookeeper初始化
  15.   //创建zookeeper配置对象
  16.   ZookeeperConfiguration zookeeperConfiguration = new ZookeeperConfiguration(serverList, namespace);
  17.   //创建协调注册中心对象
  18.   CoordinatorRegistryCenter zookeeperRegistryCenter = new ZookeeperRegistryCenter(zookeeperConfiguration);
  19.   //初始化注册中心
  20.   zookeeperRegistryCenter.init();
  22.   //作业初始化
  23.   //这里是定义JOB的名字
  24.   String jobName = "JavaSimpleJob";
  25.   //创建作业核心配置的建造者builder类型
  26.   JobCoreConfiguration.Builder javaCoreConfigurationBuilder =
  27.   JobCoreConfiguration.newBuilder(jobName, cron, shardingTotalCount);
  28.   //根据builder构建核心配置
  29.   JobCoreConfiguration jobCoreConfiguration =    javaCoreConfigurationBuilder.shardingItemParameters(shardingItemParameters).build();
  31.   //getCanonicalName 返回包名+类名字，这里是作业执行类的信息
  32.   String canonicalName = JavaSimpleJob.class.getCanonicalName();
  33.   //根据核心配置和作业执行类创建作业类型配置
  34.   JobTypeConfiguration jobTypeConfiguration = new SimpleJobConfiguration(jobCoreConfiguration, canonicalName);
  36.   //根据作业类型配置初始化轻量级作业配置
  37.   LiteJobConfiguration liteJobConfiguration = LiteJobConfiguration.newBuilder(jobTypeConfiguration).build();
  39.   //作业调度器初始化
  40.   JobScheduler jobScheduler = new JobScheduler(zookeeperRegistryCenter,liteJobConfiguration);
  41.   jobScheduler.init();
  42.  }

首先确保zookeeper服务已经启动，然后直接运行main方法即可。
2.2 使用Spring配置一个作业
（1）导入Maven包

  1. <dependency>
  2.  <groupId>com.dangdang</groupId>
  3.  <artifactId>elastic-job-lite-spring</artifactId>
  4.  <version>2.1.5</version>
  5. </dependency>

（2）配置Spring文件
配置注册中心对象

  1. <reg:zookeeper id="regCenter" 
  2.                server-lists="${serverLists}" 
  3.                namespace="${namespace}" 
  4.                base-sleep-time-milliseconds="${baseSleepTimeMilliseconds}"             
  5.                max-sleep-time-milliseconds="${maxSleepTimeMilliseconds}" 
  6.                max-retries="${maxRetries}"/>

配置作业对象

  1. <job:simple id="${simple.id}" 
  2.             class="${simple.class}" 
  3.             registry-center-ref="regCenter"
  4.             sharding-total-count="${simple.shardingTotalCount}"
  5.             cron="${simple.cron}"  
  6.             sharding-item-parameters="${simple.shardingItemParameters}"
  7.             monitor-execution="${simple.monitorExecution}" 
  8.             monitor-port="${simple.monitorPort}"
  9.             failover="${simple.failover}"
  10.             description="${simple.description}" 
  11.             disabled="${simple.disabled}"
  12.             overwrite="${simple.overwrite}" />

本实例只展示来我们配置Spring时候需要铁添加的配置，如果想要完整跑一个项目可以参考官方源码的elastic-job-example示例文件。

参考网站：

查看原文,技术咨询与支持,可以扫描微信公众号进行回复咨询
在这里插入图片描述

,