【分布式任务调度】XXL-JOB执行器配置及定时任务的创建(二)

news2024/11/24 1:41:16

文章目录

  • 1. 前言
  • 2. 调度器配置
    • 2.1.依赖及配置
    • 2.2.任务实例
    • 2.3.调度中心管理配置
  • 3. 总结

1. 前言

在上一篇《XXL-JOB调度中心集群部署配置》 中,我们已经得到了一个调度中心的集群,接下来需要了解如何配置调度器及创建定时任务。
本文的主要内容包括:

  • 配置并启动调度器
  • 创建并执行定时任务

2. 调度器配置

第一次配置调度器,可以参考源码路径下的SpringBoot示例项目进行配置,也可以参考的官方文档的配置。
调度器的配置非常简单,只需要3个步骤就可以完成配置。

2.1.依赖及配置

依赖包引入执行器只需要引入XXL-JOB的core包,我们可以在当前已存在的SpringBoot服务中引入,也可以创建一个新的服务来进行引入,现在部署的调度中心版本为2.3.1,执行器也配置为相同的版本。

  • maven配置:
dependency>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-core</artifactId>
    <version>2.3.1</version>
</dependency>
  • gradle配置:
implementation 'com.xuxueli:xxl-job-core:2.3.1'

properties配置properties文件的配置,官网已经有了详细的描述:

### 调度中心部署根地址 [选填]:如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调";为空则关闭自动注册;
xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin
### 执行器通讯TOKEN [选填]:非空时启用;
xxl.job.accessToken=
### 执行器AppName [选填]:执行器心跳注册分组依据;为空则关闭自动注册
xxl.job.executor.appname=xxl-job-executor-sample
### 执行器注册 [选填]:优先使用该配置作为注册地址,为空时使用内嵌服务 ”IP:PORT“ 作为注册地址。从而更灵活的支持容器类型执行器动态IP和动态映射端口问题。
xxl.job.executor.address=
### 执行器IP [选填]:默认为空表示自动获取IP,多网卡时可手动设置指定IP,该IP不会绑定Host仅作为通讯实用;地址信息用于 "执行器注册" 和 "调度中心请求并触发任务";
xxl.job.executor.ip=
### 执行器端口号 [选填]:小于等于0则自动获取;默认端口为9999,单机部署多个执行器时,注意要配置不同执行器端口;
xxl.job.executor.port=9999
### 执行器运行日志文件存储磁盘路径 [选填] :需要对该路径拥有读写权限;为空则使用默认路径;
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
### 执行器日志文件保存天数 [选填] : 过期日志自动清理, 限制值大于等于3时生效; 否则, 如-1, 关闭自动清理功能;
xxl.job.executor.logretentiondays=30

我们可以把这个配置文件直接复制到项目中,需要注意修改下面几个位置:

# 调度中心地址修改为集群的地址
xxl.job.admin.addresses=http://ls.xxljob.cn/xxl-job-admin
# 因为调度中心配置的是default_token,此处我们保持一致
xxl.job.accessToken=huizhiyimo
# 指定执行器名称,每个服务都应该有不同的执行器名称,同一个服务的不同集群节点的执行器名称应该相同
xxl.job.executor.appname=my-simple-executor

properties的使用
properties文件配置完成后,我们需要将这些配置使用起来,在SpringBoot中可以通过@Value注解将配置文件中的值注入到字段中,然后我们就可以使用这些字段,初始化XXL-JOB的执行器对象,把这个执行器对象交给Spring托管就可以了。
代码配置可以查看xxl-job-executor-sample-springboot中的XxlJobConfig,在实际使用的时候可以直接把XxlJobConfig复制到自己的项目中去,也可以自行封装一个SpringBoot的starter包,在其他的项目中直接引入starter包进行使用,这里不再赘述。
最终,会使用XxlJobSpringExecutor生成一个Bean注册到Spring中,这个就是当前服务节点中的执行器对象,执行器对象会充当指挥官的角色,由它来调用不同的定时任务。

