首页 > 其他分享 >分布式任务调度(00)-xxlJob综述

分布式任务调度(00)-xxlJob综述

时间:2023-11-02 20:05:00浏览次数:31  
标签:执行器 执行 00 xxlJob 请求 调度 JobHandler 任务 任务调度

1 配置属性

1.1 执行器

任务的绑定的执行器:

  • 任务触发调度时,将自动发现注册成功的执行器,实现任务自动发现
  • 也方便进行任务分组

每个任务须绑定一个执行器, 可在 "执行器管理" 设置。

1.2 任务描述

便于任务管理

1.3 路由策略

当执行器集群部署时,提供的路由策略

  • FIRST(第一个):固定选择第一个机器
  • LAST(最后一个):固定选择最后一个机器
  • ROUND(轮询):
  • RANDOM(随机):随机选择在线的机器;
  • CONSISTENT_HASH(一致性HASH):每个任务按照Hash算法固定选择某一台机器,且所有任务均匀散列在不同机器上。
  • LEAST_FREQUENTLY_USED(最不经常使用):使用频率最低的机器优先被选举
  • LEAST_RECENTLY_USED(最近最久未使用):最久未使用的机器优先被选举
  • FAILOVER(故障转移):按照顺序依次进行心跳检测,第一个心跳检测成功的机器选定为目标执行器并发起调度
  • BUSYOVER(忙碌转移):按照顺序依次进行空闲检测,第一个空闲检测成功的机器选定为目标执行器并发起调度
  • SHARDING_BROADCAST(分片广播):广播触发对应集群中所有机器执行一次任务,同时系统自动传递分片参数;可根据分片参数开发分片任务;

1.4 Cron

触发任务执行的Cron表达式。

2 运行模式

2.1 BEAN模式

任务以JobHandler方式维护在执行器端;需要结合 "JobHandler" 属性匹配执行器中任务;

2.2 GLUE模式(Java)

任务以源码方式维护在调度中心;该模式的任务实际上是一段继承自IJobHandler的Java类代码并 "groovy" 源码方式维护,它在执行器项目中运行,可使用@Resource/@Autowire注入执行器里中的其他服务;

2.3 JobHandler

运行模式为 "BEAN模式" 时生效,对应执行器中新开发的JobHandler类“@JobHandler”注解自定义的value值;

3 阻塞处理策略

调度过于密集执行器来不及处理时的处理策略; 单机串行(默认):调度请求进入单机执行器后,调度请求进入FIFO队列并以串行方式运行; 丢弃后续调度:调度请求进入单机执行器后,发现执行器存在运行的调度任务,本次请求将会被丢弃并标记为失败; 覆盖之前调度:调度请求进入单机执行器后,发现执行器存在运行的调度任务,将会终止运行中的调度任务并清空队列,然后运行本地调度任务;

  • 子任务:每个任务都拥有一个唯一的任务ID(任务ID可以从任务列表获取),当本任务执行结束并且执行成功时,将会触发子任务ID所对应的任务的一次主动调度。
  • 任务超时时间:支持自定义任务超时时间,任务运行超时将会主动中断任务;
  • 失败重试次数;支持自定义任务失败重试次数,当任务失败时将会按照预设的失败重试次数主动进行重试;
  • 报警邮件:任务调度失败时邮件通知的邮箱地址,支持配置多邮箱地址,配置多个邮箱地址时用逗号分隔;
  • 负责人:任务的负责人;
  • 执行参数:任务执行所需的参数;

4 架构设计

4.1 设计思想

  • 调度行为抽象形成“调度中心”公共平台,平台自身并不承担业务逻辑,“调度中心”只负责发起调度请求
  • 任务抽象成分散的JobHandler,交由“执行器”统一管理,“执行器”负责接收调度请求,并执行对应JobHandler的业务逻辑

因此,“调度”、“任务”两部分可解耦,提高系统整体稳定性和扩展性。

4.2 系统组成

调度模块(调度中心)

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

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

接收调度请求并执行任务逻辑:

  • 任务模块专注任务执行,开发维护更简单高效
  • 接收“调度中心”的执行请求、终止请求和日志请求

标签:执行器,执行,00,xxlJob,请求,调度,JobHandler,任务,任务调度
From: https://blog.51cto.com/JavaEdge/8154068

