3千字带你搞懂XXL-JOB任务调度平台(经典)

深藏阁楼爱情的钟 2023-09-24 18:17 55阅读 0赞

思维导图

![53bab6fdf44dccc226b6a2e3e550cfda.jpeg][]

文章已收录Github精选，欢迎Star：https://github.com/yehongzhi/learningSummary

一、概述

在平时的业务场景中，经常有一些场景需要使用定时任务，比如：

时间驱动的场景：某个时间点发送优惠券，发送短信等等。批量处理数据：批量统计上个月的账单，统计上个月销售数据等等。固定频率的场景：每隔5分钟需要执行一次。所以定时任务在平时开发中并不少见，而且对于现在快速消费的时代，每天都需要发送各种推送，消息都需要依赖定时任务去完成，应用非常广泛。

二、为什么需要任务调度平台

在Java中，传统的定时任务实现方案，比如Timer，Quartz等都或多或少存在一些问题：

不支持集群、不支持统计、没有管理平台、没有失败报警、没有监控等等而且在现在分布式的架构中，有一些场景需要分布式任务调度：

同一个服务多个实例的任务存在互斥时，需要统一的调度。任务调度需要支持高可用、监控、故障告警。需要统一管理和追踪各个服务节点任务调度的结果，需要记录保存任务属性信息等。显然传统的定时任务已经不满足现在的分布式架构，所以需要一个分布式任务调度平台，目前比较主流的是elasticjob和xxl-job。

elasticjob由当当网开源，目前github有6.5k的Star，使用的公司在官网登记有76家。

![c5bfce997200a29c24dabae6623b80a1.jpeg][]

跟xxl-job不同的是，

elasticjob是采用zookeeper实现分布式协调

，实现任务高可用以及分片。

![a12a71859faa23b65ad4f13519272909.jpeg][]

三、为什么选择XXL-JOB

实际上更多公司选择xxl-job，目前xxl-job的github上有15.7k个star，登记公司有348个。毫无疑问elasticjob和xxl-job都是非常优秀的技术框架，接下来我们进一步对比讨论，探索一下为什么更多公司会选择xxl-job。

首先先介绍一下xxl-job，这是出自大众点评许雪里(xxl就是作者名字的拼音首字母)的开源项目，官网上介绍这是一个轻量级分布式任务调度框架，其核心设计目标是开发迅速、学习简单、轻量级、易扩展。跟elasticjob不同，xxl-job环境依赖于mysql，不用ZooKeeper，这也是最大的不同。

elasticjob的初衷是为了面对高并发复杂的业务，即使是在业务量大，服务器多的时候也能做好任务调度，尽可能的利用服务器的资源。使用ZooKeeper使其具有高可用、一致性的，而且还具有良好的扩展性。官网上写

elasticjob是无中心化的，通过ZooKeeper的选举机制选举出主服务器，如果主服务器挂了，会重新选举新的主服务器。因此elasticjob具有良好的扩展性和可用性，但是使用和运维有一定的复杂

。

![bb0582b653a7686cb75e39dae1033d88.jpeg][]

xxl-job则相反，是通过一个中心式的调度平台，调度多个执行器执行任务，调度中心通过DB锁保证集群分布式调度的一致性，这样扩展执行器会增大DB的压力，但是如果实际上这里数据库只是负责任务的调度执行。但是如果没有大量的执行器的话和任务的情况，是不会造成数据库压力的。实际上大部分公司任务数，执行器并不多(虽然面试经常会问一些高并发的问题)。

相对来说，xxl-job中心式的调度平台轻量级，开箱即用，操作简易，上手快，与SpringBoot有非常好的集成，而且监控界面就集成在调度中心，界面又简洁，对于企业维护起来成本不高，还有失败的邮件告警等等。这就使很多企业选择xxl-job做调度平台。

四、安装

4.1 拉取源码

搭建xxl-job很简单，有docker拉取镜像部署和源码编译两种方式，docker部署的方式比较简单，我就讲源码编译的方式。首先到github拉取xxl-job源码到本地。

![5bd736f877515b120ec4510f5353bb08.jpeg][]

4.2 导入IDEA

拉取源码下来后，可以看到项目结构，如下：

![ac27a4eb6d34c9ee0f06c44de0222d52.jpeg][]

