快速入门

1. 使用API配置启动

引入maven依赖

  1. <dependency>
  2.     <groupId>io.elasticjob</groupId>
  3.     <artifactId>elastic-job-lite-core</artifactId>
  4.     <version>${latest.release.version}</version>
  5. </dependency>

作业开发

  1. public class MyElasticJob implements SimpleJob {
  3.     @Override
  4.     public void execute(ShardingContext context) {
  5.         switch (context.getShardingItem()) {
  6.             case 0: 
  7.                 // do something by sharding item 0
  8.                 break;
  9.             case 1: 
  10.                 // do something by sharding item 1
  11.                 break;
  12.             case 2: 
  13.                 // do something by sharding item 2
  14.                 break;
  15.             // case n: ...
  16.         }
  17.     }
  18. }

作业配置

  1.     // 定义作业核心配置
  2.     JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder("demoSimpleJob", "0/15 * * * * ?", 10).build();
  3.     // 定义SIMPLE类型配置
  4.     SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, SimpleDemoJob.class.getCanonicalName());
  5.     // 定义Lite作业根配置
  6.     LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();

启动作业

  1. public class JobDemo {
  3.     public static void main(String[] args) {
  4.         new JobScheduler(createRegistryCenter(), createJobConfiguration()).init();
  5.     }
  7.     private static CoordinatorRegistryCenter createRegistryCenter() {
  8.         CoordinatorRegistryCenter regCenter = new ZookeeperRegistryCenter(new ZookeeperConfiguration("zk_host:2181", "elastic-job-demo"));
  9.         regCenter.init();
  10.         return regCenter;
  11.     }
  13.     private static LiteJobConfiguration createJobConfiguration() {
  14.         // 创建作业配置
  15.         // ...
  16.     }
  17. }

2. 使用Spring配置启动

  1. <dependency>
  2.     <groupId>io.elasticjob</groupId>
  3.     <artifactId>elastic-job-lite-spring</artifactId>
  4.     <version>${latest.release.version}</version>
  5. </dependency>

作业开发

同使用API配置中作业开发

作业配置

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.     xmlns:reg="http://www.dangdang.com/schema/ddframe/reg"
  5.     xmlns:job="http://www.dangdang.com/schema/ddframe/job"
  6.     xsi:schemaLocation="http://www.springframework.org/schema/beans
  7.                         http://www.springframework.org/schema/beans/spring-beans.xsd
  8.                         http://www.dangdang.com/schema/ddframe/reg
  9.                         http://www.dangdang.com/schema/ddframe/reg/reg.xsd
  10.                         http://www.dangdang.com/schema/ddframe/job
  11.                         http://www.dangdang.com/schema/ddframe/job/job.xsd
  12.                         ">
  13.     <!--配置作业注册中心 -->
  14.     <reg:zookeeper id="regCenter" server-lists="yourhost:2181" namespace="dd-job" base-sleep-time-milliseconds="1000" max-sleep-time-milliseconds="3000" max-retries="3" />
  16.     <!-- 配置作业-->
  17.     <job:simple id="demoSimpleSpringJob" class="xxx.MyElasticJob" registry-center-ref="regCenter" cron="0/10 * * * * ?" sharding-total-count="3" sharding-item-parameters="0=A,1=B,2=C" />
  18. </beans>

启动作业

将配置Spring命名空间的xml通过Spring启动，作业将自动加载。

详细的规则配置请参考配置手册