XXL-JOB分布式任务调度快速入门

2024-06-12 20:28

本文主要是介绍XXL-JOB分布式任务调度快速入门,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

文章目录

  • 概念
  • 快速启动XXL-JOB调度
  • 初始化执行器项目
  • 配置执行器
  • 新增GLUE模式(Java)的任务
  • 新增BEAN模式(类形式)的任务
  • BEAN模式(方法形式)的任务
  • 参考来源

概念

XXL-JOB是一个开源的分布式任务调度平台,它是一个轻量级、易扩展的任务调度平台

快速启动XXL-JOB调度

  • 拉取XXL-JOB源码

    git clone https://gitee.com/xuxueli0323/xxl-job.git
    
  • 执行调度数据库SQL脚本
    IDEA打开调度项目,执行doc/db/tables_xxl_job.sql

  • 配置调度中心数据库连接地址
    在这里插入图片描述

  • 修改调度中心日志文件地址
    在这里插入图片描述

  • 启动并访问调度中心

    • 访问地址:http://localhost:8080/xxl-job-admin
    • 用户名:admin
    • 密码:123456
      在这里插入图片描述

初始化执行器项目

  • 初始化一个Spring Boot项目

我这里使用的 Spring Boot 版本是 2.3.6.release
在这里插入图片描述

  • 引入maven依赖
    <dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--   XXL-JOB 公共依赖   --><dependency><groupId>com.xuxueli</groupId><artifactId>xxl-job-core</artifactId><version>2.4.1</version></dependency></dependencies>
  • 配置 XXL-JOB
server.port=20200
spring.application.name=xxl-job-demo
### 调度中心部署根地址 [选填]:如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调";为空则关闭自动注册;
xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin
### 执行器通讯TOKEN [选填]:非空时启用;
xxl.job.accessToken=default_token
### 执行器AppName [选填]:执行器心跳注册分组依据;为空则关闭自动注册
xxl.job.executor.appname=my-xxl-job-executor
### 执行器注册 [选填]:优先使用该配置作为注册地址,为空时使用内嵌服务 ”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=D:\TestFiles\logs\xxl-job\jobhandler
### 执行器日志文件保存天数 [选填] : 过期日志自动清理, 限制值大于等于3时生效; 否则, 如-1, 关闭自动清理功能;
xxl.job.executor.logretentiondays=30
  • 创建XXL-JOB配置类
@Configuration
public class XxlJobConfig {private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);@Value("${xxl.job.admin.addresses}")private String adminAddresses;@Value("${xxl.job.accessToken}")private String accessToken;@Value("${xxl.job.executor.appname}")private String appname;@Value("${xxl.job.executor.address}")private String address;@Value("${xxl.job.executor.ip}")private String ip;@Value("${xxl.job.executor.port}")private int port;@Value("${xxl.job.executor.logpath}")private String logPath;@Value("${xxl.job.executor.logretentiondays}")private int logRetentionDays;@Beanpublic XxlJobSpringExecutor xxlJobExecutor() {logger.info(">>>>>>>>>>> xxl-job config init.");XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();xxlJobSpringExecutor.setAdminAddresses(adminAddresses);xxlJobSpringExecutor.setAppname(appname);xxlJobSpringExecutor.setIp(ip);xxlJobSpringExecutor.setPort(port);xxlJobSpringExecutor.setAccessToken(accessToken);xxlJobSpringExecutor.setLogPath(logPath);xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);return xxlJobSpringExecutor;}
}
  • 启动项目

配置执行器

在这里插入图片描述

新增GLUE模式(Java)的任务

GLUE模式(Java)运行模式的任务实际上是一段继承自IJobHandler的Java类代码,它在执行器项目中运行,它只需要在调度中心控制台创建,无需我们手动编写任务代码

  • 创建GLUE模式(Java)的任务
    在这里插入图片描述
    在这里插入图片描述

  • 手动执行任务
    在这里插入图片描述
    在这里插入图片描述

  • 查看执行结果
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述

实际上,当我们创建了一个GLUE模式(Java)的任务后,调度中心会帮我们自动生成任务代码,代码可以在GLUE IDE查看
在这里插入图片描述
在这里插入图片描述

新增BEAN模式(类形式)的任务

创建BEAN模式(类形式)的任务需要我们在执行器项目中自行编写任务代码

  • 创建一个Job类
public class MyXxlJob extends IJobHandler {@Overridepublic void execute() throws Exception {XxlJobHelper.log("hello class xxl-job");}
}
  • 在XXL-JOB配置类中将Job注入到执行器容器
    @PostConstructpublic void registerJob() {XxlJobExecutor.registJobHandler("MyXxlJob", new MyXxlJob());}
  • 创建BEAN模式(类形式)的任务
    在这里插入图片描述
  • 执行任务并查看执行结果
    与前面GLUE模式(Java)任务的操作类似