导入到IDEA，配置一下Maven，下载相关的jar包，稍等一下后，就可以看到这样的项目：

![6aa4113b0c3689eb230a4c93be939c4e.jpeg][]

4.3 初始化数据库

前面讲过xxl-job需要依赖mysql，所以需要初始化数据库，在xxl-jobdocdb路径下找到tables\_xxl\_job.sql文件。在mysql上运行sql文件。

![e055e3cb470b58f64e8870730131d696.jpeg][]

4.4 配置文件

接着就改一下配置文件，在admin项目下找到application.properties文件。

\#\#\# 调度中心JDBC链接spring.datasource.url=jdbc:mysql://127.0.0.1:3306/xxl\_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghaispring.datasource.username=rootspring.datasource.password=spring.datasource.driver-class-name=com.mysql.jdbc.Driver\#\#\# 报警邮箱spring.mail.host=smtp.qq.comspring.mail.port=25spring.mail.username=xxx@qq.comspring.mail.password=xxxspring.mail.properties.mail.smtp.auth=truespring.mail.properties.mail.smtp.starttls.enable=truespring.mail.properties.mail.smtp.starttls.required=truespring.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=200xxl.job.triggerpool.slow.max=100\#\#\# 调度中心日志表数据保存天数 \[必填\]：过期日志自动清理；限制大于等于7时生效，否则, 如-1，关闭自动清理功能；xxl.job.logretentiondays=10

4.5 编译运行

简单一点直接跑admin项目的main方法启动也行。

![568f18600dfceff2c1462a3f7f594774.jpeg][]

如果部署在服务器呢，那我们需要打包成jar包，在IDEA利用Maven插件打包。

![a506322ad0b2614978d6077ad9a23c38.jpeg][]

然后在xxl-jobxxl-job-admintarget路径下，找到jar包。

![a26bc7156893ce5fd9defd95206ffa81.jpeg][]

然后就得到jar包了，使用java-jar命令就可以启动了。

![79af86f57131c42de5d64e3bc328ef3e.jpeg][]

到这里就已经完成了！打开浏览器，输入

http://localhost:8080/xxl-job-admin

进入管理页面。默认账号/密码：admin/123456。

![b16c23d9e21f85fb7931d166a8abc96a.jpeg][]

五、永远的HelloWord

部署了调度中心之后，需要往调度中心注册执行器，添加调度任务。接下来就参考xxl-job写一个简单的例子。

首先创建一个SpringBoot项目，名字叫"xxljob-demo"，添加依赖。

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>com.xuxueli</groupId><artifactId>xxl-job-core</artifactId><version>2.2.0</version></dependency></dependencies>

接着修改application.properties。

\# web portserver.port=8081\# log configlogging.config=classpath:logback.xmlspring.application.name=xxljob-demo\#\#\# 调度中心部署跟地址 \[选填\]：如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调"；为空则关闭自动注册；xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin\#\#\# 执行器通讯TOKEN \[选填\]：非空时启用；xxl.job.accessToken=\#\#\# 执行器AppName \[选填\]：执行器心跳注册分组依据；为空则关闭自动注册xxl.job.executor.appname=xxl-job-demo\#\#\# 执行器注册 \[选填\]：优先使用该配置作为注册地址，为空时使用内嵌服务 ”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=10

接着写一个配置类XxlJobConfig。

@ConfigurationpublicclassXxlJobConfig\{ 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\}") privateint port; @Value("$\{xxl.job.executor.logpath\}") private String logPath; @Value("$\{xxl.job.executor.logretentiondays\}") privateint logRetentionDays; @Beanpublic XxlJobSpringExecutor xxlJobExecutor()\{ logger.info(">>>>>>>>>>> xxl-job config init."); XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor(); xxlJobSpringExecutor.setAdminAddresses(adminAddresses); xxlJobSpringExecutor.setAppname(appname); xxlJobSpringExecutor.setAddress(address); xxlJobSpringExecutor.setIp(ip); xxlJobSpringExecutor.setPort(port); xxlJobSpringExecutor.setAccessToken(accessToken); xxlJobSpringExecutor.setLogPath(logPath); xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays); return xxlJobSpringExecutor; \}\}

接着编写一个任务类XxlJobDemoHandler，使用Bean模式。

