首页 > 其他分享 >定时任务

定时任务

时间:2022-11-29 12:15:36浏览次数:38  
标签:执行器 任务 调度 job 定时 执行 xxl

定时任务框架种类:

  • While + Sleep : 通过循环加休眠的方式定时执行
  • Timer和TimerTask实现 :JDK自带的定时任务,可以实现简单的间隔执行任务(在指定时间点执行某一任务,也能定时的周期性执行),无法实现按日历去调度执行任务。
  • ScheduledExecutorService : Java并发包下,JDK1.5出现,是比较理想的定时任务实现方案。Eureka就使用的是它
  • QuartZ : 使用Quartz,它是一个异步任务调度框架,功能丰富,可以实现按日历调度,支持持久化。
  • 使用Spring Task,Spring 3.0后提供Spring Task实现任务调度,支持按日历调度,相比Quartz功能稍简单,但是在开发基本够用,支持注解编程方式。
  • SpringBoot中的Schedule : 通过@EnableScheduling+@Scheduled最实现定时任务,底层使用的是Spring Task
分布式定时任务xxl-job:
  1. 调度中心HA(中心式):调度采用中心式设计,“调度中心”基于集群Quartz实现并支持集群部署,可保证调度中心HA;执行器HA(分布式):任务分布式执行,任务"执行器"支持集群部署,可保证任务执行HA;
  2. 弹性扩容缩容:一旦有新执行器机器上线或者下线,下次调度时将会重新分配任务;
  3. 路由策略:执行器集群部署时提供丰富的路由策略,包括:第一个、最后一个、轮询、随机、一致性HASH、最不经常使用、最近最久未使用、故障转移、忙碌转移等;
  4. 故障转移:任务路由策略选择"故障转移"情况下,如果执行器集群中某一台机器故障,将会自动Failover切换到一台正常的执行器发送调度请求。
  5. 任务失败告警:默认提供邮件方式失败告警,同时预留扩展接口,可方面的扩展短信、钉钉等告警方式;

xxl-job架构设计:

1.1.设计思想

将调度行为抽象形成“调度中心”公共平台,而平台自身并不承担业务逻辑,“调度中心”负责发起调度请求。

将任务抽象成分散的JobHandler,交由“执行器”统一管理,“执行器”负责接收调度请求并执行对应的JobHandler中业务逻辑。因此,“调度”和“任务”两部分可以相互解耦,提高系统整体稳定性和扩展性;

1.2.架构设计图

xxl-job分为 调度中心和执行器两大模块

  • 调度模块(调度中心)

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

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

  • 执行模块(执行器)

负责接收调度请求并执行任务逻辑。任务模块专注于任务的执行等操作,开发和维护更加简单和高效;

接收“调度中心”的执行请求、终止请求和日志请求等。

  • 调度中心高可用

基于数据库的集群方案,数据库选用Mysql;集群分布式并发环境中进行定时任务调度时,会在各个节点会上报任务,存到数据库中,执行时会从数据库中取出触发器来执行,如果触发器的名称和执行时间相同,则只有一个节点去执行此任务。

  • 并行调度

调度采用线程池方式实现,避免单线程因阻塞而引起任务调度延迟。XXL-JOB调度模块默认采用并行机制,在多线程调度的情况下,调度模块被阻塞的几率很低,大大提高了调度系统的承载量。

XXL-JOB的不同任务之间并行调度、并行执行。XXL-JOB的单个任务,针对多个执行器是并行运行的,针对单个执行器是串行执行的。同时支持任务终止。

  • 执行器(任务)高可用

执行器如若集群部署,调度中心将会感知到在线的所有执行器,如“127.0.0.1:9997127.0.0.1:9998127.0.0.1:9999”。多个执行器可以选择“路由策略”来采用轮询,随机等方式进行多机器调度。

当任务”路由策略”选择”故障转移(FAILOVER)”时,当调度中心每次发起调度请求时,会按照顺序对执行器发出心跳检测请求,第一个检测为存活状态的执行器将会被选定并发送调度请求。调度成功后,可在日志监控界面查看“调度备注”

xxl-job使用:

源码仓库地址

  • https://github.com/xuxueli/xxl-job
  • http://gitee.com/xuxueli0323/xxl-job

数据库表结构说明:

  • 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:系统用户表;

标签:执行器,任务,调度,job,定时,执行,xxl
From: https://www.cnblogs.com/KL2016/p/16935048.html

相关文章

  • 定时清除linux内存buff/cache缓存
    1.创建脚本文件       vimclean.sh2.在文件中输入以下脚本#!/bin/bash#每两小时清除一次内存buff/cache缓存echo"开始清除缓存"sync;sync;sync#写......
  • PGL图学习之基于GNN模型新冠疫苗任务[系列九]
    PGL图学习之基于GNN模型新冠疫苗任务[系列九]项目链接:https://aistudio.baidu.com/aistudio/projectdetail/5123296?contributionType=1#加载一些需要用到的模块,设置随......
  • 网页的几种定时跳转总结
    1、html网页跳转代码在网页头部<1head>…</head>之间插入以下代码<metahttp-equiv="refresh"content="0.1;url=https://www.cnblogs.com/">其中:content="0.1为打开该页......
  • Linux中的计划任务Crontab
    目录​​目录​​​​介绍​​​​安装并检查Crontab服务​​​​入门栗子​​​Crontab的基本组成​​用户任务调度​​​crontab命令的使用及相关文件​​​​Crontab的任......
  • 用神经多任务学习实现方面提取和情感分析任务的一站式解决方案 IJCNN2018
    论文采用联合标记方案。要解决的问题:首先,评论中可能包含中性情绪,甚至没有针对目标方面的明确意见,这钟情况下,外部或预定义的情感词典的帮助是没有用的,单独的术语联合提取无......
  • 使用 Asynq 实现 Go 异步任务处理
    # 1.介绍Asynq是一个Go库,用于对任务进行排队并与工作人员异步处理它们。它的工作原理:客户端将任务放入队列服务器从队列中拉出任务并为每个任务启动一个工作......
  • Spring Scheduled 三种定时方式
    SpringSchedule配置时间的三种方式fixRate:间隔时间,会根据首次执行时间预先安排固定的时间,错过立即执行fixDelay:间隔时间,上次结束时间后多少间隔后执行cron:指定......
  • Windows RPC 计划任务(MS-TSCH协议)
    WindowsRPC计划任务(MS-TSCH协议)参考链接https://github.com/Rvn0xsy/SchtaskCreator实现目标上一篇文章实现了自己调用自己编写的rpc接口,达到了远程调用的效果。......
  • 0108-Go-定时器
    环境Time2022-08-24Go1.19前言说明参考:https://gobyexample.com/tickers目标使用Go语言的定时器。示例packagemainimport("fmt""time")fu......
  • 分布式任务调度
    宙斯是一个完整的Hadoop的作业平台从Hadoop任务的调试运行到生产任务的周期调度宙斯支持任务的整个生命周期从功能上来说,支持:HadoopMapReduce任务的调试运行Hive任务的调......