当前位置: 首页 > article >正文

[特殊字符] 分布式定时任务调度实战:XXL-JOB工作原理与路由策略详解

在微服务架构中,定时任务往往面临多实例重复执行任务冲突等挑战。为了解决这一问题,企业级调度框架 XXL-JOB 提供了强大的任务统一调度与执行机制,特别适合在分布式系统中使用。

本文将从 XXL-JOB 的核心架构入手,详细讲解其调度原理,并带你了解各类路由策略的作用与应用场景。


📌 目录

  1. XXL-JOB 简介

  2. 分布式系统中的定时任务挑战

  3. XXL-JOB 的工作原理

  4. XXL-JOB 任务执行流程

  5. 常见路由策略详解

  6. 小结


一、XXL-JOB 简介

XXL-JOB 是开源的分布式任务调度平台,采用 Web 可视化操作界面,具备高可用、可扩展、易集成等特点。它能够统一调度多个微服务实例的任务,避免重复执行,是解决分布式定时任务冲突问题的利器。

官网地址:分布式任务调度平台XXL-JOB


二、分布式系统中的定时任务问题

在分布式系统中,每个微服务通常会部署多个实例,如果每个实例都运行自己的定时任务,容易导致:

  • ✅ 多实例重复执行相同任务

  • ✅ 状态不一致、数据污染

  • ✅ 难以统一管理和监控任务执行情况

为了解决上述问题,我们需要一个 统一调度中心,确保一个任务只能由一个实例执行


三、XXL-JOB 的工作原理

🎯 目标:在多实例部署环境中,确保定时任务只执行一次,且易于配置和监控

XXL-JOB 通过调度中心 + 执行器的方式实现统一管理和调度:

1. 安装调度中心(xxl-job-admin)

调度中心是核心控制平台,负责:

  • 存储任务配置(调度时间、执行器、执行策略等)

  • 定时触发任务

  • 调用具体服务端的执行器接口

  • 记录日志、任务状态

2. 在微服务中集成执行器(xxl-job-core)

执行器作为任务实际执行者,在应用启动时自动向调度中心注册。

<!-- 示例依赖 -->
<dependency><groupId>com.xuxueli</groupId><artifactId>xxl-job-core</artifactId><version>2.3.0</version>
</dependency>
@XxlJob("demoJobHandler")
public ReturnT<String> demoJobHandler(String param) throws Exception {log.info("任务开始执行,参数:{}", param);return ReturnT.SUCCESS;
}

3. 在调度中心配置任务

可配置内容包括:

  • 执行器名称

  • 执行方式(BEAN 方法、脚本等)

  • 调度周期(Cron 表达式)

  • 路由策略(轮询、随机、分片等)

  • 失败重试次数、超时时间等


四、任务执行流程图解


五、XXL-JOB 路由策略详解

路由策略决定了在一个执行器对应多个实例时,具体由哪个实例执行任务。

路由策略说明
第一个(FIRST)永远选择地址列表中的第一个执行器(不变)
轮询(ROUND)轮流让不同的执行器执行任务,保证负载均衡
随机(RANDOM)随机选择一个执行器节点,适度负载均衡
一致性HASH根据任务参数哈希定位到固定的执行器,保证相同参数始终被同一节点处理(适合有状态场景)
分片广播(SHARDING_BROADCAST)将任务拆分为 N 份,同时在所有执行器上广播执行(适合大任务拆分)

✅ 实际应用建议:

  • 轮询策略:适合大多数无状态任务,保证多节点均衡执行;

  • 一致性 Hash:适合任务依赖特定资源,如分库分表、按用户分区的任务;

  • 分片广播:适合 ETL、大数据导出等高资源任务。


六、小结

XXL-JOB 为分布式系统中的定时任务调度提供了高效、稳定的解决方案。通过集中式调度 + 多种路由策略,可以轻松应对任务重复执行、分布式任务协调难等问题。

优势回顾:

  • 可视化配置,管理简单

  • 支持多种任务执行模式与路由策略

  • 日志可查、状态可控

  • 开源免费,生态活跃


📌 如果你在微服务中还在用 @Scheduled 定时任务,强烈推荐切换到 XXL-JOB,彻底解决多实例重复调度问题!

