springboot集成elastic job

深碍√TFBOYSˉ_ 2023-01-05 12:39 143阅读 0赞

### 文章目录 ###

*   *  集成
     *   *  pom.xml添加依赖
         *  application.properties 添加
         *  配置任务
     *  其他
     *   *  @ElasticJobConf 是最核心的注解
         *  基本结构
         *  cron如何设置为可配置

## 集成 ##

### pom.xml添加依赖 ###

<dependency>
    	<groupId>com.cxytiandi</groupId>
    	<artifactId>elastic-job-spring-boot-starter</artifactId>
    	<version>1.0.0</version>
    </dependency>
    <dependency>
    	<groupId>org.apache.curator</groupId>
    	<artifactId>curator-framework</artifactId>
    	<version>2.10.0</version>
    </dependency>
    <dependency>
    	<groupId>org.apache.curator</groupId>
    	<artifactId>curator-recipes</artifactId>
    	<version>2.10.0</version>
    </dependency>

### application.properties 添加 ###

elasticJob.zk.serverLists=localhost:2181
    elasticJob.zk.namespace=user-sync

### 配置任务 ###

代码：

@Component
    @ElasticJobConf(name = "UserSyncJob",cron="0 0 0 * * ?",shardingTotalCount=5) // 每天零点执行
    public class UserSyncJob extends SimpleJob{ 
      @Override
      public void execute(ShardingContext shardingContext) { 
      	// 要执行的逻辑
      }
    }

启动项目，当满足cron定时任务时，执行execute方法。

## 其他 ##

### @ElasticJobConf 是最核心的注解 ###

@ElasticJobConf( 
    	name = "UserSyncJob",  // 任务名称
    	cron="0 0 0 * * ?",    // 定时
    	shardingTotalCount=5)  // 分为几片

### 基本结构 ###

ElasticJob 是个空接口，代码如下：
      public interface ElasticJob { 
      }
      下面有3个基本job：
      SimpleJob
        public interface SimpleJob extends ElasticJob { 
          void execute(ShardingContext var1);
        }
      ScriptJob 用的较少
      DataflowJob 用于处理数据流

### cron如何设置为可配置 ###

直接在java代码中是不行的，因为会报错。  
CronExpression ‘$\{invoiceCheckJob.cron\}’ is invalid. java.text.ParseException: Unexpected character: $

不写cron也是不行的，会提示要填cron，填""是可以的。

可以在配置中用：  
elastic.job.InvoiceCheckJob.cron=0 0 0/1 \* \* ?