BEAN模式(方法形式)的任务

在BEAN模式(类形式)下,每个类代表一个任务,而在BEAN模式(方法形式)下,每个方法代表一个任务,只需要在方法上用@XxlJob注解标识即可

  • 创建一个Job类并编写一个Job方法
@Component
public class MyMethodXxlJob {@XxlJob("MyMethodXxlJob")public void sayHello() {XxlJobHelper.log("hello method xxl-job");}
}
  • 创建BEAN模式(方法形式)的任务
    在这里插入图片描述

  • 执行任务并查看执行结果
    与前面GLUE模式(Java)任务的操作类似

参考来源

  • XXL-JOB官网

这篇关于XXL-JOB分布式任务调度快速入门的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1055249

相关文章

从入门到精通详解Python虚拟环境完全指南

《从入门到精通详解Python虚拟环境完全指南》Python虚拟环境是一个独立的Python运行环境,它允许你为不同的项目创建隔离的Python环境,下面小编就来和大家详细介绍一下吧... 目录什么是python虚拟环境一、使用venv创建和管理虚拟环境1.1 创建虚拟环境1.2 激活虚拟环境1.3 验证虚

SpringBoot集成XXL-JOB实现任务管理全流程

《SpringBoot集成XXL-JOB实现任务管理全流程》XXL-JOB是一款轻量级分布式任务调度平台,功能丰富、界面简洁、易于扩展,本文介绍如何通过SpringBoot项目,使用RestTempl... 目录一、前言二、项目结构简述三、Maven 依赖四、Controller 代码详解五、Service

Redis实现分布式锁全过程

《Redis实现分布式锁全过程》文章介绍Redis实现分布式锁的方法,包括使用SETNX和EXPIRE命令确保互斥性与防死锁,Redisson客户端提供的便捷接口,以及Redlock算法通过多节点共识... 目录Redis实现分布式锁1. 分布式锁的基本原理2. 使用 Redis 实现分布式锁2.1 获取锁

解决Nginx启动报错Job for nginx.service failed because the control process exited with error code问题

《解决Nginx启动报错Jobfornginx.servicefailedbecausethecontrolprocessexitedwitherrorcode问题》Nginx启... 目录一、报错如下二、解决原因三、解决方式总结一、报错如下Job for nginx.service failed bec

Python多线程实现大文件快速下载的代码实现

《Python多线程实现大文件快速下载的代码实现》在互联网时代,文件下载是日常操作之一,尤其是大文件,然而,网络条件不稳定或带宽有限时,下载速度会变得很慢,本文将介绍如何使用Python实现多线程下载... 目录引言一、多线程下载原理二、python实现多线程下载代码说明:三、实战案例四、注意事项五、总结引

C#使用Spire.XLS快速生成多表格Excel文件

《C#使用Spire.XLS快速生成多表格Excel文件》在日常开发中,我们经常需要将业务数据导出为结构清晰的Excel文件,本文将手把手教你使用Spire.XLS这个强大的.NET组件,只需几行C#... 目录一、Spire.XLS核心优势清单1.1 性能碾压:从3秒到0.5秒的质变1.2 批量操作的优雅

Java List 使用举例(从入门到精通)

《JavaList使用举例(从入门到精通)》本文系统讲解JavaList,涵盖基础概念、核心特性、常用实现(如ArrayList、LinkedList)及性能对比,介绍创建、操作、遍历方法,结合实... 目录一、List 基础概念1.1 什么是 List?1.2 List 的核心特性1.3 List 家族成

Redis分布式锁中Redission底层实现方式

《Redis分布式锁中Redission底层实现方式》Redission基于Redis原子操作和Lua脚本实现分布式锁,通过SETNX命令、看门狗续期、可重入机制及异常处理,确保锁的可靠性和一致性,是... 目录Redis分布式锁中Redission底层实现一、Redission分布式锁的基本使用二、Red

redis和redission分布式锁原理及区别说明

《redis和redission分布式锁原理及区别说明》文章对比了synchronized、乐观锁、Redis分布式锁及Redission锁的原理与区别,指出在集群环境下synchronized失效,... 目录Redis和redission分布式锁原理及区别1、有的同伴想到了synchronized关键字

Mybatis-Plus 3.5.12 分页拦截器消失的问题及快速解决方法

《Mybatis-Plus3.5.12分页拦截器消失的问题及快速解决方法》作为Java开发者,我们都爱用Mybatis-Plus简化CRUD操作,尤其是它的分页功能,几行代码就能搞定复杂的分页查询... 目录一、问题场景:分页拦截器突然 “失踪”二、问题根源:依赖拆分惹的祸三、解决办法:添加扩展依赖四、分页