概述
Elastic-Job是一个分布式调度解决方案，由两个相互独立的子项目Elastic-Job-Lite和Elastic-Job-Cloud组成。
官方文档地址:http://elasticjob.io/docs/elastic-job-lite/00-overview/
提供了如下功能

• 分布式调度协调
• 弹性扩容缩容
• 失效转移
• 错过执行作业重触发
• 作业分片一致性，保证同一分片在分布式环境中仅一个执行实例
• 自诊断并修复分布式不稳定造成的问题
• 支持并行调度
• 支持作业生命周期操作
• 丰富的作业类型
• Spring整合以及命名空间提供
• 运维平台

单机定时任务
通常我们在开发过程中或多或少会运用到定时任务。常用单机定时任务我们常用的包括:

• java自带的timer
• ScheduledExecutorService
• spring定时任务
• Quartz 也可支持分布式

单机定时任务的缺点

• 缺乏高可用性,单机式的定时任务调度只能在一台机器上运行，程序或系统异常将导致功能不可用
• 单机处理极限，单机的分布式调度只能在一台机器上执行，收到单机CUP内存等的限制

elastic-job的使用场景
elastic-job就是一个分布式的定时任务调度,我们能用它做什么?
例如有个需求需要在每天晚上统计当天的订单订单情况,单机模式下我们会写一段程序去处理，假如有10万个订单，处理成功需要耗时很长时间，且在机器瓶颈下可能会导致内存不足等情况。若使用elastic-job,我们则可以考虑将定时任务进行分片，让其分布在不同的机器上运行，提供可用性，减少单机失败带来的功能不可用。例如当下有2台机器，将任务分成4片，则每台机器处理其中2片任务。


文章图片
image.png 使用实例初探
根据上图，实现将任务分成4片，分别在2台机器上执行
任务类

//具体执行的任务类 public class MyElasticJob implements SimpleJob { public final static Logger logger = LoggerFactory.getLogger(MyElasticJob.class); @Override public void execute(ShardingContext shardingContext) { int shardingTotalCount = shardingContext.getShardingTotalCount(); String shardingParameter = shardingContext.getShardingParameter(); //任务的分片项，从0开始递增例如有四个分片则序号为0~4 int shardingItem = shardingContext.getShardingItem(); //分片带的参数例如0=A,1=B,2=C,3=D String jobParamter = shardingContext.getJobParameter(); logger.info("shardingItem =" + shardingItem + " , shardingTotalCount=" + shardingTotalCount + " , shardingParameter =" + shardingParameter + " ,jobParamter =" + jobParamter); //System.out.println("shardingItem =" + shardingItem + " , shardingTotalCount=" + shardingTotalCount + " , shardingParameter =" + shardingParameter + " ,jobParamter =" + jobParamter); switch (shardingItem){ case0: doLongJob("食品订单"); break; case 1: doSmallJob("电脑订单"); break; case 2: doLongJob("服装订单"); break; case 3: doSmallJob("机械订单"); break; } }public void doLongJob(String msg){ logger.info("========长时间任务=======" + msg); try { TimeUnit.SECONDS.sleep(60); } catch (InterruptedException e) { e.printStackTrace(); } }public void doSmallJob(String msg){ logger.info("========短时间任务=======" + msg); } }

配置类