2.2.任务实例

我们需要注册一个Bean到Spring中,并使用@XxlJob告诉执行器哪个方法是需要进行调度的,代码如下:

@Component
public class MyJob {

    private final Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);

    @XxlJob("mySimpleJob")
    public void mySimpleJob() {
        logger.info("执行自定义任务");
    }
}

注:当前的XXL-JOB是通过Http协议来进行通信的,需要依赖Tomcat,所以在需要引入web依赖。

implementation 'org.springframework.boot:spring-boot-starter-web'

配置好后,我们就可以启动SpringBoot服务了,启动后就会往调度中心的数据库中,注册一个执行器实例。注册的数据存入到xxl_job_registry表中:
在这里插入图片描述

字段解释参考下面的执行器集群。

执行器集群执行器也是支持集群的,只需要在properties文件中,将addresses和appname配置为一样的就可以了。此外,如果是在同一台机器上启动的话,还需要修改端口xxl.job.executor.port=9999为其他的数值。
启动第二个节点之后,注册数据如下:

在这里插入图片描述

  • registry_key: 执行器节点中配置的appname,即执行器名称。
  • registry_value: 执行器节点暴露的ip和端口号。

看到这个数据,不难猜到,registry_key是让调度中心用来获取执行器所有节点的请求地址的key,获取到请求地址后,就可以请求执行器的调度接口进行任务调度了。

2.3.调度中心管理配置

创建执行器
在执行器的服务实例启动完毕之后,还需要在调度中心的后台配置对应的执行器,以及任务信息。
通过http://ls.xxljob.cn/xxl-job-admin打开管理平台,默认用户名、密码分别是admin,123456,进入执行器管理,新增如下配置:
在这里插入图片描述

关于注册方式,如果选择手动录入,需要自行将执行器的ip地址填写到文本框中。
如果选择的是自动注册,就会自动获取上面提到的xxl_job_registry表中的ip地址列表,这种方式可以动态的感知到执行器的上下线,是一种更加合适的方式。

保存完成之后,就可以在列表中看到my-simple-executor这个执行器,点击查看Online机器地址就可以看到当前执行器的注册实例的ip地址啦。
在这里插入图片描述

需要注意的是:这里的地址列表是保存在执行器表xxl_job_group中的,如果在页面创建完成之后,Online机器地址没有值,可以等待30秒左右再进行查询,因为注册完成的执行器实例,每30秒会更新一次注册信息,这里涉及到执行器实例的探活,本篇暂时不提,会在后面的原理分析中补充。

创建定时任务操作到这里之后,距离成功就只有一步之遥了,我们需要在调度中心的管理平台上,给刚刚创建的自定义执行器配置一个定时任务,关联到执行器实例中使用@XxlJob注解的方法。
在这里插入图片描述
在这里插入图片描述

配置解释可以参考官方文档中的配置属性详细说明。
简单的说,这里的配置表示每5秒钟执行一次my-simple-executor执行器实例中的mySimleJob任务。
保存后,将任务启动。
在这里插入图片描述

然后点击查询日志,可以看到,任务已经执行成功了。
在这里插入图片描述

至此,一个定时任务的配置就已经完成啦,可以按照这个配置的流程,在生产环境中的任意一个SpringBoot服务上集成定时任务。

3. 总结

本篇讲解了在有了调度中心的基础上,如何配置执行器从而达到在服务中使用定时任务的过程。

  1. 在SpringBoot项目中引入xxl-core包。
  2. 编辑properties文件,并解析到字段中,然后使用这个配置初始化执行器。
  3. 编写定时任务方法,并使用@XxlJob注解,并配置任务名称。
  4. 在调度中心管理平台中,先创建执行器配置,有了执行器之后在对应的执行器分组下创建定时任务。

启动定时任务,之后就可以查看定时任务的执行效果了。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/754596.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

MySQL的登录与退出(图文详解)

