xxl-job原理（版本2.3.1）

news2024/10/5 18:30:33

一、xxl-job架构图

$[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-M46gacso-1673794844088)(sources\xxl-job2.1.0架构图.png)]$

$[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-joy0armp-1673794844090)(sources\xxl-job2.3.0架构图1.png)]$

1、调度中心

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

2、执行器

负责接收调度请求并执行任务逻辑。任务模块专注于任务的执行等操作，开发和维护更加简单和高效；
接收“调度中心”的执行请求、终止请求和日志请求等。

二、执行器注册流程

$[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ztIQWzhY-1673794844092)(sources\注册流程.png)]$

1、调度中心注册（注册/删除）异步处理

线程池配置：2核心线程数，最大线程数10，任务队列2000，活跃时间30s，执行+日志的拒绝策略。

2、注册数据处理流程

三、调度中心触发任务

$[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-VEi5BikU-1673794844094)(sources\job触发接收流程图.png)]$

1、任务触发快慢线程池设计

快线程池配置：10核心线程数，最大线程数至少200，任务队列1000

慢线程池配置：10核心线程数，最大线程数至少100，任务队列2000

2、job降级逻辑

job超时次数超过500ms为超时，一分钟内任务超时次数超过10次（不包含10），运行触发任务有快线程池fastTriggerPool降级为慢线程池slowTriggerPool

3、触发启动加排他锁

为什么要控制？因为触发中心是集群部署，每个实例都会执行触发任务。需要控制在某一时刻只有一个实例在触发任务。

4、时间轮

在这里插入图片描述

ringData， Map<秒数, List>

//存数
int ringSecond = (int)((jobInfo.getTriggerNextTime()/1000)%60);
 ringItemData.add(jobId);
//取数
int nowSecond = Calendar.getInstance().get(Calendar.SECOND);  
for (int i = 0; i < 2; i++) {
   List<Integer> tmpData = ringData.remove( (nowSecond+60-i)%60 );
         if (tmpData != null) {
                ringItemData.addAll(tmpData);
         }
}

job超时统计

long minTim_now = System.currentTimeMillis()/60000;
if (minTim != minTim_now) {
    minTim = minTim_now;
    jobTimeoutCountMap.clear();
}

5、触发job预读5s数据

$[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-duCJW759-1673794844095)(sources\预读5s数据.jpg)]$

预读数量计算：（快线程大小 + 慢线程池大小） * 20 默认：（200 + 100）* 20 = 6000

预读时间：5秒。运行中的Job

6、ringData读取逻辑

下一秒开始 TimeUnit.MILLISECONDS.sleep(1000 - System.currentTimeMillis() % 1000);

获取当前秒和过去1秒的任务。ringData删除掉已经触发的任务。

$[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-M67KyUBK-1673794844096)(sources\ringData.png)]$

7、添加触发任务流程

$[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-HyTUYHKA-1673794844098)(sources\添加任务触发流程图.png)]$

1、快慢线程池设计，降级处理，防止正常触发的任务被慢job阻塞。

2、ConcurrentMap存储超时次数，在多线程场景下的使用。

3、job超时统计数据保存时效逻辑

  long minTim_now = System.currentTimeMillis()/60000;
                    if (minTim != minTim_now) {
                        minTim = minTim_now;
                        jobTimeoutCountMap.clear();
                    }