相关文章:

[特殊字符] 分布式定时任务调度实战:XXL-JOB工作原理与路由策略详解

在微服务架构中&#xff0c;定时任务往往面临多实例重复执行、任务冲突等挑战。为了解决这一问题&#xff0c;企业级调度框架 XXL-JOB 提供了强大的任务统一调度与执行机制&#xff0c;特别适合在分布式系统中使用。 本文将从 XXL-JOB 的核心架构入手&#xff0c;详细讲解其调…...

java面试题及答案2020,java最新面试题(四十四)

java面试题及答案2020 二面-2020/3/18 1、自我介绍项目比赛 2、java集合框架全部介绍。。从list set queue到map 3、hashmap底层扩容线程安全问题 4、如果-一个对象要作为hashmap的key需要做什么 5、Threadlocal类以及 内存泄漏 6、线程同步方式,具体每一个怎么做的 7、jvm类加…...

Spring Boot 中处理 JSON 数值溢出问题:从报错到优雅解决

一、问题背景&#xff1a;为什么我的接口突然报错了&#xff1f; 假设你正在开发一个 Spring Boot 接口&#xff0c;接收类似这样的 JSON 请求&#xff1a; {"size": 111111111111111111111 }然后突然收到用户的反馈&#xff1a;请求报错啦&#xff01; 查看日志&a…...

oracle 锁的添加方式和死锁的解决

DML锁添加方式 DML 锁可由一个用户进程以显式的方式加锁&#xff0c;也可通过某些 SQL 语句隐含方式实现。 DML 锁有三种加锁方式&#xff1a;共享锁方式、独占锁方式、共享更新。 共享锁&#xff0c;独占锁用于 TM 锁&#xff0c;共享锁用于 TX 锁。 1)共享方式的表级锁 共享方…...

基于Hadoop的音乐推荐系统(源码+lw+部署文档+讲解),源码可白嫖!

摘要 本毕业生数据分析与可视化系统采用B/S架构&#xff0c;数据库是MySQL&#xff0c;网站的搭建与开发采用了先进的Java语言、爬虫技术进行编写&#xff0c;使用了Spring Boot框架。该系统从两个对象&#xff1a;由管理员和用户来对系统进行设计构建。主要功能包括&#xff…...

Java查询数据库表信息导出Word

参考: POI生成Word多级标题格式_poi设置word标题-CSDN博客 1.概述 使用jdbc查询数据库把表信息导出为word文档, 导出为word时需要下载word模板文件。 已实现数据库: KingbaseES, 实现代码: 点击跳转 2.效果图 2.1.生成word内容 所有数据库合并 数据库不合并 2.2.生成文件…...

DAY9:Oracle数据库安全管理深度解析

引言 在当今数据泄露事件频发的时代&#xff0c;数据库安全管理已成为DBA和开发者的必修课。本文将深入探讨Oracle数据库安全管理的四大核心领域&#xff1a;用户权限管理、数据库审计、透明数据加密&#xff08;TDE&#xff09;和虚拟私有数据库&#xff08;VPD&#xff09;&…...

RK3588平台用v4l工具调试USB摄像头实践(亮度,饱和度,对比度,色相等)

目录 前言:v4l-utils简介 一&#xff1a;查找当前的摄像头设备 二&#xff1a;查看当前摄像头支持的v4l2-ctl调试参数 三根据提示设置对应参数&#xff0c;在提示范围内设置 四&#xff1a;常用调试命令 五:应用内执行命令方法 前言:v4l-utils简介 v4l-utils工具是由Linu…...

Dart Flutter数据类型详解 int double String bool list Map

