快速入門Elastic-Job

0.前言

• 本案例基於springboot 1.5.9 和 Elastic-Job-Lite
• 官網地址

1.maven依賴

<dependency>
   <groupId>com.dangdang</groupId>
   <artifactId>elastic-job-lite-core</artifactId>
   <version>2.1.5</version>
</dependency>
<dependency>
   <groupId>org.apache.curator</groupId>
   <artifactId>curator-client</artifactId>
   <version>2.11.1</version>
</dependency>

2.配置類

import com.dangdang.ddframe.job.config.JobCoreConfiguration;
import com.dangdang.ddframe.job.config.simple.SimpleJobConfiguration;
import com.dangdang.ddframe.job.lite.api.JobScheduler;
import com.dangdang.ddframe.job.lite.config.LiteJobConfiguration;
import com.dangdang.ddframe.job.reg.base.CoordinatorRegistryCenter;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperConfiguration;
import com.dangdang.ddframe.job.reg.zookeeper.ZookeeperRegistryCenter; 
import org.springframework.boot.CommandLineRunner;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class ElasticJobConfig {
    private static CoordinatorRegistryCenter createRegistryCenter() {
        //多點
        //CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration("ip1:port1,ip2:port2,ip3:port3", "elastic-job-demo"));
        //單點
        CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration("127.0.0.1", "elastic-job-demo"));//(String serverLists, String namespace)
        regCenter.init();
        return regCenter;
    }
    private static LiteJobConfiguration createJobConfiguration() {
        //定義作業核心配置,這里設置總片數為 3(若要修改總片數,需要刪除 zookeeper 之前的節點,或者改變上面的 namespace 否則不會立即生效)
        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder("myJobName", "0/5 * * * * ?", 5).shardingItemParameters("0=a,1=b,2=c").build();
        //定義作業 SIMPLE 類型配置
        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, MyElasticJob.class.getCanonicalName());
        //定義作業 Lite 根配置
        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
        return simpleJobRootConfig;
    }
    @Bean
    public CommandLineRunner commandLineRunner() {//CommandLineRunner 里面的方法在應用啟動后執行 
        return (String... args) -> {
            new JobScheduler(createRegistryCenter(), createJobConfiguration()).init();
        };
    }
}

 

3.任務類

import com.dangdang.ddframe.job.api.ShardingContext;
import com.dangdang.ddframe.job.api.simple.SimpleJob;

public class MyElasticJob implements SimpleJob {

    @Override
    public void execute(ShardingContext shardingContext) {
        System.out.println("總分片數: " + shardingContext.getShardingTotalCount());
        switch (shardingContext.getShardingItem()) {
            case 0: {
                System.err.println("當前分片" + shardingContext.getShardingItem());
                break;
            }
            case 1: {
                System.err.println("當前分片" + shardingContext.getShardingItem());
                break;
            }
            case 2: {
                System.err.println("當前分片" + shardingContext.getShardingItem());
                break;
            }
            default: {
                System.out.println("MyElasticJob - default");
            }
        }
    }
}

4.測試

　　先啟動zookeeper,然后啟動應用即可

5.補充

　　可通過對數據的 id 對最大分片數進行取余,分配到各個分片上,從而以多線程的方式更快速地執行任務

6.參考

　　傳送門