# elastic-job-spring-boot-starter

**Repository Path**: eaco/elastic-job-spring-boot-starter

## Basic Information

- **Project Name**: elastic-job-spring-boot-starter
- **Description**: Spring boot 使用Elastic-job
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2018-07-30
- **Last Updated**: 2020-12-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# elastic-job-spring-boot-starter

参考自：https://github.com/yinjihuan/elastic-job-spring-boot-starter
若有侵权请联系我删除。

###解决spring-boot2.0+版本的配置参数问题

        配置文件前缀使用elastic-job开头    
        ``
        elastic-job.zk.serverLists=127.0.0.1:2181
        elastic-job.zk.namespace=yi-job
        ``

###支持两种方式配置任务：

####配置文件方式：
application.properties

    elastic-job.MySimpleJob2.cron = 0/10 * * * * ?
    elastic-job.MySimpleJob2.shardingItemParameters = 0=0,1=1,2=2
    elastic-job.MySimpleJob2description = 简单任务
    elastic-job.MySimpleJob2.shardingTotalCount = 3
    elastic-job.MySimpleJob2.overwrite = true

MySimpleJob2.java
    
    /**
     * @author: yiz
     * @date: 2018/7/30 13:58
     **/
    @ElasticJobConf(name = "MySimpleJob2")
    public class MySimpleJob2 implements SimpleJob {
    
        public void execute(ShardingContext context) {
            String shardParamter = context.getShardingParameter();
            System.out.println("分片参数：" + shardParamter);
            int value = Integer.parseInt(shardParamter);
            for (int i = 0; i < 1; i++) {
                if (i % 2 == value) {
                    String time = new SimpleDateFormat("HH:mm:ss").format(new Date());
                    System.out.println(time + ":开始执行简单任务2:" + i+"--shard="+value);
                }
            }
        }
    }
    
    
####注解方式配置

MySimpleJob.java

    
    /**
     * @author: yiz
     * @date: 2018/7/30 13:58
     **/
    @ElasticJobConf(name = "MySimpleJob", cron = "0/10 * * * * ?",
            shardingItemParameters = "0=0,1=1,2=2", description = "简单任务",shardingTotalCount = 3,overwrite = true)
    public class MySimpleJob implements SimpleJob {
    
        public void execute(ShardingContext context) {
            String shardParamter = context.getShardingParameter();
            System.out.println("分片参数：" + shardParamter);
            int value = Integer.parseInt(shardParamter);
            for (int i = 0; i < 1; i++) {
                if (i % 2 == value) {
                    String time = new SimpleDateFormat("HH:mm:ss").format(new Date());
                    System.out.println(time + ":开始执行简单任务1:" + i+"--shard="+value);
                }
            }
        }
    }