@ComponentpublicclassXxlJobDemoHandler\{ /\*\* \* Bean模式，一个方法为一个任务 \* 1、在Spring Bean实例中，开发Job方法，方式格式要求为 "public ReturnT<String> execute(String param)" \* 2、为Job方法添加注解 "@XxlJob(value="自定义jobhandler名称", init = "JobHandler初始化方法", destroy = "JobHandler销毁方法")"，注解value值对应的是调度中心新建任务的JobHandler属性的值。 \* 3、执行日志：需要通过 "XxlJobLogger.log" 打印执行日志； \*/@XxlJob("demoJobHandler") public ReturnT<String> demoJobHandler(String param)throws Exception \{ XxlJobLogger.log("java, Hello World~~~"); XxlJobLogger.log("param:" + param); return ReturnT.SUCCESS; \}\}

在resources目录下，添加logback.xml文件。

<?xml version="1.0" encoding="UTF-8"?><configurationdebug="false"scan="true"scanPeriod="1 seconds"><contextName>logback</contextName><propertyname="log.path"value="/data/applogs/xxl-job/xxl-job-executor-sample-springboot.log"/><appendername="console"class="ch.qos.logback.core.ConsoleAppender"><encoder><pattern>%d\{HH:mm:ss.SSS\} %contextName \[%thread\] %-5level %logger\{36\} - %msg%n</pattern></encoder></appender><appendername="file"class="ch.qos.logback.core.rolling.RollingFileAppender"><file>$\{log.path\}</file><rollingPolicyclass="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"><fileNamePattern>$\{log.path\}.%d\{yyyy-MM-dd\}.zip</fileNamePattern></rollingPolicy><encoder><pattern>%date %level \[%thread\] %logger\{36\} \[%file : %line\] %msg%n </pattern></encoder></appender><rootlevel="info"><appender-refref="console"/><appender-refref="file"/></root></configuration>

写完之后启动服务，然后可以打开管理界面，找到执行器管理，添加执行器。

![0c602f47c71a3f5280c896a376c6432f.jpeg][]

接着到任务管理，添加任务。

![e11dc55bfb17b9e016dcd8796b0fbe82.jpeg][]

![c7714c2521cebc1bf15a37ecf203b2de.jpeg][]

最后我们可以到任务管理去测试一下，运行demoJobHandler。

![d57db861504e446c608708fab63b1875.jpeg][]

![59bebc08be473ef4ea9edeb8e950312c.jpeg][]

点击保存后，会立即执行。点击查看日志，可以看到任务执行的历史日志记录。

![194728ba8fee5cf16db90b2608adeee8.jpeg][]

打开刚刚执行的执行日志，我们可以看到，运行成功。

![4cdbceefd1a1512ff32e04ebae9a77ad.jpeg][]

这就是简单的Demo演示，非常简单，上手也快。

六、谈谈架构设计

下面简单地说一下xxl-job的架构，我们先看官网提供的一张架构图来分析。

![762e0270dc316d6f23148657bc79d719.jpeg][]

从架构图可以看出，分别有调度中心和执行器两大组成部分

调度中心。负责管理调度信息，按照调度配置发出调度请求，自身不承担业务代码。支持可视化界面，可以在调度中心对任务进行新增，更新，删除，会实时生效。支持监控调度结果，查看执行日志，查看调度任务统计报表，任务失败告警等等。执行器。负责接收调度请求，执行调度任务的业务逻辑。执行器启动后需要注册到调度中心。接收调度中心的发出的执行请求，终止请求，日志请求等等。接下来我们看一下xxl-job的工作原理。

![ee2540c2a9f559c688f613b6d3e7b460.jpeg][]

任务执行器根据配置的调度中心的地址，自动注册到调度中心。达到任务触发条件，调度中心下发任务。执行器基于线程池执行任务，并把执行结果放入内存队列中、把执行日志写入日志文件中。执行器的回调线程消费内存队列中的执行结果，主动上报给调度中心。当用户在调度中心查看任务日志，调度中心请求任务执行器，任务执行器读取任务日志文件并返回日志详情。絮叨

看完以上的内容，基本算入门了。实际上，xxl-job还有很多功能，要深入学习，还需要到官网去研究探索。最好就是自己在本地搭建一个xxl-job来玩玩，动手实践是学得最快的学习方式。

