xxl-job 任务调度搭建及简单使用

news/2024/5/19 1:44:05 标签: xxl-job, 调度中心, 分布式, 定时api调用

  xxl-job是开源架构,可以通过它实现调度中心和执行器。 git地址和 官网中进行了详细的技术说明。
  xxl-job支持单机部署和集群式部署,在集群式部署中又可以实现调度中心集群式部署和执行器集群式部署。本文主要针对调度中心和执行器分离单机部署方式进行说明。

xxl-job任务调度搭建及简单使用

  • 简介
  • 调度中心搭建
    • 数据库创建
    • 配置文件编写
    • docker容器启动
    • 启动测试
  • 执行器搭建
    • 依赖引入
    • 配置
  • 使用说明

简介

  xxl-job中存在调度中心和执行器两个概念,其中调度中心负责定时调度,执行器负责具体的执行工作。调度中心本质上就是一个spring boot项目。在使用xxl-job时在调度中心配置调度规则及执行内容,然后再在执行器中实现具体的执行作业。
  本demo中在调度中心配置每隔一分钟执行一次,执行的具体内容为调用某个service的方法,在执行其中需要实现service的具体方法。

调度中心搭建

  调度中心的搭建可以分为四部分进行分别是:

  • 数据库创建
  • 配置文件编写
  • docker容器启动
  • 启动测试
    下面将针对上述四个过程中进行详细说明。

数据库创建

  数据库创建SQL文件可以通过git查找,位于\xxl-job-master\doc\db路径下,可以在mysql中创建一个数据库然后执行该SQL文件实现数据库表结构及基础数据的初始化。

配置文件编写

  通过查看xxl-job-admin项目的pom文件包含以下内容:

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>

  可知调度中心本质上就是一个springboot项目。其docker构建文件如下:

FROM openjdk:8-jre-slim
MAINTAINER xuxueli
ENV PARAMS=""
ENV TZ=PRC
RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo $TZ > /etc/timezone
ADD target/xxl-job-admin-*.jar /app.jar
ENTRYPOINT ["sh","-c","java -jar $JAVA_OPTS /app.jar $PARAMS"]

  可通过-e PARAMS设置docker启动命令中调度中心的执行参数。既然调度中心本质上一个spring boot程序,因此可以配置该程序运行的配置文件,即application.properties文件。根据官网指出xxl-job提供了以下特有配置内容:

### 调度中心JDBC链接:链接地址请保持和 2.1章节 所创建的调度数据库的地址一致
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=root_pwd
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
### 报警邮箱
spring.mail.host=smtp.qq.com
spring.mail.port=25
spring.mail.username=xxx@qq.com
spring.mail.password=xxx
spring.mail.properties.mail.smtp.auth=true
spring.mail.properties.mail.smtp.starttls.enable=true
spring.mail.properties.mail.smtp.starttls.required=true
spring.mail.properties.mail.smtp.socketFactory.class=javax.net.ssl.SSLSocketFactory
### 调度中心通讯TOKEN [选填]:非空时启用;
xxl.job.accessToken=
### 调度中心国际化配置 [必填]: 默认为 "zh_CN"/中文简体, 可选范围为 "zh_CN"/中文简体, "zh_TC"/中文繁体 and "en"/英文;
xxl.job.i18n=zh_CN
## 调度线程池最大线程配置【必填】
xxl.job.triggerpool.fast.max=200
xxl.job.triggerpool.slow.max=100
### 调度中心日志表数据保存天数 [必填]:过期日志自动清理;限制大于等于7时生效,否则, 如-1,关闭自动清理功能;
xxl.job.logretentiondays=30

  除此之外我们还可以进行spring boot的启动项配置,如下设置启动使用数据库连接内容:

### xxl-job, datasource
spring.datasource.url=jdbc:mysql://mysql:3306/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=password
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

