分布式任务解决方案

Elastic-Job介绍

官网：http://elasticjob.io/index_zh.html

由当当网基于Quartz + Zookeeper的二次开放产品

• 基于Zookeeper分布式锁，保证只有一个服务去执行定时任务。

• 基于Zookeeper实现了注册中心，自动帮助我们去调度指定的服务执行定时任务。

• 基于Zookeeper实现了注册中心，基于心跳的方式，自动去检测服务的健康情况。

• 

   

Elastic-Job实现分布式任务

springboot项目

导入依赖  

<dependency>
    <groupId>com.dangdang</groupId>
    <artifactId>elastic-job-lite-spring</artifactId>
    <version>2.1.5</version>
</dependency>

配置Zookeeper信息

@Bean
public CoordinatorRegistryCenter center(){
    CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(
            new ZookeeperConfiguration("192.168.199.109:2181,192.168.199.109:2182,192.168.199.109:2183", "elastic-job-demo"));
    regCenter.init();
    return regCenter;
}

 

 创建指定的定时任务

 

配置执行的周期，并且开始调度任务

这里的MyJob 就是上图配置的定时任务。 

下图的center()就是配置zookeeper的配置中心。

 

// 执行任务调度信息 
   @Bean
    public SpringJobScheduler jobConfig(MyJob myJob){

 // 定义作业核心配置
        JobCoreConfiguration jobCoreConfiguration = JobCoreConfiguration.newBuilder("myJob", "0/5 * 15 12 12 ?", 3).build();

 // 定义SIMPLE类型配置
        SimpleJobConfiguration simpleJobConfiguration = new SimpleJobConfiguration(jobCoreConfiguration, MyJob.class.getCanonicalName());

 // 定义Lite作业根配置
        LiteJobConfiguration liteJobConfiguration = LiteJobConfiguration.newBuilder(simpleJobConfiguration).build();

   // 定义SpringJobScheduler
        SpringJobScheduler springJobScheduler = new SpringJobScheduler(myJob,center(),liteJobConfiguration);
        springJobScheduler.init();
        return springJobScheduler;
    }


}

配置zookeeper信息跟配置执行周期都是写在启动类里并注入的，定时任务是自己创建的

适用于一个微服务集群设置定时任务时，任务重复执行。