当前位置：文档之家 › 定时任务__@Xxl-JOB的使用

定时任务__@Xxl-JOB的使用

  • 格式：pdf
  • 大小：1.11 MB
  • 文档页数：11

定时任务__@Xxl-JOB的使⽤

概述xxl-job框架

⾸先我们要知道什么是XXL-JOB？

官⽅简介：XXL-JOB是⼀个分布式任务调度平台，其核⼼设计⽬标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接⼊多家公司线上产品线，开箱即⽤

XXL-JOB的有点特性：

1、简单：⽀持通过Web页⾯对任务进⾏CRUD操作，操作简单，⼀分钟上⼿；

2、动态：⽀持动态修改任务状态、启动/停⽌任务，以及终⽌运⾏中任务，即时⽣效； 3、调度中⼼HA（中⼼式）：调度采⽤中⼼式设计，“调度中⼼”⾃研调度组件并⽀持集群部署，可保证调度中⼼HA； 4、执⾏器HA（分布式）：任务分布式执⾏，任务"执⾏器"⽀持集群部署，可保证任务执⾏HA； 5、注册中⼼: 执⾏器会周期性⾃动注册任务, 调度中⼼将会⾃动发现注册的任务并触发执⾏。同时，也⽀持⼿动录⼊执⾏器地址； 6、弹性扩容缩容：⼀旦有新执⾏器机器上线或者下线，下次调度时将会重新分配任务； 7、路由策略：执⾏器集群部署时提供丰富的路由策略，包括：第⼀个、最后⼀个、轮询、随机、⼀致性HASH、最不经常使⽤、最近最久未使⽤、故障转移、忙碌转移等； 8、故障转移：任务路由策略选择"故障转移"情况下，如果执⾏器集群中某⼀台机器故障，将会⾃动Failover切换到⼀台正常的执⾏器发送调度请求。 9、阻塞处理策略：调度过于密集执⾏器来不及处理时的处理策略，策略包括：单机串⾏（默认）、丢弃后续调度、覆盖之前调度； 10、任务超时控制：⽀持⾃定义任务超时时间，任务运⾏超时将会主动中断任务； 11、任务失败重试：⽀持⾃定义任务失败重试次数，当任务失败时将会按照预设的失败重试次数主动进⾏重试；其中分⽚任务⽀持分⽚粒度的失败重试； 12、任务失败告警；默认提供邮件⽅式失败告警，同时预留扩展接⼝，可⽅便的扩展短信、钉钉等告警⽅式； 13、分⽚⼴播任务：执⾏器集群部署时，任务路由策略选择"分⽚⼴播"情况下，⼀次任务调度将会⼴播触发集群中所有执⾏器执⾏⼀次任务，可根据分⽚参数开发分⽚任务； 14、动态分⽚：分⽚⼴播任务以执⾏器为维度进⾏分⽚，⽀持动态扩容执⾏器集群从⽽动态增加分⽚数量，协同进⾏业务处理；在进⾏⼤数据量业务操作时可显著提升任务处理能⼒和速度。 15、事件触发：除了"Cron⽅式"和"任务依赖⽅式"触发任务执⾏之外，⽀持基于事件的触发任务⽅式。调度中⼼提供触发任务单次执⾏的API服务，可根据业务事件灵活触发

…

是⽬前主流的分布式任务调度平台，许多公司的产品业务都有XXL-JOB的接⼊

开源社区使⽤

⾸先从GitHub上⾯将项⽬clone下来，如果⽹络问题导致速度慢也可以从Gitee上⾯拉取

xxl-job架构图

（压缩之后可以在⽂件中发现他的架构图）分布式任务项⽬的简单搭建

在GitHub上获取源代码

解压、导⼊开发⼯具

修改pom.xml⽂件：

主要修改为：配置新的JDK版本:JDK8（默认为JDK7）

1.修改Admin中的pmx⽂件

2.修改xxl-job-master的pom配置⽂件

两个pom⽂件都要添加 org.apache.maven.plugins maven-source-plugin ${maven-source-plugin.version} package jar-no-fork

修改数据源

对应数据库⽂件,可以导⼊到⾃⼰的数据库中 注意:如果库中有同名的表了,需要到⽂件中注释掉创建表的步骤

在数据库中表的介绍

导⼊maven

结构相关介绍：xxl-job-admin：调度中⼼

xxl-job-core：公共依赖

xxl-job-executor…：执⾏器

⽂件中有sql⽂件，运⾏⽣成库表1. xxl_job_lock：任务调度锁表；