目录 一、服务的启动 1、方式1&#xff1a;使用图形界面工具启动 方式2&#xff1a;使用命令行工具启动 二、服务的停止 方式1&#xff1a;使用图形界面工具停止 方式2&#xff1a;使用命令行工具停止 二、自带客户端的登录与退出 登录方式1&#xff1a;MySQL自带客户端 …

详解 ➾【FTP服务工作原理及连接模式】

详解 ➾【FTP服务工作原理及连接模式】 &#x1f53b; 前言&#x1f53b; 一、FTP服务简介&#x1f6a5; 1.1 FTP工作原理&#x1f6a5; 1.2 匿名用户访问的产生&#x1f6a5; 1.3 FTP服务的连接模式&#x1f6a5; 1.4 几种流行的FTP服务器软件 &#x1f53b; 总结—温故知新 &…

toastr js clear 不成功的一个原因和解决办法

在系统里使用了 toastr js 即时弹出后台通知。toastr 支持先后显示多个弹出消息,这点很好。然后我又加了自定义样式,使得消息通知更好看些。 我的想法是通知消息显示一段时间后关闭;也可点击关闭按钮,关闭通知并标记已读;或者点击通知消息中的链接查看通知相关的内容,同时…

Python面向对象学习整理(一)

一、面向对象中的几点概念 1.1 什么是类&#xff1f; 类&#xff1a;用户定义的对象原型&#xff08;prototype&#xff09;&#xff0c;该原型定义了一组可描述该类任何对象的属性&#xff0c;属性是数据成员&#xff08;类变量 和 实例变量&#xff09;和方法&#xff0c;可…

(简单)剑指Offer 21. 调整数组顺序使奇数位于偶数前面 Java

记数组nums的长度为n。从先nums左侧开始遍历&#xff0c;如果遇到的是奇数&#xff0c;就表示这个元素已经调整完成&#xff0c;继续从左往右遍历&#xff0c;直到遇到一个偶数。然后从nums右侧开始遍历&#xff0c;如果遇到的是偶数&#xff0c;就表示这个元素已经调整完成了&…

arcgis拓扑检查

不能有悬挂点 不能有伪结点***路网处理很重要&#xff0c;看研究吧。 一直默认到最后。 导入要素类&#xff0c;单个 toupu2右键新建拓扑&#xff08;T&#xff09; 一般选不能有悬挂点&#xff0c;不能重叠。 一路默认 是 拉进图层可视化 线要素的话记得添加字段length&#…

Redis数据结构 — Dict

目录 Dict结构设计 — rehash rehash触发机制 Dict扩容 Dict收缩 ​编辑渐进式 rehash 哈希表优点在于&#xff0c;它能以 O(1) 的复杂度快速查询数据。为解决哈希冲突&#xff0c;Redis 采用了「链式哈希」来解决哈希冲突&#xff0c;在不扩容哈希表的前提下&#xff0c;…

直播美颜SDK与智能美妆:技术融合的未来

对于许多直播主和观众来说&#xff0c;如何在直播中呈现最佳的外貌成为了一个重要问题。为了解决这个问题&#xff0c;直播美颜SDK与智能美妆技术的融合应运而生&#xff0c;为用户带来了前所未有的美妆体验。 简单来讲&#xff0c;直播美颜SDK可以理解为计算机视觉技术和人工…

WebDAV之π-Disk派盘 + Solid Explorer

Solid Explorer 支持WebDAV方式连接π-Disk派盘。 Solid Explorer 是一款非常优秀的 Android 文件管理器&#xff0c;Material Design 设计风格&#xff0c;双栏布局&#xff0c;可拖拽操作、支持 ROOT 权限、多媒体浏览器、压缩包支持&#xff0c;Chromecast 流支持等众多功…

AdsPower 的功能到底好不好用?一文详解,真实揭露