目录 字符串的几种方式 bool值的判断 List的定义方式 Map的定义方式 Dart判断数据类型 (is 关键词来判断类型) Dart的数据类型详解 int double String bool list Map 常用数据类型: Numbers(数值): int double Strings(字符串) String Booleans(布尔…...

LainChain技术解析:基于RAG架构的下一代语言模型增强框架

摘要 随着大语言模型(LLM)在自然语言处理领域的突破性进展,如何突破其知识时效性限制、提升事实准确性成为关键挑战。LainChain通过整合检索增强生成(RAG)技术,构建起动态知识接入框架,为LLM提供实时外部知识支持。本文从技术原理、架构设计、应用场景三个维度,深入解…...

组件是怎样写的(1):虚拟列表-VirtualList

本篇文章是《组件是怎样写的》系列文章的第一篇&#xff0c;该系列文章主要说一下各组件实现的具体逻辑&#xff0c;组件种类取自 element-plus 和 antd 组件库。 每个组件都会有 vue 和 react 两种实现方式&#xff0c;可以点击 https://hhk-png.github.io/components-show/ …...

在Linux中,使用read函数去读取写入文件空洞部分时,读取出来的内容是什么?为什么这样操作,以及应用场景?

使用 read 函数读取文件空洞&#xff08;hole&#xff09;部分时&#xff0c;读取到的内容会被系统填充为 \0&#xff08;即零字节&#xff09;。文件空洞是稀疏文件中未实际分配磁盘空间的区域&#xff0c;但逻辑上表现为连续的零字节。 1.在指定空洞部分后&#xff0c;写入数…...

Qt6笔记-对Qt6中对CMakeLists.txt的解析

首先&#xff0c;新建Qt Console Application项目。 下面对CMakeLists.txt进行次理解。新建好后&#xff0c;Qt Creator会生成CMakeLists.txt&#xff0c;具体内容如下&#xff1a; cmake_minimum_required(VERSION 3.16)project(EasyCppMain LANGUAGES CXX)set(CMAKE_AUTOUIC…...

CIFAR10图像分类学习笔记(三)---数据加载load_cifar10

新创建一个load_cifar10源文件 需要导入的包 import glob from torchvision import transforms from torch.utils.data import DataLoader ,Dataset import os #读取工具 from PIL import Image import numpy as np 01同样定义10个类别的标签名数组 label_name ["airpl…...

计算机视觉cv入门之答题卡自动批阅

前边我们已经讲解了使用cv2进行图像预处理与边缘检测等方面的知识&#xff0c;这里我们以答题卡自动批阅这一案例来实操一下。 大致思路 答题卡自动批阅的大致流程可以分为这五步&#xff1a;图像预处理-寻找考试信息区域与涂卡区域-考生信息区域OCR识别-涂卡区域填涂答案判断…...

Java学习手册:JSON 数据格式基础知识

1. JSON 简介 JSON&#xff08;JavaScript Object Notation&#xff09;是一种轻量级的数据交换格式&#xff0c;易于阅读和编写&#xff0c;也易于机器解析和生成。它最初来源于 JavaScript&#xff0c;但如今已被许多语言所采用&#xff0c;包括 Java、Python、C 等。JSON 以…...

【Python爬虫详解】第四篇:使用解析库提取网页数据——BeautifuSoup

在前一篇文章中&#xff0c;我们学习了如何编写第一个爬虫程序&#xff0c;成功获取了网页的HTML内容。然而&#xff0c;原始HTML通常包含大量我们不需要的信息&#xff0c;真正有价值的数据往往隐藏在HTML的标签和属性中。这一篇&#xff0c;我们将学习如何使用Python的解析库…...

《重塑AI应用架构》系列: Serverless与MCP融合创新,构建AI应用全新智能中枢

在人工智能飞速发展的今天&#xff0c;数据孤岛和工具碎片化问题一直是阻碍AI应用高效发展的两大难题。由于缺乏统一的标准&#xff0c;AI应用难以无缝地获取和充分利用数据价值。 为了解决这些问题&#xff0c;2024年AI领域提出了MCP&#xff08;Model Context Protocol模型上…...

深度图可视化

import cv2# 1.读取一张深度图 depth_img cv2.imread("Dataset_depth/images/train/1112_0-rgb.png", cv2.IMREAD_UNCHANGED) print(depth_img.shape) cv2.imshow("depth", depth_img) # (960, 1280) print(depth_img)# 读取一张rgb的图片做对比 input_p…...

【调优】log日志海量数据分表后查询速度调优

原始实现 使用pagehelper实现分页 // 提取开始时间的年份和月份&#xff0c;拼装成表名List<String> timeBetween getTimeBetween(condition);List<String> fullTableName getFullTableName(Constants.LOG_TABLE_NAME, timeBetween);PageHelperUtil.startPage(c…...

hive默认的建表格式

在 Hive 中创建表时&#xff0c;默认的建表语法格式如下&#xff1a; CREATE TABLE table_name (column1_type,column2_type,... ) ROW FORMAT DELIMITED FIELDS TERMINATED BY , STORED AS TEXTFILE;在这个语法中&#xff1a; CREATE TABLE table_name&#xff1a;指定要创建…...

sass 变量

基本使用 如果分配给变量的值后面添加了 !default 标志 &#xff0c;这意味着该变量如果已经赋值&#xff0c;那么它不会被重新赋值&#xff0c;但是&#xff0c;如果它尚未赋值&#xff0c;那么它会被赋予新的给定值。 如果在此之前变量已经赋值&#xff0c;那就不使用默认值…...

微软Edge浏览器字体设置

前言 时间&#xff1a;2025年4月 自2025年4月起&#xff0c;微软Edge浏览器的默认字体被微软从微软雅黑替换成了Noto Sans&#xff0c;如下图。Noto Sans字体与微软雅黑风格差不多&#xff0c;但在4K以下分辨率的显示器上较微软雅黑更模糊&#xff0c;因此低分辨率的显示器建议…...

Vue生命周期详细解析

前言 Vue.js作为当前最流行的前端框架之一&#xff0c;其生命周期钩子函数是每个Vue开发者必须掌握的核心概念。本文将全面解析Vue的生命周期&#xff0c;帮助开发者更好地理解Vue实例的创建、更新和销毁过程。 一、Vue生命周期概述 Vue实例从创建到销毁的整个过程被称为Vue…...

基于c#,wpf,ef框架,sql server数据库,音乐播放器

详细视频: 【基于c#,wpf,ef框架,sql server数据库&#xff0c;音乐播放器。-哔哩哔哩】 https://b23.tv/ZqmOKJ5...

前端项目搭建集锦:vite、vue、react、antd、vant、ts、sass、eslint、prettier、浏览器扩展,开箱即用,附带项目搭建教程

前端项目搭建集锦&#xff1a;vite、vue、react、antd、vant、ts、sass、eslint、prettier、浏览器扩展&#xff0c;开箱即用&#xff0c;附带项目搭建教程 前言&#xff1a;一、Vue项目下载快速通道二、React项目下载快速通道三、BrowserPlugins项目下载快速通道四、项目搭建教…...

【C++游戏引擎开发】第21篇:基于物理渲染(PBR)——统计学解构材质与光影

引言 宏观现象:人眼观察到的材质表面特性(如金属的高光锐利、石膏的漫反射柔和),本质上是微观结构对光线的统计平均结果。 微观真相:任何看似平整的表面在放大后都呈现崎岖的微观几何。每个微表面(Microfacet)均为完美镜面,但大量微表面以不同朝向分布时,宏观上会表…...

什么是Maven

Maven的概念 Maven是一个一键式的自动化的构建工具。Maven 是 Apache 软件基金会组织维护的一款自动化构建工具&#xff0c;专注服务于Java 平台的项目构建和依赖管理。Maven 这个单词的本意是&#xff1a;专家&#xff0c;内行。Maven 是目前最流行的自动化构建工具&#xff0…...

强化学习复习,价值函数的推导——北大pdf p41(ppt75)(动手学也有)

我们经常看到强化学习中有求汇报期望 E E E&#xff0c;转化为价值函数(value function) V V V&#xff0c;策略的状态价值函数(State-Value function) V π V_π Vπ​和动作价值函数&#xff08;action-value function&#xff09; Q π Q_π Qπ​。还有提到通过将期望将消除…...

neo4j中节点内的名称显示不全解决办法(如何让label在节点上自动换行)

因为节点过多而且想让节点中所有文字都显示出来而放大节点尺寸 从neo4j中导出png,再转成PDF来查看时&#xff0c;要看清节点里面的文字就得放大5倍才行 在网上看了很多让里面文字换行的办法都不行 然后找到一个比较靠谱的办法是在要显示的标签内加换行符 但是我的节点上显示的是…...