public class FastDemo { private static CoordinatorRegistryCenter createRegistryCenter(){ //elasticjob采用zookeeper进行任务的调度，根据抢主的方式实现同一时刻只有一个任务在一台机器上执行,保证不重复，这里配置zookeeper的地址 CoordinatorRegistryCenter registryCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration("192.168.0.103:2181","elastic-job-demo")); registryCenter.init(); return registryCenter; }private static LiteJobConfiguration createJobConfiguration() { //设置任务每15秒执行一次，一共分成4片，elastic-job会获取当前这个任务一共在多少台服务器上进行平均分配，例如我将war包分别放在了128，129机器上，任务总片为4,则按照elasticjob的默认分配策略，128将执行第0，1片任务，129执行第2，3片任务 JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration .newBuilder("demoSimpleJob", "0/20 * * * * ?", 4) .shardingItemParameters("0=A,1=B,2=C,3=D") .jobParameter("xuzy") .failover(true) //设置失效转移,当一台机器挂了以后他的分片会让其他台服务器执行 .build(); // 定义SIMPLE类型配置 SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, MyElasticJob.class.getCanonicalName()); // 定义Lite作业根配置 LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build(); return simpleJobRootConfig; }public static void initJob(){ new JobScheduler(createRegistryCenter(), createJobConfiguration()).init(); } }

ServletContextLTest类

public class ServletContextLTest implements ServletContextListener { @Override public void contextInitialized(ServletContextEvent sce) { FastDemo.initJob(); }@Override public void contextDestroyed(ServletContextEvent sce) { } }

web.xml

com.xzy.elasticjob.servletListener.ServletContextLTest

将项目打包成war分别放在128,129上面分别观察日志
128日志

[root@server-1 bin]# taif -f /var/logs/elasticjob.log -bash: taif: command not found [root@server-1 bin]# tail -f /var/logs/elasticjob.log Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally. NOT STARTED. Currently in standby mode. Number of jobs executed: 0 Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 1 threads. Using job-store 'org.quartz.simpl.RAMJobStore' - which does not support persistence. and is not clustered.2019-04-27 02:12:03 [ INFO] - org.quartz.impl.StdSchedulerFactory -StdSchedulerFactory.java(1339) -Quartz scheduler 'demoSimpleJob' initialized from an externally provided properties instance. 2019-04-27 02:12:03 [ INFO] - org.quartz.impl.StdSchedulerFactory -StdSchedulerFactory.java(1343) -Quartz scheduler version: 2.2.1 2019-04-27 02:12:04 [ INFO] - org.quartz.core.QuartzScheduler -QuartzScheduler.java(575) -Scheduler demoSimpleJob_$_NON_CLUSTERED started. 2019-04-27 02:12:15 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =2 , shardingTotalCount=4 , shardingParameter =C ,jobParamter =xuzy 2019-04-27 02:12:15 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(42) -========长时间任务=======服装订单 2019-04-27 02:12:15 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =3 , shardingTotalCount=4 , shardingParameter =D ,jobParamter =xuzy 2019-04-27 02:12:15 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(51) -========短时间任务=======机械订单 2019-04-27 02:13:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =2 , shardingTotalCount=4 , shardingParameter =C ,jobParamter =xuzy 2019-04-27 02:13:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(42) -========长时间任务=======服装订单 2019-04-27 02:13:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =3 , shardingTotalCount=4 , shardingParameter =D ,jobParamter =xuzy 2019-04-27 02:13:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(51) -========短时间任务=======机械订单 2019-04-27 02:14:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =2 , shardingTotalCount=4 , shardingParameter =C ,jobParamter =xuzy 2019-04-27 02:14:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(42) -========长时间任务=======服装订单 2019-04-27 02:14:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =3 , shardingTotalCount=4 , shardingParameter =D ,jobParamter =xuzy 2019-04-27 02:14:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(51) -========短时间任务=======机械订单

129日志

[root@server-2 bin]# tail -f /var/logs/elasticjob.log 2019-04-27 02:12:15 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =1 , shardingTotalCount=4 , shardingParameter =B ,jobParamter =xuzy 2019-04-27 02:12:15 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(51) -========短时间任务=======电脑订单 2019-04-27 02:13:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =0 , shardingTotalCount=4 , shardingParameter =A ,jobParamter =xuzy 2019-04-27 02:13:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(42) -========长时间任务=======食品订单 2019-04-27 02:13:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =1 , shardingTotalCount=4 , shardingParameter =B ,jobParamter =xuzy 2019-04-27 02:13:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(51) -========短时间任务=======电脑订单 2019-04-27 02:14:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =0 , shardingTotalCount=4 , shardingParameter =A ,jobParamter =xuzy 2019-04-27 02:14:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(42) -========长时间任务=======食品订单 2019-04-27 02:14:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =1 , shardingTotalCount=4 , shardingParameter =B ,jobParamter =xuzy 2019-04-27 02:14:30 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(51) -========短时间任务=======电脑订单 2019-04-27 02:15:45 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =0 , shardingTotalCount=4 , shardingParameter =A ,jobParamter =xuzy 2019-04-27 02:15:45 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(42) -========长时间任务=======食品订单 2019-04-27 02:15:45 [ INFO] - com.xzy.elasticjob.MyElasticJob -MyElasticJob.java(23) -shardingItem =1 , shardingTotalCount=4 , shardingParameter =B ,jobParamter =xuzy

可以看到128,129分别处理了不同的数据分片，期间假如128服务器挂了，由于配置了失效转移，原来128的服装订单、机械订单任务将转移给129继续执行
elastic-job作业调度-zookeeper
elastic-job是通过zookeeper进行任务协调和故障转移。
当启动项目后会发现任务在zookeeper注册了节点，如下,首先在根据我们的配置创建了/elastic-job-demo/demoSimpleJob节点，对应的config,instances, leader, servers和sharding


文章图片
image.png

• config节点
  config节点记录了任务的配置信息，包含执行类，cron表达式，分片算法类，分片数量，分片参数。默认状态下，如果你修改了Job的配置比如cron表达式，分片数量等是不会更新到zookeeper上去的，除非你把参数overwrite修改成true或者使用rmr /elastic-job-demo/demoSimpleJob命令删除节点并重新启动创建

{ "jobName": "demoSimpleJob", //任务名称 "jobClass": "com.xzy.elasticjob.MyElasticJob", //具体执行类 "jobType": "SIMPLE", //任务类型 "cron": "0/20 * * * * ?", //任务实行时间corn "shardingTotalCount": 4, //总分片数 "shardingItemParameters":"0\u003dA,1\u003dB,2\u003dC,3\u003dD", //分片参数 "jobParameter": "xuzy", //任务参数 "failover": true, //是否失效转移 "misfire": true, "description": "", "jobProperties": { "job_exception_handler": "com.dangdang.ddframe.job.executor.handler.impl.DefaultJobExceptionHandler",//默认的异常处理类 "executor_service_handler": "com.dangdang.ddframe.job.executor.handler.impl.DefaultExecutorServiceHandler" //默认的作业处理线程池类 }, "monitorExecution": true, "maxTimeDiffSeconds": -1, "monitorPort": -1, "jobShardingStrategyClass": "", "reconcileIntervalMinutes": 10, "disabled": false, //作业是否禁止启动 "overwrite": false //本地配置是否可覆盖注册中心配置 }

• instances节点
  同一个Job下的elastic-job的部署实例。一台机器上可以启动多个Job实例，也就是Jar包。instances的命名是IP+@-@+PID
  如图，demoSimpleJob有两个实例，地址如下
  
  
  文章图片
  image.png
  
• leader节点
  任务实例的主节点信息，通过zookeeper的主节点选举，选出来的主节点信息。下面的子节点分为election，sharding和failover三个子节点。分别用于主节点选举，分片和失效转移处理。election下面的instance节点显式了当前主节点的实例ID：jobInstanceId。latch节点也是一个永久节点用于选举时候的实现分布式锁。sharding节点下面有一个临时节点，necessary，是否需要重新分片的标记。如果分片总数变化，或任务实例节点上下线或启用/禁用，以及主节点选举，都会触发设置重分片标记，主节点会进行分片计算
  
  
  文章图片
  image.png
• servers节点
  记录了任务实例的信息
  
  
  文章图片
  image.png
• sharding节点
  任务的分片信息，子节点是分片项序号，从零开始，至分片总数减一。从这个节点可以看出哪个分片在哪个实例上运行
  
  
  文章图片
  image.png
  
  文章图片
  image.png

elastic-job-lite-console
elastic-job-lite-console是elasticjob提供的管理工具
安装方法

• 在https://github.com/miguangying/elastic-job-lite-console下载zip文件并压缩得到tar.gz。如果是linux则将tar.gz放到linux解压，可以得到start.sh，点击执行。如果是window则再次解压tar.gz得到start.bat直接点击执行
• 登录用户名密码root/root,默认端口8899
• 【《elastic-job》学习】进入首页后添加注册中心配置命名空间为代码上的命名空间，页面上可以查看每个作业的运行情况和进行手动触发
  
  
  文章图片
  image.png
  
  文章图片
  image.png
  
  文章图片
  image.png
  
  文章图片
  image.png

推荐阅读

• 

  事例如何分析一篇通讯
• 

  空气炸锅炸的蛋糕多久能熟 空气炸锅炸的蛋糕多久能熟透
• 

  redis基本常用的方法，redis基础用法
• 

  安卓手机查看本机网关,wifi静态ip和dns怎么用?
• 

  手表|上海江诗丹顿手表的保养方法
• 

  封控区解封后黄码会变绿码吗
• 

  切斯特·米尔顿·萨瑟姆|把癌细胞注射到健康人体内，会得癌吗？还真有科学家做了相关试验
• 

  黑法师的养殖方法 黑法师的养殖方法和注意事项无图片
• 

  艾先生讲古之混乱之子Sons of Anarchy 混乱之子吧
• 

  梨水可以止咳化痰吗 冰糖梨水可以止咳化痰吗
• 

  辐射避难所怎么合并房子
• 

  dnf刷图职业排行2020年10月 dnf95平民一线刷图职业
• 

  熟地黄怎么做汤
• 

  小型全身按摩器 – 小型手拿按摩器种类
• 

  枕头芯的种类有哪些
• 

  花木兰的品质和精神 花木兰的品质和精神在哪里
• 

  投稿|家装互联网，困于“局域网”？
• 

  眼线胶笔要怎么使用呢
• 

  给老人重阳节祝福语简短
• 

  react源码debugger之理解调度（使用react17版本）

• 慢慢的美丽
• 《真与假的困惑》???|《真与假的困惑》??? ——致良知是一种伟大的力量
• 《跨界歌手》:亲情永远比爱情更有泪点
• 诗歌:|诗歌: 《让我们举起世界杯，干了！》
• 期刊|期刊 | 国内核心期刊之（北大核心）
• 《魔法科高中的劣等生》第26卷（Invasion篇）发售
• 人间词话的智慧
• 《一代诗人》37期，生活，江南j，拨动心潭的一泓秋水
• 广角叙述|广角叙述 展众生群像——试析鲁迅《示众》的展示艺术
• 书评——《小行星》