xxl-Job基础配置
介绍:
XXL-JOB是一个轻量级分布式任务调度平台,其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线,开箱即用。
几个特性:
简单:支持通过Web页面对任务进行CRUD操作,操作简单,一分钟上手;
2、动态:支持动态修改任务状态、启动/停止任务,以及终止运行中任务,即时生效
3、注册中心: 执行器会周期性自动注册任务, 调度中心将会自动发现注册的任务并触发执行,每30秒清理一次注册表中的无效机器。同时,也支持手动录入执行器地址;
4 、失败处理策略:每10秒检测失败任务,报警和重试;
5、一致性:“调度中心”通过DB锁保证集群分布式调度的一致性, 一次任务调度只会触发一次执行
简单的job配置以及代码编写:
①.编写一个定时任务对象
在类上加上注解@JobHandler(value = “这个相当于这个定时任务的code唯一标识”)
该类要继承IJobHandler接口,实现execute()方法进行重写
在execute方法肿编写你需要处理的业务代码请求即可!
加上@Component注解在容器启动的时候将这个类注入到容器中
②去job的web页面配置任务参数
1.配置执行器
1.AppName是在服务的配置文件自定义的任务调度名称,要跟配置文件定义的名称一致地址才能映射上
2.Name自定义名称,排序默认1即可
3.注册方式选择手动注册,机器地址的话就需要重启之后任务调度中心根据你定义的AppName去服务配置文件映射 找到名称一样的服务地址
配置文件里面的任务调度配置要开启:enable=true,创建好执行器之后重启服务就可自动映射上去啦!
2.任务管理配置
选择对应的绑定的执行器,然后新建任务
1.路由策略:
-
策略 参数值 详细含义 第一个 FIRST 固定选择第一个机器 最后一个 LAST 固定选择最后一个机器 轮询 ROUND 依次选择执行 随机 RANDOM 随机选择在线的机器 一致性HASH CONSISTENT_HASH 每个人物按照Hash算法固定选择某一台机器,且所有任务均匀散列在不同机器上 最不经常使用 LEAST_FREQUENTLY_USED 使用频率最低的机器优先被选择 最近最久未使用 LEAST_RECENTLY_USED 最久未使用的机器优先被选择 故障转义 FAILOVER 按照顺序依次进行心跳检测,第一个心跳检测成功的机器选定为目标执行器并发起调度 忙碌转义 BUSYOVER 按照顺序依次进行空闲检测,第一个空闲检测成功的机器选定位目标执行器并发起调度 分片广播 SHARDING_BROADCAST 广播触发对应集群中所有机器执行一次任务,同事系统自动传递分片参数,可根据分片参数开发分片任务
2.任务描述:
自定义描述内容
3.Cron表达式:
这个参数表示你要多久,什么时候去调用这个任务,调用时间可根据需求自定义
4.JobHandler:
这个参数就是代码里面定义的任务唯一标识
5.任务参数:
传递给后台代码的参数值
6.子任务ID:
当有任务需要相互依赖时使用,比如在对账业务里,下载对账文件任务成功之后,才开始对账。那么,可以把这几个任务当成一个大任务来串行处理,即在一个任务的末尾触发另一个任务。
如果我们需要在本任务执行结束并且执行成功的时候触发另外一个任务,那么就可以把另外的任务作为本任务的子任务运行,就只需要在本任务里填入另外一个任务的jobId即可(可以在任务列表查看JobId)
7.阻塞处理策略:
策略 | 参数值 | 含义 |
---|---|---|
单机串行,默认 | SERIAL_EXECUTION | 调度请求进入单机执行器后,调度请求进入FIFO队列并以串行方式运行 |
丢弃后续调度 | DISCARD_LATER | 调度请求进入单机执行器后,发现执行器存在运行的调度任务,本次请求将会被丢弃并标记为失败 |
覆盖之前调度 | COVER_EARLY | 调度请求进入单机执行器后,发现执行器存在运行的调度任务,将会终止运行中的调度任务并清空队列,然后运行本次调度任务 |
可以手动调用任务进行执行:执行成功之后查看日志!!!
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341