docker容器启动

  在docker启动的过程中我们主要需要注意的点有以下内容:

  • 指定配置文件
  • 端口映射
  • 网络配置

  由于spring boot启动可以指定配置文件,在进行docker部署调度中心时需要配置数据库连接、token等相关内容,因此我们需要实现自己的配置文件,可以通过文件卷挂载+ -e配置变量的形式实现进行配置文件自定义。
  spring boot web项目启动的端口默认是8080,使用docker部署需要将容器内端口映射出来。
  此外,由于xxl-job-admin调度中心需要使用到数据库,因此我们需要将调度中心容器和mysql容器实现网络通信,为方便两个容器之间的通信,将MySQL容器和调度中心容器放到同一网络下,因此需要配置–net参数。
  部署命令如下:

docker run -d --net=nacos-mysql --name=xxl-job-admin -p 8081:8080 -v D:\docker\xxl-job\application.properties:/application.properties  -e PARAMS='--spring.config.location=/application.properties' xuxueli/xxl-job-admin:2.4.0

注意:需要将mysql容器也放到nacos-mysql网络下,并且创建数据库。调度中心的容器创建过程中必须指定版本号,不能使用last进行获取。

启动测试

进行管理员客户端访问。

http://localhost:8081/xxl-job-admin/
用户名:admin
密码:123456

运行界面如下:
在这里插入图片描述

执行器搭建

依赖引入

  执行器实际就是执行任务的具体程序,在实现执行器搭建的过程中需要在项目中引入:

  		<!-- xxl-job-core -->
        <dependency>
            <groupId>com.xuxueli</groupId>
            <artifactId>xxl-job-core</artifactId>
            <version>2.4.0</version>
        </dependency>
        <!-- 作为一个spring cloud项目,使用openfeign进行api调用具体的服务-->

配置

@Configuration
public class XxlJobConfig {
    @Bean
    public XxlJobSpringExecutor xxlJobExecutor() {
        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
        // 调度中心url
        xxlJobSpringExecutor.setAdminAddresses("http://127.0.0.1:8081/xxl-job-admin");
        // 执行器名称
        xxlJobSpringExecutor.setAppname("imos-job");
//        xxlJobSpringExecutor.setAddress("");
//        xxlJobSpringExecutor.setIp("192.168.1.56");
//        xxlJobSpringExecutor.setPort(7999);
		// token,该配置必须和调度中心的配置文件总的token配置一致
        xxlJobSpringExecutor.setAccessToken("default_token");
//        xxlJobSpringExecutor.setLogPath(logPath);
//        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);

        return xxlJobSpringExecutor;
    }
}

  通过以上操作及完成了执行器的搭建过程,可以将执行器理解为一个spring 项目,在里面编写我们具体的业务代码即可。
  在本demo中执行器将通过openfeign调用其他微服务的相关接口实现定时任务,因此pom文件中还需要引入其他相关依赖。
  在执行器的搭建过程中,我们发现除了引入job-core依赖配置bean之外,并没有为执行器做什么其他相关配置,执行器某个业务的定时执行是由调度中心进行配置的,执行器本身并没有定时配置,简单来讲,执行器仅给调度中心提供原料执行的作用。
  本demo的实现采用glue模式进行实现,该模式下,使用者在调度中心编写java代码,java代码中可以通过@autowire的形式引入执行器定义的service,因此可以理解为执行器为调度中心提供原料。待定时任务执行时,调度中心其实是将java代码发送给执行器,执行器接受到代码后通过反射等形式进行执行代码。

使用说明

运行调度中心

  启动调度中心docker容器,登录调度中心管理界面,并添加一个执行器,该执行器名称和我们执行器中设定的名称需要一致,注册方式选择自动注入即可:
在这里插入图片描述

运行执行器

  运行执行器后,OnLine 机器地址应该存在一组ip字段。如下图
在这里插入图片描述## 新增任务
  在调度中心中新增任务并选择glue模式,如下图
在这里插入图片描述

