替換的原因：

我想用quartz實現定時任務叢集的時候，遇到過很坑的問題就是所有做叢集的機器都必須保證時間的一致性，要不然有很多機器的專案是起不來的；除此之外，使用quartz很容易造成資料庫死鎖的問題，雖然我已經降低了quartz的資料庫事務級別，但還是有這種情況發生，所以用過一段時間之後，新的專案就用了elastic-job。

版本：

elastic-job有兩個版本：一個是elastic-job-lite，一個是elastic-job-cloud；一般情況下elastic-job-lite就滿足了，我在專案中用的也是這個，elastic-job-cloud是基於mesos的，雖然功能比lite多，但感覺lite就夠用了，如果有對cloud感興趣的同學可以取官網

使用：

其實他的使用方法在官網都可以找得到，我的是基於springboot的：

1、在application-properties中配置註冊中心和事件追蹤資料來源

#elastic-job叢集支援   開始*************************************************
#zookpeer註冊中心配置
regCenter.serverList=192.168.40.23:2181
regCenter.namespace=cron-provider

#elastic-job事件追蹤資料庫配置
jobEventConfig.url=jdbc:mysql://192.168.40.23:3306/youjia_cron?useUnicode=true&characterEncoding=UTF-8
jobEventConfig.driverClassName=com.mysql.jdbc.Driver
jobEventConfig.username=kudev_w
jobEventConfig.password=nBVHe1M/Q3TKmtLBPseVnVOeFO7jO1Ww
#elastic-job叢集支援   結束*************************************************
 

import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperConfiguration;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 定時任務註冊中心配置
 *
 * @author 高仕立
 * @date 2017/12/18 16:54
 */
@Configuration
@ConditionalOnExpression("'${regCenter.serverList}'.length() > 0")
public class RegistryCenterConfig {

    @Bean(initMethod = "init")
    public ZookeeperRegistryCenter regCenter(@Value("${regCenter.serverList}") final String serverList, @Value("${regCenter.namespace}") final String namespace) {
        return new ZookeeperRegistryCenter(new ZookeeperConfiguration(serverList, namespace));
    }
}
 

import com.dangdang.ddframe.job.event.JobEventConfiguration;
import com.dangdang.ddframe.job.event.rdb.JobEventRdbConfiguration;
import com.youjia.cron.common.util.EncryptUtils;
import org.apache.commons.dbcp.BasicDataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 定時器時事件資料來源配置
 *
 * @author 高仕立
 * @date 2017/12/18 16:36
 */
@Configuration
public class JobEventConfig {

    @Bean
    public JobEventConfiguration jobEventConfiguration(@Value("${jobEventConfig.url}") final String url, @Value("${jobEventConfig.driverClassName}") final String driverClassName,
                                                       @Value("${jobEventConfig.username}") final String username, @Value("${jobEventConfig.password}") final String password) {
        BasicDataSource dataSource = new BasicDataSource();
        dataSource.setUrl(url);
        dataSource.setDriverClassName(driverClassName);
        dataSource.setUsername(username);
        dataSource.setPassword(EncryptUtils.decrypt(password));
        return new JobEventRdbConfiguration(dataSource);
    }
}

4、配置定時任務常量，如果分片為1，部署多臺服務的時候，自動切換為主從

package com.youjia.cron.config.elastic_job;

/**
 * 定時任務常量相關配置類
 *
 * @author 高仕立
 * @date 2017/12/19 10:10
 */
public class JobParamtersConfig {

    /**
     * 測試定時
     */
    public static String test_cron = "0/1 * * * * ?";

    /**
     * 測試作業分片總數
     */
    public static int test_total_count = 2;

    /**
     * 測試分片序列號和引數
     */
    public static String test_shardingItemParameters = "0=A,1=B";
}

import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.simple.SimpleJob;
import com.youjia.cron.common.constants.SmartLockConstant;
import com.youjia.cron.dao.lock.LodLockApplyMapper;
import com.youjia.cron.dao.lodjoinexamine.LodPreOnlineExample;
import com.youjia.cron.dao.lodjoinexamine.LodPreOnlineMapper;
import com.youjia.cron.model.lock.LodLockApply;
import com.youjia.cron.model.lock.LodLockApplyExample;
import com.youjia.cron.service.lock.third.huohe.HuoheTech;
import com.youjia.found.exception.YJException;
import com.youjia.lodge.model.LodPreOnline;
import net.sf.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * 測試定時模組
 *
 * @author 高仕立
 * @date 2017/12/14 14:29
 */
@Component
public class TestJob implements SimpleJob {

    private static final Logger logger = LoggerFactory.getLogger(TestJob.class);

    @Override
    public void execute(ShardingContext context) {
        System.out.println("現在的日期是：" + new Date());
    }

}

6、初始化定時任務：

import com.dangdang.ddframe.job.api.simple.SimpleJob;
import com.dangdang.ddframe.job.config.JobCoreConfiguration;
import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
import com.dangdang.ddframe.job.event.JobEventConfiguration;
import com.dangdang.ddframe.job.lite.api.JobScheduler;
import com.dangdang.ddframe.job.lite.config.LiteJobConfiguration;
import com.dangdang.ddframe.job.lite.spring.api.SpringJobScheduler;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter;
import com.youjia.cron.job.test.TestJob;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.annotation.Resource;

/**
 * @author 高仕立
 * @date 2017/12/18 16:55
 */
@Configuration
public class SimpleJobConfig {

    @Resource
    private ZookeeperRegistryCenter regCenter;

    @Resource
    private JobEventConfiguration jobEventConfiguration;

    @Bean
    public SimpleJob testJob(){
        return new TestJob();
    }

    /**
     * 初始化測試定時任務
     *
     * @return
     */
    @Bean(initMethod = "init")
    public JobScheduler simpleTestJobScheduler(final SimpleJob testJob) {
        return new SpringJobScheduler(testJob, regCenter, getTestJobConfiguration(), jobEventConfiguration);
    }

    /**
     * 配置測試定時任務
     *
     * @return
     */
    private LiteJobConfiguration getTestJobConfiguration() {

        return LiteJobConfiguration.newBuilder(
                new SimpleJobConfiguration(
                        JobCoreConfiguration.newBuilder(TestJob.class.getCanonicalName(), test_cron, test_total_count)
                                .shardingItemParameters(test_shardingItemParameters).description
                                ("測試定時任務").build(), TestJob.class.getCanonicalName())
        ).overwrite(true).monitorPort(9091).build();
    }


}

監控：

 編譯一下程式碼中的elastic-job下的console模組，會生成一個tar包，解壓之後會生成bin目錄，如果是windows平臺的啟動

start.bat，如果是linux，需要將start.sh的編碼轉換一下才可以執行；

效果圖如下：