简介： 本文主要介绍分布式定时任务框架xxl-job，本文首先会对xxl-job做一个基本的介绍，接着将xxl-job与quartz做一个比较，最后就是介绍xxl-job调度的详细过程。

前言

本文主要介绍分布式定时任务框架xxl-job，本文首先会对xxl-job做一个基本的介绍，接着将xxl-job与quartz做一个比较，最后就是介绍xxl-job调度的详细过程。

xxl-job的介绍

xxl-job是一个开源的分布式定时任务框架，其调度中心和执行器是相互分离，分开部署的，两者通过HTTP协议进行通信。其架构如下图所示：

(资料图片仅供参考)

调度中心：

负责管理调度信息，按照调度配置发出调度请求，自身不承担业务代码。调度系统与任务解耦，提高了系统可用性和稳定性，同时调度系统性能不再受限于任务模块；

支持可视化、简单且动态的管理调度信息，包括任务新建，更新，删除，GLUE开发和任务报警等，所有上述操作都会实时生效，同时支持监控调度结果以及执行日志，支持执行器Failover，支持创建执行器等功能。

执行模块（执行器）：

负责接收调度请求并执行任务逻辑。任务模块专注于任务的执行等操作，开发和维护更加简单和高效；接收“调度中心”的执行请求、终止请求和日志请求等。

特性

xxl-job的特性有很多，官网上有详细的介绍，这里我会介绍几个重要的特性：

1.简单：支持通过Web页面对任务进行CRUD操作，操作简单，一分钟上手；

2.动态：支持动态修改任务状态、启动/停止任务，以及终止运行中的任务，都是即时生效的。

3.调度中心HA（中心式）：调度采用中心式设计，“调度中心”自研调度组件并支持集群部署，可保证调度中心HA；

4.执行器HA（分布式）：任务分布式执行，任务”执行器”支持集群部署，可保证任务执行HA；

5.调度过期策略：调度中心错过调度时间的补偿处理策略：包括：忽略，立即补偿触发一次等；

6.阻塞处理策略：调度过于密集执行器来不及处理时的处理策略，策略包括：单机串行（默认）、丢弃后续调度、覆盖之前的调用。

7.任务超时控制：支持自定义任务超时时间，任务运行超时将会主动中断任务；

xxl-job相关的数据表

xxl-job将任务信息以及日志信息持久化到数据表中，这个就保证了可以动态的添加删除任务。

1.xxl_job_lock：任务调度锁表，在线程查询任务信息时会调用上锁。

2.xxl_job_group：执行器信息表，维护任务执行器信息；

3.xxl_job_info：调度扩展信息表： 用于保存XXL-JOB调度任务的扩展信息，如任务分组、任务名、机器地址、执行器、执行入参和报警邮件等等；

4.xxl_job_log：调度日志表： 用于保存XXL-JOB任务调度的历史信息，如调度结果、执行结果、调度入参、调度机器和执行器等等；

5.xxl_job_log_report：调度日志报表：用户存储XXL-JOB任务调度日志的报表，调度中心报表功能页面会用到；

6.xxl_job_logglue：任务GLUE日志：用于保存GLUE更新历史，用于支持GLUE的版本回溯功能；

7.xxl_job_registry：执行器注册表，维护在线的执行器和调度中心机器地址信息；

8.xxl_job_user：系统用户表；

xxl-job与quartz的异同

这一部分主要是将quartz和xxl-job做一个比较，quartz是一款开源的使用非常广泛的定时任务框架。其可以说是定时任务的鼻祖，很多理念都与xxl-job类似。

综合比较

整体来说，xxl-job就是quartz的一个增强版，其弥补了quartz不支持并行调度，不支持失败处理策略和动态分片的策略等诸多不足，同时其有管理界面，上手比较容易，支持分布式，适用于分布式场景下的使用。两者相同的是都是通过数据库锁来控制任务不能重复执行。

核心类比较

quartz中的类有很多，我们关注并掌握好Schedule（调度容器），Trigger(触发器)，JobDetail&Job(定义具体的执行任务)这几个类就掌握了quartz的核心了。因为其余的类都是围绕这几个类转的，下图展示了各个核心类的调用关系：

quartz的调用示例：

public class RAMQuartz {    public static void main(String[] args) throws SchedulerException {   //1.创建Scheduler的工厂        SchedulerFactory sf = new StdSchedulerFactory();        //2.从工厂中获取调度器实例        Scheduler scheduler = sf.getScheduler();        //3.创建JobDetail        JobDetail jobDetail = JobBuilder.newJob(RAMJob.class).withDescription(\"this is a ram job\")                .withIdentity(\"ramJob\", \"ramGroup\").build();   //job的name和group        // 4.任务运行的时间，SimpleScheduler类型触发器有效,3秒后启动        long time = System.currentTimeMillis() + 3 * 1000L;        Date startTime = new Date(time);        // 5.创建Trigger        CronTrigger cronTrigger = TriggerBuilder.newTrigger().withDescription(\"\")                .withIdentity(\"ramTrigger\", \"ramTriggerGroup\")                .startAt(startTime).withSchedule(CronScheduleBuilder.cronSchedule(\"0/10 * * * * ?\")) //每10秒跑一次                .build();        // 6.注册任务和定时器        scheduler.scheduleJob(jobDetail, cronTrigger);        // 7.启动调度器        scheduler.start();        System.out.println(\"启动时间： \" + new Date()); }

点击查看原文，获取更多福利！

https://developer.aliyun.com/article/1149981?utm_content=g_1000367811

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。