分布式定时任务调度框架

一、前言

在开发中会有定时任务的场景需要用到定时任务，如订单超时需要自动取消订单、数据需定时备份、定时短信邮件的发送等，如此涉及到几个概念：

任务：业务逻辑的实现，如定时生日短信发送
调度器：根据配置（cron表达式）来告知执行器去执行任务
执行器：任务执行的载体

二、springBoot中的实现

1、代码实现

@Configuration
@EnableScheduling//标识这个类是定时任务类
@EnableAsync//定义这个类可以用异步线程
public class MyTask{
  @Scheduled(cron = "* * * * * ?")//cron可以分为6个参数或者7个参数【秒、分、时、天、月、周、年】
  @Async//定义该方法用异步
  publicvoid task(){}
}

其中我们查看timer的源码可以发现，timer内部加了同步锁，同一个timer默认是单线程的定时任务，如果任务持续时间较长，就会将后续定时任务拖延，导致丢失任务。

2、spring中定时任务存在的问题

不支持集群部署：比如你启动三个实例，每个实例都会去触发执行器去执行“优惠券要过期给用户发送一个提醒”这个任务，这时候就产生了重复执行的问题。
通常是单机部署的，单机就存在挂掉的风险。
不支持失败重试:出现异常后任务终结，不能根据执行状态，控制任务重新执行
不支持动态管理：不重启任务情况下，关闭和启动任务，修改cron表达式等。
无报警：任务失败后不能发送报警通知
不支持分片任务

三、XXL-JOB简要介绍

地址：https://gitee.com/xuxueli0323/xxl-job/、https://github.com/xuxueli/xxl-job

XXL-JOB是一个轻量级分布式任务调度平台，其实现原理是：调度中心会配置 cron表达式，路由策略，处理类的bean实例，执行器需要向调度中心发生心跳，对于长时间没有收到心跳的执行器，调度中心会将其剔除
其中在高可用过程中xxl-job-admin是通过xxl_job_qrtz_locks表来竞争数据库锁保证多个调度中心分发任务只分发一次

image.png

以下是xxl-job的架构图

image.png

四、PowerJob简要介绍

地址：https://github.com/KFCFans/PowerJob

架构图

五、定时任务调度框架的对比

image.png

六、公司目前的技术选型是XXL-JOB，故用XXL-JOB用来开发实践

1、先把git上的文件clone下来，运行doc目录下的tables_xxl_job.sql

image.png

2、启动admin

修改admin中的配置文件，改成自己本地的信息

3、启动"执行器"

xxl-job-executor-sample-springboot/src/main/resources/application.properties配置说明


### 调度中心部署跟地址 [选填]：如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调"；为空则关闭自动注册；
xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin

### 执行器AppName [选填]：执行器心跳注册分组依据；为空则关闭自动注册
xxl.job.executor.appname=xxl-job-executor-sample

### 执行器IP [选填]：默认为空表示自动获取IP，多网卡时可手动设置指定IP，该IP不会绑定Host仅作为通讯实用；地址信息用于 "执行器注册" 和 "调度中心请求并触发任务"；
xxl.job.executor.ip=

### 执行器端口号 [选填]：小于等于0则自动获取；默认端口为9999，单机部署多个执行器时，注意要配置不同执行器端口；
xxl.job.executor.port=9999

### 执行器通讯TOKEN [选填]：非空时启用；(注意与调度中心保持一致)
xxl.job.accessToken=

### 执行器运行日志文件存储磁盘路径 [选填] ：需要对该路径拥有读写权限；为空则使用默认路径；
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler

### 执行器日志保存天数 [选填] ：值大于3时生效，启用执行器Log文件定期清理功能，否则不生效；
xxl.job.executor.logretentiondays=-1

真是开箱即用，操作简单

参考官网地址：https://www.xuxueli.com/xxl-job/#%E4%BA%8C%E3%80%81%E5%BF%AB%E9%80%9F%E5%85%A5%E9%97%A8

最后编辑于：2020.12.18 08:56:33