相关文章

  • (C语言)1到50的阶乘之和列表,参考用,洛谷:P1009 [NOIP1998 普及组] 阶乘之和
    1到50列表,阶乘之和S=1!+2!+3!+⋯+n!(n≤50)1::12::33::94::335::1536::8737::59138::462339::40911310::403791311::4395471312::52295631313::674997711314::9392826831315::140160263631316::2232439252431317::37801182062031318::678038552634831319::12842......
  • Jtti:香港服务器促销70% off,100M带宽@不限流$ 99.3/月,免费20G DDoS防御
    Jtti:香港服务器促销70%off,100M带宽@不限流$ 99.3/月,免费20GDDoS防御 Jtti针对香港服务器发布了特价促销,70%off,每月仅需$ 99.3,具体配置为XeonE5-2660、500GSSD、16GB内存、100M大带宽@不限流,免费20G防御,可以安装Linux或者Windows操作系统。除了香港服务器以外,新加坡和美国机......
  • 4793: 虫食算 noip2004提高组T4 深搜/剪枝
    #include<bits/stdc++.h>usingnamespacestd;typedeflonglongll;constintN=1e3+10,inf=0x3f3f3f3f;charA[N],B[N],C[N];charwords[N];intcnt;charkeys[N];boolvis[N];intn;voidprint(){for(inti=0;i<n-1;i++)pri......
  • 题解:[SCOI2008] 城堡
    应该是联赛前最后一次任性了,浪费的时间有点多,不过也揭露了我的基础知识和代码能力都很弱的问题,得加油啊。先stodwt。给定一棵基环树森林,起初有\(m\)个点已被选进\(S\)里,你需要再选\(k\)个点加入到\(S\)中,最小化其余点到\(S\)距离的最大值。这个问题直接做非常困难,......
  • acwing300任务安排1对“费用提前计算”的解释
    我们考查对任意一种方案答案的构成假设最终方案只有这三段那么很显然,答案为$$(S+sumT_[i])\cdotsumC_{i}+(2S+sumT_[j])\cdot(sumC_{j}-sumC_{i})+(3S+sumT_[n])\cdot(sumC_{n}-sumC_{j})$$我们换一种写法,答案为$$sumT_{i}\cdotsumC_{i}+sumT_{j}\cdot(sumC_{j}-sumC_{i}......
  • 洛谷 P2290 [HNOI2004] 树的计数(Prufer序列,Cayley 公式)
    传送门解题思路关于Prufer序列的构造,见OI-wiki这里直接放结论:一个Prufer序列与一个无根树一一对应度数为\(d_i\)的节点在序列中出现了\(d_i-1\)次\(\sum(d_i-1)=n-2\)n个点的完全图的生成树有\(n^{n-2}\)种所以相当于n-2个数(有重复的)进行全排列,答案即为:\[\frac......
  • NOIP2003 传染病控制 深搜/剪枝
    思路题目大意是:把一棵树按深度分层,每一层断掉一条边,是剩下的节点数最小。其实,我们可以将问题转换为断掉的节点数最多。首先,贪心不可行,很容易被卡。因为数据只有300,直接搜索就行。搜索时一层一层搜,枚举断掉哪条边,并标记后代。#include<bits/stdc++.h>usingnamespacestd;......
  • 聊城企业申请ISO9001体系认证的步骤是什么
    聊城企业申请ISO9001体系认证的步骤是什么恒标知产刘经理申请ISO9001质量管理体系认证有5个程序,具体步骤如下:一、申请人提交一份正式的应由其代表签署的申请书。申请书或其附件应包括:1)申请方简况,如组织的性质、名称、地址、法律地位、以及有关人力和技术资源。2)申请认证的覆盖的产......
  • app支付金额为100,但是前端却显示50,这种情况是怎么回事呢?该如何处理?
    app支付金额为100,但是前端却显示50,这种情况是怎么回事呢?该如何处理?1、可能是服务端没有正常响应返回数据导致的问题--前端发起请求到服务端后没有正常响应返回响应数据,导致回显金额跟实际支付金额不一致;2、可能是前端展示的问题--前端正常请求了,服务端也正常响应返回数据了,包括......
  • Linux【CPU100% 问题定位】
    一、场景     在我们项目部署上线的时候,我们是不是会经常去Linux服务器上查查服务器的CPU使用率,或者是运维经常会盯Linux的CPU使用率。如果CPU使用率一直100%,如何查找并解决问题?二、步骤    2.1、定位到进程        使用top和ps分析工具报告......