[53bab6fdf44dccc226b6a2e3e550cfda.jpeg]: https://img-blog.csdnimg.cn/img_convert/53bab6fdf44dccc226b6a2e3e550cfda.jpeg
[c5bfce997200a29c24dabae6623b80a1.jpeg]: https://img-blog.csdnimg.cn/img_convert/c5bfce997200a29c24dabae6623b80a1.jpeg
[a12a71859faa23b65ad4f13519272909.jpeg]: https://img-blog.csdnimg.cn/img_convert/a12a71859faa23b65ad4f13519272909.jpeg
[bb0582b653a7686cb75e39dae1033d88.jpeg]: https://img-blog.csdnimg.cn/img_convert/bb0582b653a7686cb75e39dae1033d88.jpeg
[5bd736f877515b120ec4510f5353bb08.jpeg]: https://img-blog.csdnimg.cn/img_convert/5bd736f877515b120ec4510f5353bb08.jpeg
[ac27a4eb6d34c9ee0f06c44de0222d52.jpeg]: https://img-blog.csdnimg.cn/img_convert/ac27a4eb6d34c9ee0f06c44de0222d52.jpeg
[6aa4113b0c3689eb230a4c93be939c4e.jpeg]: https://img-blog.csdnimg.cn/img_convert/6aa4113b0c3689eb230a4c93be939c4e.jpeg
[e055e3cb470b58f64e8870730131d696.jpeg]: https://img-blog.csdnimg.cn/img_convert/e055e3cb470b58f64e8870730131d696.jpeg
[568f18600dfceff2c1462a3f7f594774.jpeg]: https://img-blog.csdnimg.cn/img_convert/568f18600dfceff2c1462a3f7f594774.jpeg
[a506322ad0b2614978d6077ad9a23c38.jpeg]: https://img-blog.csdnimg.cn/img_convert/a506322ad0b2614978d6077ad9a23c38.jpeg
[a26bc7156893ce5fd9defd95206ffa81.jpeg]: https://img-blog.csdnimg.cn/img_convert/a26bc7156893ce5fd9defd95206ffa81.jpeg
[79af86f57131c42de5d64e3bc328ef3e.jpeg]: https://img-blog.csdnimg.cn/img_convert/79af86f57131c42de5d64e3bc328ef3e.jpeg
[b16c23d9e21f85fb7931d166a8abc96a.jpeg]: https://img-blog.csdnimg.cn/img_convert/b16c23d9e21f85fb7931d166a8abc96a.jpeg
[0c602f47c71a3f5280c896a376c6432f.jpeg]: https://img-blog.csdnimg.cn/img_convert/0c602f47c71a3f5280c896a376c6432f.jpeg
[e11dc55bfb17b9e016dcd8796b0fbe82.jpeg]: https://img-blog.csdnimg.cn/img_convert/e11dc55bfb17b9e016dcd8796b0fbe82.jpeg
[c7714c2521cebc1bf15a37ecf203b2de.jpeg]: https://img-blog.csdnimg.cn/img_convert/c7714c2521cebc1bf15a37ecf203b2de.jpeg
[d57db861504e446c608708fab63b1875.jpeg]: https://img-blog.csdnimg.cn/img_convert/d57db861504e446c608708fab63b1875.jpeg
[59bebc08be473ef4ea9edeb8e950312c.jpeg]: https://img-blog.csdnimg.cn/img_convert/59bebc08be473ef4ea9edeb8e950312c.jpeg
[194728ba8fee5cf16db90b2608adeee8.jpeg]: https://img-blog.csdnimg.cn/img_convert/194728ba8fee5cf16db90b2608adeee8.jpeg
[4cdbceefd1a1512ff32e04ebae9a77ad.jpeg]: https://img-blog.csdnimg.cn/img_convert/4cdbceefd1a1512ff32e04ebae9a77ad.jpeg
[762e0270dc316d6f23148657bc79d719.jpeg]: https://img-blog.csdnimg.cn/img_convert/762e0270dc316d6f23148657bc79d719.jpeg
[ee2540c2a9f559c688f613b6d3e7b460.jpeg]: https://img-blog.csdnimg.cn/img_convert/ee2540c2a9f559c688f613b6d3e7b460.jpeg