你一定听说过AdsPower、Multilogin、dolphin、vmlogin浏览器、紫鸟、悦互联等等这些常见的指纹浏览器软件吧&#xff01;其中&#xff0c;AdsPower浏览器作为一款跨境圈里的“明星指纹浏览器”&#xff0c;号称具备许多功能&#xff0c;这就让许多跨境人对这个浏览器充满好奇&a…

jdk11缺少jre的问题解决

问题&#xff1a;升级jdk的时候文件中缺少jre&#xff0c;导致项目启动报错 jdk11不在默认用户强制安装jre&#xff0c;所以jdk包中不在包含jre文件 解决步骤1&#xff1a;进入jdk安装包的根目录&#xff0c;输入cmd 解决步骤2&#xff1a;在cmd中输入以下命令 bin\jlink.e…

Jacoco代码覆盖率为0问题排查

目录 原因解决通过IDEA的TestMe重新生成测试类eclipse生成测试类JUnit Test Suite 其它查看覆盖率覆盖catch代码 我问GPT 整jacoco有意义嘛 前几天解决了无法生成jacoco.exec执行文件问题后&#xff0c;发现编写测试类好像无效&#xff0c;代码覆盖率全为0 原因 通过eclipse直…

谈一下开放电商数据接口的存在意义

随着互联网的迅速发展&#xff0c;电子商务&#xff08;E-commerce&#xff09;已经成为了现代社会中不可或缺的一部分。人们越来越喜欢在网上购物&#xff0c;电商平台也开始成为许多商家扩大销售渠道的利器。而为了更好地满足用户需求和提升整个电商行业的效率&#xff0c;开…

《MySQL》索引

文章目录 前提知识索引定义和结构理解数据文件结构B树结构来存储数据的优势索引分类 索引操作拓展知识索引覆盖复合索引全文索引 前提知识 下面例子都以Innodb为例 数据是存储在磁盘上的&#xff0c;MySQL是一款专门管理数据的软件。既然MySQL要管理数据&#xff0c;而数据又在…

浮层展示信息位置处理

效果图 代码 <template><div><ul class"info-wrap"><liv-for"(item, index) in list":key"item.id"class"info-item"><div class"base-info"mouseenter"showDetailInfo($event, index)&qu…

【微信小程序-uniapp】CustomDialog 居中弹窗组件

1. 效果图 2. 组件完整代码 <template><uni-popup :ref="ref" type="center" @change

nginx的前端集成

对于springcloud项目&#xff0c;后端我们有很多的微服务&#xff0c;当然前端我们也可以有很多的小项目进行集成 前端项目部署思路 通过nginx来进行配置&#xff0c;功能如下 通过nginx的反向代理功能访问后台的网关资源 通过nginx的静态服务器功能访问前端静态页面 配置ng…

错过直播?快收藏详实回顾!Get「研发效能管理」7 步实践指南与案例剖析

目录 效能提升&#xff0c;无论企业规模大小&#xff0c;研发效能管理不可或缺 头部大厂 腰部厂商 中小型企业 研发效能管理 GDAI 模型&#xff0c;监管与迭代相辅相成&#xff0c;效能螺旋上升 研发效能管理 7 步走&#xff0c;明晰 6 大角色场景&#xff0c;有的放矢&a…

自动化测试面临的问题剖析

前面的文章为大家介绍了我们内部在使用的一些自动化框架&#xff0c;大家可以了解到我们使用的自动化测试框架太多。测试工程师就会面临这样的问题&#xff1a;到底应该选择哪个框架&#xff1f;应该选择哪种脚本语言&#xff1f;有什么办法能降低编写脚本的门槛&#xff1f;这…

攻防世界-Crypto-easy_ECC

题目描述&#xff1a;一道数学题 已知椭圆曲线加密Ep(a,b)参数为 p 15424654874903 a 16546484 b 4548674875 G(6478678675,5636379357093) 私钥为 k 546768 求公钥K(x,y) 1. 思路分析 这个没啥好说的&#xff0c;就是一道数学题&#xff0c;关键在于ECC算法的原…