springboot集成elastic job

文章目录

集成
- 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{@Overridepublic void execute(ShardingContext shardingContext) {// 要执行的逻辑}
}

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

其他

@ElasticJobConf 是最核心的注解

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

基本结构

ElasticJob 是个空接口，代码如下：public interface ElasticJob {}下面有3个基本job：SimpleJobpublic 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 * * ?

springboot集成elastic job相关推荐

SpringBoot集成Elasticsearch7.4 实战（一）
在网上已经有好多关于Elasticsearch的介绍,就不在翻来覆去讲一些基本概念,大家感兴趣的可以自己去找一些资料巩固下.这次只为了顾及众多首次接触Elasticsearch,案例都讲的很浅显,还有 ...
springboot集成elasticsearch6.8.23设置密码xpack连接，及遇到的None of the configured nodes are available
遇到一个 None of the configured nodes are available 的坑一.背景: 因现网扫描出来几个漏洞,目前版本使用的springboot2.1.17.RELEASE ...
SpringBoot集成Elasticseach
目录一.Elasticseach介绍 1.简单介绍 2.对比关系: 3.详细说明: 4.查出数据的解释二.SpringBoot集成Elasticseach 1.引入依赖 2.添加配置 3.创建po ...
springboot集成es7.2自定义注解创建索引
各位好,我们把之前的坑填一下,我在上上篇文章中写了springboot集成es7 的方法,并且集成了es原生客户端 High Level Rest Client, 也说明了原因, 我用的版本较高, ...
从ElasticSearch 认识到实战（SpringBoot集成ES）
ElasticSearch 认识到实战目录搜索引擎介绍 ElasticSearch知识安装使用restful风格查询ES SpringBoot配置ES SpringBoot集成使用一.搜索引 ...
Elasticsearch-Sql+Mybatis+SpringBoot集成
Elasticsearch-Sql+Mybatis+SpringBoot集成本文介绍了springboot如何集成elasticsearch-sql+mybatis rest方式使用es-sql J ...
elasticsearch集群搭建及springboot集成使用
elasticsearch集群搭建及springboot集成使用 1. ES介绍 2. 原理 2.1 核心概念 2.2 索引功能 2.3 ES特性 3. 分词器(analyzer) 4. 集群搭建 4 ...
springboot集成Elasticsearch实现各种搜索功能
springboot集成Elasticsearch各类搜索功能实现 springboot集成Elasticsearch使用completion suggest实现自动关键字补全建立学生的索引和映射: ...
ES入门学习：ElasticSearch、Kibana、ik分词器的安装、简单使用及SpringBoot集成
前言 es是采用Java语言开发,因此,想要安装运行es需要提前准备好jdk环境,关于linux配置jdk在前文linux配置jdk 本文主要介绍es的安装.kibana的安装和简单使用及ik分词器的 ...