xxl_job_group：执⾏器信息表，维护任务执⾏器信息；xxl_job_info：调度扩展信息表： ⽤于保存XXL-JOB调度任务的扩展信息，如任务分组、任务名、机器地址、执⾏器、执⾏⼊参和报警邮件等等；xxl_job_log：调度⽇志表： ⽤于保存XXL-JOB任务调度的历史信息，如调度结果、执⾏结果、调度⼊参、调度机器和执⾏器等等；xxl_job_log_report：调度⽇志报表：⽤户存储XXL-JOB任务调度⽇志的报表，调度中⼼报表功能页⾯会⽤到；xxl_job_logglue：任务GLUE⽇志：⽤于保存GLUE更新历史，⽤于⽀持GLUE的版本回溯功能；xxl_job_registry：执⾏器注册表，维护在线的执⾏器和调度中⼼机器地址信息；xxl_job_user：系统⽤户表；

启动服务

需要启动两个服务,第⼀个是图形化界⾯的启动,⼀个是任务SpringBoot定时任务类基本同等于我们项⽬中的任务类

启动xxl-job-admin项⽬[图形化界⾯]

路径: D:\demo\xxl-job-master\xxl-job-admin\src\main\java\com\xxl\job\admin\XxlJobAdminApplication.java

启动xxl-job-executor-sample-springboot项⽬[定时任务类]

路径: D:\demo\xxl-job-master\xxl-job-executor-samples\xxl-job-executor-sample-springboot\src\main\java\com\xxl\job\executor\XxlJobExecutorApplication.java

注意：其实我们项⽬中有两个模板,启动那个都可以,只是我⽤了SpringBoot,所以就只启动了这个

启动结果

访问登录页⾯

输⼊地址就可以访问到对应的图形化界⾯了

⽹址:

默认的管理员账号:admin

密码:123456

登录成功的页⾯

⾃建分布式任务：Hello world

执⾏器主要分为两种⽅式:1. ⾃动注册2. ⼿动注册

⼿动图解[⾃动不弄,可以看视频学习]

①创建执⾏器

②创建任务

③在任务后⾯--》操作按钮--》开启任务

④查看⽇志

执⾏器注意事项

1、确认pom⽂件中引⼊了 “xxl-job-core” 的maven依赖；

2、配置⽂件：

==>: xxl.job.admin.addresses配置（调度中⼼地址：例如http://127.0.0.1:8080/xxl-job-admin）

==>: xxl.job.executor.appname配置（执⾏器AppName，可视化界⾯添加执⾏器时需要）

==>: xxl.job.executor.port配置（执⾏器端⼝号，多个执⾏器时注意端⼝号不⼀致）

3、不同版本的机器地址输⼊的格式不⼀样

例如：2.2版格式à地址:端⼝1.0版格式àIP地址:端⼝

遇到的问题

问题1：执⾏器地址为空

原因--》执⾏器中 没有地址

解决⽅案--》输⼊地址：地址：端⼝

IP地址

端⼝

问题2：异常信息unknown code for readObject at 0x3c

1.错误提⽰⽆法找到执⾏器。原因：需要启动两个项⽬ xxl-job-admin 、xxl-job-executor-samples (这⾥我⽤的是xxl-job-executor-sample-springboot)2.调度成功了，但是执⾏不会停⽌，只能⼿动停⽌，执⾏结果是失败的。或者启动时遇到以下的异常信息：unknown code for readObject at 0x3c

原因：这种提⽰的错误⼀般出在admin配置address没有配对。检查xxl-job-executor-springboot-example⾥⾯配置⽂件的xxl.job.admin.addresses=http://localhost:8080/xxl-job-admin与启动步骤2是否⼀致

完成！

合集下载

任务调度中心xxl-job对外接口使用

任务调度中心xxl-job对外接口使用

任务调度中⼼xxl-job对外接⼝使⽤

com.test

xxl-job-core

1.0-SNAPSHOT

commons-httpclient

commons-httpclient

3.1

application.yml配置信息

xxl:

job:

admin:

# xxl-job admin address list, such as "http://address" or "http://address01,http://address02"

# xxl-job-admin 启动地址

addresses: http://192.168.1.59:7000/xxl-job-admin

# xxl-job, access token

accessToken:

executor:

# xxl-job executor appname ⼿动配置的客户端名称

appname: xxl-job-executor-test

# xxl-job executor registry-address: default use address to registry , otherwise use ip:port if address is null

address:

# xxl-job executor server-info 可以⾃动分配地址进⾏注册

ip:

port: 9985

# xxl-job executor log-path

logpath: logs/applogs/xxl-job/jobhandler

# xxl-job executor log-retention-days

logretentiondays: 30

controller层代码

package com.controller;

import com.alibaba.fastjson.JSONObject;

import com.util.TimeUtil;

xxljob原理

xxljob原理

xxljob原理

xxl-job是一个分布式任务调度平台，它通过实现任务触发、任务分发、任务执行、调度分析等功能来实现分布式任务调度。它通过实现以下三步来完成任务调度：

（1）触发任务

xxl-job定义了多种任务触发方式，可以根据实际情况来选择。它支持的任务触发方式包括：手动触发、定时触发、每日循环触发、每星期循环触发、webhooks等。