编写任务代码

  在任务管理列表中点击操作进入GULE模式,进行java代码编写:
在这里插入图片描述
  在编写代码的过程中可以引入执行器中存在的service或者new执行器中的对象,需要注意的是在使用执行器的类或者方法的过程中需要import相关类,类的全限定名和执行器中需要严格保持一致。

执行

  在任务管理操作进行执行任务,执行器将执行该代码并在控制台展示相关内容如下图:
在这里插入图片描述


http://www.niftyadmin.cn/n/5003062.html

相关文章

2023年7月京东投影仪行业品牌销售排行榜(京东大数据)

鲸参谋监测的京东平台7月份投影仪行业销售数据已出炉&#xff01; 7月份&#xff0c;投影仪市场呈现增长趋势。根据鲸参谋平台的数据可知&#xff0c;7月京东平台投影仪的销量将近20万&#xff0c;同比增长约16%&#xff1b;销售额将近3.8亿&#xff0c;同比增长约4%。 ​*数据…

Vue项目案例-头条新闻

目录 1.项目介绍 1.1项目功能 1.2数据接口 1.3设计思路 2.创建项目并安装依赖 2.1创建步骤 2.2工程目录结构 2.3配置文件代码 3.App主组件开发 3.1设计思路 3.2对应代码 4.共通组件开发 4.1设计思路 4.2对应代码 5.头条新闻组件开发 5.1设计思路 5.2对应代码 …

Spring——Spring IOC原理

摘要 IoC 不是一种技术&#xff0c;只是一种思想&#xff0c;一个重要的面向对象编程的法则&#xff0c;它能指导我们如何设计出松耦合、更优良的程序。传统应用程序都是由我们在类内部主动创建依赖对象&#xff0c;从而导致类与类之间高耦合&#xff0c;难于测试&#xff1b;…

C++ Opencv视频检测

使用OpenCV进行视频检测的一般步骤如下&#xff1a;导入OpenCV库和视频文件。 对每一个视频帧进行对象检测。可以使用诸如Haar特征分类器、Cascade分类器或深度学习模型等技术进行对象检测。 #include <opencv2/imgcodecs.hpp> #include <opencv2/highgui.hpp> …

批量采集的时间管理与优化

在进行大规模数据采集时&#xff0c;如何合理安排和管理爬取任务的时间成为了每个专业程序员需要面对的挑战。本文将分享一些关于批量采集中时间管理和优化方面的实用技巧&#xff0c;帮助你提升爬虫工作效率。 1. 制定明确目标并设置合适频率 首先要明确自己所需获取数据的范…

常见信号滤波方法(卡尔曼滤波、滑动平均、异常值剔除)的原理解析与C语言实现

常见信号滤波方法&#xff08;卡尔曼滤波、滑动平均、异常值剔除&#xff09;的原理解析与C语言实现 日期作者版本备注2023.09.04Dog TaoV1.0完成文档的初始版本。 文章目录 常见信号滤波方法&#xff08;卡尔曼滤波、滑动平均、异常值剔除&#xff09;的原理解析与C语言实现前…

4、QT中的网络编程

一、Linux中的网络编程 1、子网和公网的概念 子网网络&#xff1a;局域网&#xff0c;只能进行内网的通信公网网络&#xff1a;因特网&#xff0c;服务器等可以进行远程的通信 2、网络分层模型 4层模型&#xff1a;应用层、传输层、网络层、物理层 应用层&#xff1a;用户自…

我国元宇宙相关专利数居世界第二,中创元宇宙发展取得阶段性进步!

元宇宙是工业和互联网的下一次大变革方向&#xff0c;将划分出一个时代 9月2日&#xff0c;2023年中国国际服务贸易交易会&#xff08;以下简称“服贸会”&#xff09; 在京召开。 在同期举行的数字贸易发展趋势和前沿高峰论坛上&#xff0c;我国元宇宙产业生态在各方的支持下…