（2）任务分发

xxl-job通过任务分发将任务发送到执行器上进行执行。执行器是xxl-job的运行环境，它可以是一台物理机、私有云或公有云服务器。xxl-job可以通过执行器来实现任务负载均衡。

（3）任务执行

任务分发到执行器上后，xxl-job会自动运行任务，任务运行完毕后，xxl-job会返回执行结果。如果任务未能完成，xxl-job会根据配置的重试次数来重新发送任务，直至任务运行完毕或达到最大重试次数。

SpringBoot整合Xxl-job实现定时任务的全过程

SpringBoot整合Xxl-job实现定时任务的全过程

SpringBoot整合Xxl-job实现定时任务的全过程⽬录前⾔⼀、部署调度中⼼

1、项⽬下载

2、初始化数据

3、修改properties配置⽂件

⼆、部署SpringBoot项⽬

1、引⼊依赖

2、创建配置类

3、修改配置⽂件

4、创建执⾏器

5、启动SpringBoot项⽬三、通过调度中⼼进⾏任务调度

1、添加执⾏器

2、添加任务

3、任务调度中⼼发起任务调度四、⼩结总结

前⾔

XXL-JOB是⼀个分布式任务调度平台，其核⼼设计⽬标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接⼊多家公司线上产品线，开箱即⽤。

如果是单机并且定时任务不多的情况，可以选择Timer注解@Scheduled或者Cron⼯具类等⽅式来实现，但是这有个缺点，那就是定时任务会写死在代码中，⼀旦启动，就不能暂停或者修改。如果修改的

话，整个还项⽬要重新编译，这属实⾮常的⿇烦。

本篇⽂章将会介绍如何通过xxl-job来实现任务的调度

⼀、部署调度中⼼

1、项⽬下载

下⾯是调度中⼼代码的gitee地址，可以colon到本地

/xuxueli0323/xxl-job

2、初始化数据

在下载好的项⽬中的doc/db⽬录下有⼀个tables_xxl_job.sql⽂件，先放到⾃⼰的数据库中执⾏，其实就是初始化好调度中⼼需要的表结构和数据

3、修改properties配置⽂件

⼆、部署SpringBoot项⽬

1、引⼊依赖

com.xuxueli

xxl-job-core

2.2.0

2、创建配置类

@Configuration

public class XxlJobConfig {

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

@Value("${xxl.job.admin.addresses}")

private String adminAddresses;

xxl-job介绍

xxl-job介绍

xxl-job介绍

什么是任务调度

什么是任务调度？某⼀时间段进⾏任务的操作。

具体任务调度有哪些应⽤的场景？数据同步、交易信息、清除⽤户的信息、定期发送报表数据、活动推送等。

传统实现定时任务的⽅式？Thread、TimeTask、ScheduleExecutorService、Quartz 等；不过，这⼏种⽅式都是在单点系统使⽤，⼀旦Job服务器宕机之后，就必须采取⼀些措施；具体操作如下：

(1) 使⽤⼼跳检测监控⾃动重启、任务补偿机制（任务做标记）

(2) 定时任务在执⾏代码的时候中间突然报错，使⽤⽇志记录错误，跳过继续执⾏，在使⽤定时Job 扫描⽇志错误记录，进⾏补偿信息。

(3) 定时Job 在执⾏的时候，导致整个 Job 异常结束掉，发送邮件通知给运维⼈员。

分布式定时任务的⽅式？XXL-Job、Elastic-job等。不过，既然采⽤分布式，那么肯定会遇到项⽬部署集群，导致任务重复执⾏多次；具体操作如下：

(1) Zookeeper 实现分布式锁，每次保证拿到锁再执⾏，效率⽐较低。

(2) 配置⽂件中加⼊定时任务的开关，但是只能保证⼀台服务器执⾏，变为单击服务器。

(3) 启动的时候使⽤数据库唯⼀标识；同样是效率低。

(4) 分布式调度任务平台，解决了任务幂等问题，Job 负载均衡轮询机制（推荐）。

那么现在我们来总结下，⾸先传统的定时任务，⼏乎⽆法做到⾼可⽤，再加上项⽬部署集群，会导致任务幂等性问题；此时分布式定时任务调度平台便发挥了作⽤，咱们拿 XXL-Job来进⾏说明；相关作⽤如下：

(1) ⽀持Job集群，Job 负载均衡轮询机制保证幂等性问题。

(2) ⽀持Job补偿，如果Job执⾏失败的话，会⾃动实现重试机制，超过重启次数后，会发送邮件通知运维⼈员。

(3) ⽀持Job⽇志记录。

(4) 动态配置定时规则，传统定时Job触发规则都是写死在代码中。XXL-JOB简介

开源社区：

环境：

Maven3+Jdk1.8+Mysql5.7+xxl-job执⾏原理