尧图网页设计 
这次我们来看一个在企业级任务调度中非常实用的开源项目——XXL-JOB。如果你正在寻找一个轻量级、易扩展、支持分布式调度的任务调度平台并且关心它的配置流程、调用中心如何搭建那么这篇文章可以直接收藏。XXL-JOB 的核心价值在于将复杂的定时任务管理变得可视化、可控制它解决了传统基于Scheduled注解或Quartz集群配置繁琐、任务日志难以追踪、失败告警不及时等痛点。本文将重点拆解 XXL-JOB 的“配置调用中心”这一核心环节。很多人部署完调度中心后对于执行器如何正确注册、任务如何被精准触发感到困惑。我们会直接从实战出发不讲空泛概念重点关注调度中心与执行器的配置要点、网络连通性、注册发现机制以及任务调度的完整链路。通过本文你将能清晰地掌握如何搭建一个可用的 XXL-JOB 环境并理解其调度背后的原理为后续的复杂任务编排打下坚实基础。1. 核心能力速览在深入配置细节前我们先通过一个表格快速了解 XXL-JOB 调度中心的核心特性与要求这有助于你判断它是否适合你的项目。能力项说明项目类型分布式任务调度平台核心组件调度中心Admin、执行器Executor调度方式基于数据库锁的集群调度支持故障转移任务类型BEAN、GLUE(Java/Shell/Python等)、HTTP、命令行等触发策略CRON 表达式、固定速率、固定延迟、手动触发、父子任务触发注册发现执行器自动注册到调度中心支持手动录入通信方式基于 HTTP 的 RESTful API依赖存储必须依赖 MySQL或兼容数据库存储任务元数据与日志部署模式支持单机与集群部署调度中心执行器可分布式部署管理界面提供完整的 Web 管理后台用于任务管理、日志查询、用户管理等适合场景微服务架构下的定时任务统一管理、分布式批处理作业、需要可视化监控与告警的任务调度从上表可以看出XXL-JOB 并非一个简单的库而是一个需要独立部署的中心化调度服务。配置调用中心的核心就是让“调度中心”和“执行器”这两个角色能够正确通信与协作。2. 适用场景与使用边界XXL-JOB 非常适合以下场景微服务任务调度在 Spring Cloud 或 Dubbo 架构中各个微服务节点上的定时任务需要集中管理、避免重复执行。可视化运维需求开发或运维人员需要通过 Web 界面便捷地增删改查任务、查看执行日志、手动触发或终止任务。任务高可用与故障转移当某个执行器节点宕机时调度中心能将任务自动路由到其他健康的执行器实例上。复杂的任务编排需要实现任务依赖父子任务、分片广播大数据处理、失败重试、超时控制等高级特性。然而它也有明确的使用边界非中心化调度不适用如果你追求的是完全去中心化、无单点故障的调度模式如基于 Raft/Paxos 共识算法的方案XXL-JOB 的中心化调度器尽管支持集群可能不是最优选。超高频实时任务不适用XXL-JOB 的任务调度周期最小单位为秒级对于毫秒级或需要极低延迟的实时任务调度其基于数据库轮询的调度方式可能产生性能瓶颈。强事务性作业不适用它主要负责任务的触发与状态跟踪任务内部的业务逻辑和数据一致性需要执行器自身保证。环境依赖必须维护一个 MySQL 数据库实例这对于一些极度轻量化的应用可能引入额外复杂度。合规与安全提醒在配置调用中心时务必确保调度中心与执行器之间的网络通信安全如使用内网、配置防火墙策略。任务脚本如 GLUE 模式的执行具有较高权限需严格审核脚本内容避免注入攻击。对于操作权限应合理配置管理后台的用户角色与权限防止未授权访问。3. 环境准备与前置条件开始配置前请确保你的环境满足以下要求。这是保证后续步骤顺利进行的基础。Java 环境调度中心和执行器都是 Java 应用。推荐安装 JDK 1.8 或更高版本。可以通过java -version命令验证。MySQL 数据库这是 XXL-JOB 的必需依赖用于存储所有配置和日志。建议使用 MySQL 5.7 或以上版本。你需要准备一个专用的数据库并拥有创建表和读写数据的权限。Maven编译需要如果你计划从源码编译打包需要安装 Maven 3.x。网络连通性这是“配置调用中心”最关键也是最容易出错的环节。必须确保调度中心所在服务器其服务端口默认 8080能被所有执行器访问。执行器所在服务器其配置的xxl.job.executor.port端口默认 9999能被调度中心访问。双向网络通畅是执行器注册和任务回调成功的生命线。源码或发布包从 XXL-JOB 的 GitHub 官方仓库 (xuxueli/xxl-job) 下载最新 Release 版本的源码或直接下载编译好的xxl-job-admin-2.x.x.jar调度中心包。4. 安装部署与启动方式我们将分别部署调度中心和执行器。调度中心是独立服务执行器通常嵌入在你的业务应用中。4.1 调度中心部署第一步初始化数据库在准备好的 MySQL 中创建数据库如xxl_job然后执行源码包/doc/db/tables_xxl_job.sql中的 SQL 脚本完成表结构初始化。第二步配置调度中心找到调度中心配置文件/xxl-job-admin/src/main/resources/application.properties源码方式或解压包中的对应文件。### 调度中心JDBC链接 spring.datasource.urljdbc:mysql://你的数据库IP:3306/xxl_job?useUnicodetruecharacterEncodingUTF-8autoReconnecttrueserverTimezoneAsia/Shanghai spring.datasource.username你的数据库用户名 spring.datasource.password你的数据库密码 spring.datasource.driver-class-namecom.mysql.cj.jdbc.Driver ### 调度中心通讯TOKEN用于和执行器通信鉴权非必填但建议设置 xxl.job.accessToken你的自定义Token ### 调度中心端口 server.port8080 ### 调度中心上下文路径 server.servlet.context-path/xxl-job-admin第三步启动调度中心源码启动进入xxl-job-admin目录执行mvn clean package打包然后运行java -jar target/xxl-job-admin-2.x.x.jar。发布包启动直接运行java -jar xxl-job-admin-2.x.x.jar。启动成功后访问http://你的调度中心IP:8080/xxl-job-admin。默认登录账号/密码admin / 123456。4.2 执行器部署以Spring Boot为例执行器需要集成到你的业务项目中。首先在pom.xml中添加依赖。dependency groupIdcom.xuxueli/groupId artifactIdxxl-job-core/artifactId version2.4.0/version !-- 请使用与调度中心匹配的版本 -- /dependency然后在application.yml或application.properties中进行关键配置。# 执行器配置 xxl: job: admin: addresses: http://你的调度中心IP:8080/xxl-job-admin # 调度中心地址多个用逗号分隔 accessToken: 你的自定义Token # 与调度中心配置的accessToken一致若无则留空 executor: appname: your-app-executor # 执行器AppName是调度中心识别执行器的关键 address: # 执行器地址默认为空表示自动获取IP ip: # 执行器IP默认为空表示自动获取 port: 9999 # 执行器端口号需确保未被占用且调度中心可访问 logpath: ./logs/xxl-job/jobhandler # 任务日志文件存储路径 logretentiondays: 30 # 日志保存天数最后创建一个配置类XxlJobConfig。import com.xxl.job.core.executor.impl.XxlJobSpringExecutor; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; Configuration public class XxlJobConfig { private Logger logger LoggerFactory.getLogger(XxlJobConfig.class); Value(${xxl.job.admin.addresses}) private String adminAddresses; Value(${xxl.job.accessToken}) private String accessToken; Value(${xxl.job.executor.appname}) private String appname; Value(${xxl.job.executor.address}) private String address; Value(${xxl.job.executor.ip}) private String ip; Value(${xxl.job.executor.port}) private int port; Value(${xxl.job.executor.logpath}) private String logPath; Value(${xxl.job.executor.logretentiondays}) private int logRetentionDays; Bean public XxlJobSpringExecutor xxlJobExecutor() { logger.info( xxl-job config init.); XxlJobSpringExecutor xxlJobSpringExecutor new XxlJobSpringExecutor(); xxlJobSpringExecutor.setAdminAddresses(adminAddresses); xxlJobSpringExecutor.setAppname(appname); xxlJobSpringExecutor.setAddress(address); xxlJobSpringExecutor.setIp(ip); xxlJobSpringExecutor.setPort(port); xxlJobSpringExecutor.setAccessToken(accessToken); xxlJobSpringExecutor.setLogPath(logPath); xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays); return xxlJobSpringExecutor; } }启动你的业务应用执行器将尝试向配置的调度中心地址注册。5. 功能测试与效果验证配置完成后我们需要在调度中心 Web 界面进行一系列操作验证“调用中心”是否真正配置成功。5.1 验证执行器自动注册登录调度中心访问http://你的调度中心IP:8080/xxl-job-admin。进入“执行器管理”在左侧菜单找到“执行器管理”。查看自动注册列表如果你的网络和配置正确你应该能在列表里看到一个 AppName 为your-app-executor即你在执行器配置中设置的appname的执行器其注册方式为“自动注册”下面会列出该执行器的 IP 和端口例如192.168.1.100:9999。成功标志执行器状态正常地址信息完整。失败排查如果列表为空99% 的原因是网络不通或配置错误。请跳至第8章“常见问题”部分排查。5.2 创建并测试一个简单任务进入“任务管理”点击左侧“任务管理”然后点击“新增”。填写任务信息执行器选择刚才注册成功的your-app-executor。任务描述填写“测试任务”。路由策略选择“第一个”或“轮询”。Cron填写0/30 * * * * ?表示每30秒执行一次。运行模式选择 “BEAN”。JobHandler填写一个名称如demoJobHandler。这个名称需要与执行器中的代码对应。在执行器项目中编写任务处理器 在你的 Spring Boot 业务代码中创建一个 Bean 模式的任务处理器。import com.xxl.job.core.handler.annotation.XxlJob; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; Component public class DemoJobHandler { private static Logger logger LoggerFactory.getLogger(DemoJobHandler.class); XxlJob(demoJobHandler) // 注解中的value必须与调度中心配置的JobHandler一致 public void demoJobHandler() throws Exception { logger.info(XXL-JOB, Hello World.); // 这里编写你的业务逻辑 for (int i 0; i 5; i) { logger.info(beat at: i); Thread.sleep(1000); } } }启动与观察在调度中心任务列表找到你刚创建的任务点击操作栏的“启动”。等待约30秒一个调度周期查看“操作”栏下的“调度日志”。点击“调度日志”进入查看该次执行的“执行日志”。成功标志在“执行日志”中能看到你代码中打印的“XXL-JOB, Hello World.”和“beat at:x”等信息且任务状态为“成功”。失败排查如果状态为“失败”点击“执行日志”查看详细报错常见原因是 JobHandler 名称不匹配、执行器网络回调失败等。5.3 测试手动触发与终止手动触发一次在任务列表点击“执行一次”。立即查看调度日志确认任务被触发并执行成功。这常用于测试任务逻辑是否正确。手动终止创建一个长时间运行的任务例如在处理器中Thread.sleep(60000)。在任务启动后迅速点击“终止任务”。观察调度日志状态应变为“失败”日志中应有“手动终止”的相关记录。这验证了调度中心对执行器任务的管控能力。6. 接口 API 与批量任务XXL-JOB 调度中心本身提供了完善的 Web 操作界面。但在自动化运维或与其他系统集成时我们可能需要通过其内置的 API 来操作。6.1 调度中心 RESTful API 调用XXL-JOB 调度中心的后台操作大部分都有对应的 API。API 调用需要携带登录后获得的 Cookie 或使用 Token 进行鉴权取决于版本和配置。以下是一个使用curl命令手动触发任务的示例需先登录获取 Cookie# 1. 登录获取Cookie这里演示基础认证实际可能需处理更复杂的Session # 注意此方法仅为示例生产环境建议使用更稳定的Token方式或SDK。 curl -c cookies.txt -X POST http://你的调度中心IP:8080/xxl-job-admin/login \ -H Content-Type: application/x-www-form-urlencoded \ -d userNameadminpassword123456 # 2. 使用保存的Cookie调用“执行一次”接口 # 任务IDjobId需要在调度中心任务列表页面查看 curl -b cookies.txt -X POST http://你的调度中心IP:8080/xxl-job-admin/jobinfo/trigger \ -H Content-Type: application/x-www-form-urlencoded \ -d id你的任务ID对于更规范的集成建议查阅官方文档的 API 部分或直接在前端页面通过浏览器开发者工具的“网络”选项卡观察对应操作发出的请求进行模仿。6.2 批量任务处理模式XXL-JOB 本身不直接提供“上传文件批量创建任务”的功能。但可以通过以下模式实现批量任务处理分片广播任务这是 XXL-JOB 处理批量数据的核心模式。你只需要定义一个任务一个 JobHandler。当这个任务被触发时调度中心会向所有注册的执行器实例广播该任务。同时每个执行器会收到分片参数分片索引和总分片数。在执行器代码中你可以根据分片参数来处理数据的不同分区。XxlJob(shardingJobHandler) public void shardingJobHandler() throws Exception { // 获取分片参数 int shardIndex XxlJobHelper.getShardIndex(); int shardTotal XxlJobHelper.getShardTotal(); logger.info(分片参数当前分片序号 {}, 总分片数 {}, shardIndex, shardTotal); // 根据 shardIndex 和 shardTotal 从数据库或文件中获取属于本分片的数据进行处理 ListData myDataPartition fetchDataByShard(shardIndex, shardTotal); for (Data data : myDataPartition) { process(data); } }父子任务依赖你可以创建一个“父任务”其处理器逻辑不处理具体业务而是通过调用调度中心 API如上面所述动态触发多个“子任务”。这适合有严格顺序或依赖关系的批量作业。外部脚本驱动在调度中心创建多个 GLUEShell/Python模式的任务。编写一个外部控制脚本通过调用调度中心 API按需批量触发这些 GLUE 任务。7. 资源占用与性能观察XXL-JOB 作为任务调度中间件其资源消耗主要来自调度中心、执行器以及共用的 MySQL 数据库。调度中心资源占用CPU/内存调度中心本身是一个 Spring Boot 应用内存占用通常在 512MB - 1GB 左右CPU 消耗较低。其核心线程会周期性扫描数据库中的任务表计算下次触发时间。当任务数量极大如数万、调度非常频繁秒级时扫描数据库的压力会增大需关注数据库 CPU 和连接数。数据库连接确保 MySQLmax_connections配置足够调度中心会持有数据库连接进行任务调度和日志记录。执行器资源占用执行器作为客户端资源消耗主要取决于你编写的任务处理器JobHandler的业务逻辑。XXL-JOB 框架本身只增加少量的内存和线程开销。需要关注的是执行器的线程池。XXL-JOB 执行器使用内置线程池来运行任务避免任务阻塞。如果任务都是 IO 密集型或执行时间很长可能需要调整执行器的线程池参数在XxlJobConfig中可通过XxlJobSpringExecutor的setExecutorThreadPool等方法配置。网络 I/O 观察调度中心与执行器之间通过 HTTP 进行心跳注册、任务触发和结果回调。使用netstat或资源监视器观察相关端口的连接状态和流量。不稳定的网络会导致执行器频繁掉线、任务触发失败或回调超时。日志磁盘占用调度日志和执行日志默认存储在数据库中xxl_job_log表长期运行后该表会变得非常大可能影响调度性能。务必在调度中心配置“日志报告保留天数”并定期清理过期日志或考虑将日志迁移到其他存储。执行器的运行日志业务代码打的 log存储在配置的logpath目录也需定期清理或配置日志滚动策略。性能调优建议对于任务量大的场景可以将调度中心集群部署并配合 Nginx 进行负载均衡。数据库层面可以考虑读写分离将日志表放在单独的实例上。合理设置任务的 Cron 表达式避免大量任务在同一秒触发造成调度峰值。对于执行时间短但频繁的任务可以适当调小执行器的线程池核心线程数对于执行时间长的任务需调大最大线程数并设置合理的队列容量。8. 常见问题与排查方法配置调用中心时90%的问题集中在网络和配置上。下表列出了典型问题及排查思路。问题现象可能原因排查方式解决方案执行器列表为空未自动注册1. 网络不通。2. 执行器配置的admin.addresses错误。3. 调度中心未启动或端口不对。4. 执行器应用启动失败。1. 在执行器机器用telnet或curl测试调度中心地址端口。2. 检查执行器启动日志看是否有连接调度中心的错误。3. 登录调度中心数据库查看xxl_job_registry表是否有数据。1. 打通网络关闭防火墙或配置安全组规则。2. 核对xxl.job.admin.addresses配置确保是http://ip:port/xxl-job-admin。3. 重启调度中心确认端口监听。任务触发后调度日志显示“失败”1. 执行器宕机或网络瞬时不通。2. JobHandler 名称不匹配。3. 执行器线程池已满任务被拒绝。4. 任务执行超时。1. 查看调度日志的“执行日志”里面有详细错误堆栈。2. 检查执行器日志看是否收到任务及处理异常。3. 检查执行器机器资源CPU、内存、线程数。1. 检查执行器状态恢复网络。2. 核对XxlJob(“name”)与调度中心配置的 JobHandler。3. 调整执行器线程池配置 (xxl.job.executor.max-pool-size)。4. 在调度中心任务配置中调大“任务超时时间”。任务一直显示“运行中”不结束1. 任务逻辑死循环或长时间阻塞。2. 执行器崩溃未向调度中心回调结果。3. 网络问题导致回调失败。1. 登录执行器服务器查看该任务的线程状态和日志。2. 检查执行器进程是否存活。3. 在调度中心手动点击“终止任务”。1. 优化任务代码避免无限循环设置超时中断。2. 重启执行器。3. 检查网络稳定性考虑增加回调重试机制。调度中心集群部署任务重复执行1. 多个调度中心实例时钟不同步。2. 数据库锁竞争异常极低概率。1. 检查各服务器系统时间是否一致。2. 查看调度中心日志关于数据库锁的报错。1. 使用 NTP 服务同步所有服务器时钟。2. 确保使用 InnoDB 引擎并检查数据库事务隔离级别。GLUE模式脚本更新后不生效1. 脚本语法错误。2. 执行器缓存了旧的脚本。1. 在调度中心 Web 界面检查脚本语法高亮是否正常。2. 查看执行器日志是否有脚本编译错误。1. 修正脚本语法。2. 在执行器配置中可以尝试重启执行器以清除缓存。通用排查命令检查端口连通性telnet 调度中心IP 8080和telnet 执行器IP 9999。查看进程ps -ef | grep java或jps -l。查看日志调度中心日志在启动目录的logs/下执行器日志在配置的logpath目录和 Spring Boot 应用日志中。9. 最佳实践与使用建议基于大量项目实践遵循以下建议可以让你更稳定、高效地使用 XXL-JOB。命名规范与分组执行器 AppName使用清晰的服务名环境标识如order-service-prod、> XXL-JOB分布式任务调度平台：配置调用中心实战指南
这次我们来看一个在企业级任务调度中非常实用的开源项目——XXL-JOB。如果你正在寻找一个轻量级、易扩展、支持分布式调度的任务调度平台并且关心它的配置流程、调用中心如何搭建那么这篇文章可以直接收藏。XXL-JOB 的核心价值在于将复杂的定时任务管理变得可视化、可控制它解决了传统基于Scheduled注解或Quartz集群配置繁琐、任务日志难以追踪、失败告警不及时等痛点。本文将重点拆解 XXL-JOB 的“配置调用中心”这一核心环节。很多人部署完调度中心后对于执行器如何正确注册、任务如何被精准触发感到困惑。我们会直接从实战出发不讲空泛概念重点关注调度中心与执行器的配置要点、网络连通性、注册发现机制以及任务调度的完整链路。通过本文你将能清晰地掌握如何搭建一个可用的 XXL-JOB 环境并理解其调度背后的原理为后续的复杂任务编排打下坚实基础。1. 核心能力速览在深入配置细节前我们先通过一个表格快速了解 XXL-JOB 调度中心的核心特性与要求这有助于你判断它是否适合你的项目。能力项说明项目类型分布式任务调度平台核心组件调度中心Admin、执行器Executor调度方式基于数据库锁的集群调度支持故障转移任务类型BEAN、GLUE(Java/Shell/Python等)、HTTP、命令行等触发策略CRON 表达式、固定速率、固定延迟、手动触发、父子任务触发注册发现执行器自动注册到调度中心支持手动录入通信方式基于 HTTP 的 RESTful API依赖存储必须依赖 MySQL或兼容数据库存储任务元数据与日志部署模式支持单机与集群部署调度中心执行器可分布式部署管理界面提供完整的 Web 管理后台用于任务管理、日志查询、用户管理等适合场景微服务架构下的定时任务统一管理、分布式批处理作业、需要可视化监控与告警的任务调度从上表可以看出XXL-JOB 并非一个简单的库而是一个需要独立部署的中心化调度服务。配置调用中心的核心就是让“调度中心”和“执行器”这两个角色能够正确通信与协作。2. 适用场景与使用边界XXL-JOB 非常适合以下场景微服务任务调度在 Spring Cloud 或 Dubbo 架构中各个微服务节点上的定时任务需要集中管理、避免重复执行。可视化运维需求开发或运维人员需要通过 Web 界面便捷地增删改查任务、查看执行日志、手动触发或终止任务。任务高可用与故障转移当某个执行器节点宕机时调度中心能将任务自动路由到其他健康的执行器实例上。复杂的任务编排需要实现任务依赖父子任务、分片广播大数据处理、失败重试、超时控制等高级特性。然而它也有明确的使用边界非中心化调度不适用如果你追求的是完全去中心化、无单点故障的调度模式如基于 Raft/Paxos 共识算法的方案XXL-JOB 的中心化调度器尽管支持集群可能不是最优选。超高频实时任务不适用XXL-JOB 的任务调度周期最小单位为秒级对于毫秒级或需要极低延迟的实时任务调度其基于数据库轮询的调度方式可能产生性能瓶颈。强事务性作业不适用它主要负责任务的触发与状态跟踪任务内部的业务逻辑和数据一致性需要执行器自身保证。环境依赖必须维护一个 MySQL 数据库实例这对于一些极度轻量化的应用可能引入额外复杂度。合规与安全提醒在配置调用中心时务必确保调度中心与执行器之间的网络通信安全如使用内网、配置防火墙策略。任务脚本如 GLUE 模式的执行具有较高权限需严格审核脚本内容避免注入攻击。对于操作权限应合理配置管理后台的用户角色与权限防止未授权访问。3. 环境准备与前置条件开始配置前请确保你的环境满足以下要求。这是保证后续步骤顺利进行的基础。Java 环境调度中心和执行器都是 Java 应用。推荐安装 JDK 1.8 或更高版本。可以通过java -version命令验证。MySQL 数据库这是 XXL-JOB 的必需依赖用于存储所有配置和日志。建议使用 MySQL 5.7 或以上版本。你需要准备一个专用的数据库并拥有创建表和读写数据的权限。Maven编译需要如果你计划从源码编译打包需要安装 Maven 3.x。网络连通性这是“配置调用中心”最关键也是最容易出错的环节。必须确保调度中心所在服务器其服务端口默认 8080能被所有执行器访问。执行器所在服务器其配置的xxl.job.executor.port端口默认 9999能被调度中心访问。双向网络通畅是执行器注册和任务回调成功的生命线。源码或发布包从 XXL-JOB 的 GitHub 官方仓库 (xuxueli/xxl-job) 下载最新 Release 版本的源码或直接下载编译好的xxl-job-admin-2.x.x.jar调度中心包。4. 安装部署与启动方式我们将分别部署调度中心和执行器。调度中心是独立服务执行器通常嵌入在你的业务应用中。4.1 调度中心部署第一步初始化数据库在准备好的 MySQL 中创建数据库如xxl_job然后执行源码包/doc/db/tables_xxl_job.sql中的 SQL 脚本完成表结构初始化。第二步配置调度中心找到调度中心配置文件/xxl-job-admin/src/main/resources/application.properties源码方式或解压包中的对应文件。### 调度中心JDBC链接 spring.datasource.urljdbc:mysql://你的数据库IP:3306/xxl_job?useUnicodetruecharacterEncodingUTF-8autoReconnecttrueserverTimezoneAsia/Shanghai spring.datasource.username你的数据库用户名 spring.datasource.password你的数据库密码 spring.datasource.driver-class-namecom.mysql.cj.jdbc.Driver ### 调度中心通讯TOKEN用于和执行器通信鉴权非必填但建议设置 xxl.job.accessToken你的自定义Token ### 调度中心端口 server.port8080 ### 调度中心上下文路径 server.servlet.context-path/xxl-job-admin第三步启动调度中心源码启动进入xxl-job-admin目录执行mvn clean package打包然后运行java -jar target/xxl-job-admin-2.x.x.jar。发布包启动直接运行java -jar xxl-job-admin-2.x.x.jar。启动成功后访问http://你的调度中心IP:8080/xxl-job-admin。默认登录账号/密码admin / 123456。4.2 执行器部署以Spring Boot为例执行器需要集成到你的业务项目中。首先在pom.xml中添加依赖。dependency groupIdcom.xuxueli/groupId artifactIdxxl-job-core/artifactId version2.4.0/version !-- 请使用与调度中心匹配的版本 -- /dependency然后在application.yml或application.properties中进行关键配置。# 执行器配置 xxl: job: admin: addresses: http://你的调度中心IP:8080/xxl-job-admin # 调度中心地址多个用逗号分隔 accessToken: 你的自定义Token # 与调度中心配置的accessToken一致若无则留空 executor: appname: your-app-executor # 执行器AppName是调度中心识别执行器的关键 address: # 执行器地址默认为空表示自动获取IP ip: # 执行器IP默认为空表示自动获取 port: 9999 # 执行器端口号需确保未被占用且调度中心可访问 logpath: ./logs/xxl-job/jobhandler # 任务日志文件存储路径 logretentiondays: 30 # 日志保存天数最后创建一个配置类XxlJobConfig。import com.xxl.job.core.executor.impl.XxlJobSpringExecutor; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; Configuration public class XxlJobConfig { private Logger logger LoggerFactory.getLogger(XxlJobConfig.class); Value(${xxl.job.admin.addresses}) private String adminAddresses; Value(${xxl.job.accessToken}) private String accessToken; Value(${xxl.job.executor.appname}) private String appname; Value(${xxl.job.executor.address}) private String address; Value(${xxl.job.executor.ip}) private String ip; Value(${xxl.job.executor.port}) private int port; Value(${xxl.job.executor.logpath}) private String logPath; Value(${xxl.job.executor.logretentiondays}) private int logRetentionDays; Bean public XxlJobSpringExecutor xxlJobExecutor() { logger.info( xxl-job config init.); XxlJobSpringExecutor xxlJobSpringExecutor new XxlJobSpringExecutor(); xxlJobSpringExecutor.setAdminAddresses(adminAddresses); xxlJobSpringExecutor.setAppname(appname); xxlJobSpringExecutor.setAddress(address); xxlJobSpringExecutor.setIp(ip); xxlJobSpringExecutor.setPort(port); xxlJobSpringExecutor.setAccessToken(accessToken); xxlJobSpringExecutor.setLogPath(logPath); xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays); return xxlJobSpringExecutor; } }启动你的业务应用执行器将尝试向配置的调度中心地址注册。5. 功能测试与效果验证配置完成后我们需要在调度中心 Web 界面进行一系列操作验证“调用中心”是否真正配置成功。5.1 验证执行器自动注册登录调度中心访问http://你的调度中心IP:8080/xxl-job-admin。进入“执行器管理”在左侧菜单找到“执行器管理”。查看自动注册列表如果你的网络和配置正确你应该能在列表里看到一个 AppName 为your-app-executor即你在执行器配置中设置的appname的执行器其注册方式为“自动注册”下面会列出该执行器的 IP 和端口例如192.168.1.100:9999。成功标志执行器状态正常地址信息完整。失败排查如果列表为空99% 的原因是网络不通或配置错误。请跳至第8章“常见问题”部分排查。5.2 创建并测试一个简单任务进入“任务管理”点击左侧“任务管理”然后点击“新增”。填写任务信息执行器选择刚才注册成功的your-app-executor。任务描述填写“测试任务”。路由策略选择“第一个”或“轮询”。Cron填写0/30 * * * * ?表示每30秒执行一次。运行模式选择 “BEAN”。JobHandler填写一个名称如demoJobHandler。这个名称需要与执行器中的代码对应。在执行器项目中编写任务处理器 在你的 Spring Boot 业务代码中创建一个 Bean 模式的任务处理器。import com.xxl.job.core.handler.annotation.XxlJob; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; Component public class DemoJobHandler { private static Logger logger LoggerFactory.getLogger(DemoJobHandler.class); XxlJob(demoJobHandler) // 注解中的value必须与调度中心配置的JobHandler一致 public void demoJobHandler() throws Exception { logger.info(XXL-JOB, Hello World.); // 这里编写你的业务逻辑 for (int i 0; i 5; i) { logger.info(beat at: i); Thread.sleep(1000); } } }启动与观察在调度中心任务列表找到你刚创建的任务点击操作栏的“启动”。等待约30秒一个调度周期查看“操作”栏下的“调度日志”。点击“调度日志”进入查看该次执行的“执行日志”。成功标志在“执行日志”中能看到你代码中打印的“XXL-JOB, Hello World.”和“beat at:x”等信息且任务状态为“成功”。失败排查如果状态为“失败”点击“执行日志”查看详细报错常见原因是 JobHandler 名称不匹配、执行器网络回调失败等。5.3 测试手动触发与终止手动触发一次在任务列表点击“执行一次”。立即查看调度日志确认任务被触发并执行成功。这常用于测试任务逻辑是否正确。手动终止创建一个长时间运行的任务例如在处理器中Thread.sleep(60000)。在任务启动后迅速点击“终止任务”。观察调度日志状态应变为“失败”日志中应有“手动终止”的相关记录。这验证了调度中心对执行器任务的管控能力。6. 接口 API 与批量任务XXL-JOB 调度中心本身提供了完善的 Web 操作界面。但在自动化运维或与其他系统集成时我们可能需要通过其内置的 API 来操作。6.1 调度中心 RESTful API 调用XXL-JOB 调度中心的后台操作大部分都有对应的 API。API 调用需要携带登录后获得的 Cookie 或使用 Token 进行鉴权取决于版本和配置。以下是一个使用curl命令手动触发任务的示例需先登录获取 Cookie# 1. 登录获取Cookie这里演示基础认证实际可能需处理更复杂的Session # 注意此方法仅为示例生产环境建议使用更稳定的Token方式或SDK。 curl -c cookies.txt -X POST http://你的调度中心IP:8080/xxl-job-admin/login \ -H Content-Type: application/x-www-form-urlencoded \ -d userNameadminpassword123456 # 2. 使用保存的Cookie调用“执行一次”接口 # 任务IDjobId需要在调度中心任务列表页面查看 curl -b cookies.txt -X POST http://你的调度中心IP:8080/xxl-job-admin/jobinfo/trigger \ -H Content-Type: application/x-www-form-urlencoded \ -d id你的任务ID对于更规范的集成建议查阅官方文档的 API 部分或直接在前端页面通过浏览器开发者工具的“网络”选项卡观察对应操作发出的请求进行模仿。6.2 批量任务处理模式XXL-JOB 本身不直接提供“上传文件批量创建任务”的功能。但可以通过以下模式实现批量任务处理分片广播任务这是 XXL-JOB 处理批量数据的核心模式。你只需要定义一个任务一个 JobHandler。当这个任务被触发时调度中心会向所有注册的执行器实例广播该任务。同时每个执行器会收到分片参数分片索引和总分片数。在执行器代码中你可以根据分片参数来处理数据的不同分区。XxlJob(shardingJobHandler) public void shardingJobHandler() throws Exception { // 获取分片参数 int shardIndex XxlJobHelper.getShardIndex(); int shardTotal XxlJobHelper.getShardTotal(); logger.info(分片参数当前分片序号 {}, 总分片数 {}, shardIndex, shardTotal); // 根据 shardIndex 和 shardTotal 从数据库或文件中获取属于本分片的数据进行处理 ListData myDataPartition fetchDataByShard(shardIndex, shardTotal); for (Data data : myDataPartition) { process(data); } }父子任务依赖你可以创建一个“父任务”其处理器逻辑不处理具体业务而是通过调用调度中心 API如上面所述动态触发多个“子任务”。这适合有严格顺序或依赖关系的批量作业。外部脚本驱动在调度中心创建多个 GLUEShell/Python模式的任务。编写一个外部控制脚本通过调用调度中心 API按需批量触发这些 GLUE 任务。7. 资源占用与性能观察XXL-JOB 作为任务调度中间件其资源消耗主要来自调度中心、执行器以及共用的 MySQL 数据库。调度中心资源占用CPU/内存调度中心本身是一个 Spring Boot 应用内存占用通常在 512MB - 1GB 左右CPU 消耗较低。其核心线程会周期性扫描数据库中的任务表计算下次触发时间。当任务数量极大如数万、调度非常频繁秒级时扫描数据库的压力会增大需关注数据库 CPU 和连接数。数据库连接确保 MySQLmax_connections配置足够调度中心会持有数据库连接进行任务调度和日志记录。执行器资源占用执行器作为客户端资源消耗主要取决于你编写的任务处理器JobHandler的业务逻辑。XXL-JOB 框架本身只增加少量的内存和线程开销。需要关注的是执行器的线程池。XXL-JOB 执行器使用内置线程池来运行任务避免任务阻塞。如果任务都是 IO 密集型或执行时间很长可能需要调整执行器的线程池参数在XxlJobConfig中可通过XxlJobSpringExecutor的setExecutorThreadPool等方法配置。网络 I/O 观察调度中心与执行器之间通过 HTTP 进行心跳注册、任务触发和结果回调。使用netstat或资源监视器观察相关端口的连接状态和流量。不稳定的网络会导致执行器频繁掉线、任务触发失败或回调超时。日志磁盘占用调度日志和执行日志默认存储在数据库中xxl_job_log表长期运行后该表会变得非常大可能影响调度性能。务必在调度中心配置“日志报告保留天数”并定期清理过期日志或考虑将日志迁移到其他存储。执行器的运行日志业务代码打的 log存储在配置的logpath目录也需定期清理或配置日志滚动策略。性能调优建议对于任务量大的场景可以将调度中心集群部署并配合 Nginx 进行负载均衡。数据库层面可以考虑读写分离将日志表放在单独的实例上。合理设置任务的 Cron 表达式避免大量任务在同一秒触发造成调度峰值。对于执行时间短但频繁的任务可以适当调小执行器的线程池核心线程数对于执行时间长的任务需调大最大线程数并设置合理的队列容量。8. 常见问题与排查方法配置调用中心时90%的问题集中在网络和配置上。下表列出了典型问题及排查思路。问题现象可能原因排查方式解决方案执行器列表为空未自动注册1. 网络不通。2. 执行器配置的admin.addresses错误。3. 调度中心未启动或端口不对。4. 执行器应用启动失败。1. 在执行器机器用telnet或curl测试调度中心地址端口。2. 检查执行器启动日志看是否有连接调度中心的错误。3. 登录调度中心数据库查看xxl_job_registry表是否有数据。1. 打通网络关闭防火墙或配置安全组规则。2. 核对xxl.job.admin.addresses配置确保是http://ip:port/xxl-job-admin。3. 重启调度中心确认端口监听。任务触发后调度日志显示“失败”1. 执行器宕机或网络瞬时不通。2. JobHandler 名称不匹配。3. 执行器线程池已满任务被拒绝。4. 任务执行超时。1. 查看调度日志的“执行日志”里面有详细错误堆栈。2. 检查执行器日志看是否收到任务及处理异常。3. 检查执行器机器资源CPU、内存、线程数。1. 检查执行器状态恢复网络。2. 核对XxlJob(“name”)与调度中心配置的 JobHandler。3. 调整执行器线程池配置 (xxl.job.executor.max-pool-size)。4. 在调度中心任务配置中调大“任务超时时间”。任务一直显示“运行中”不结束1. 任务逻辑死循环或长时间阻塞。2. 执行器崩溃未向调度中心回调结果。3. 网络问题导致回调失败。1. 登录执行器服务器查看该任务的线程状态和日志。2. 检查执行器进程是否存活。3. 在调度中心手动点击“终止任务”。1. 优化任务代码避免无限循环设置超时中断。2. 重启执行器。3. 检查网络稳定性考虑增加回调重试机制。调度中心集群部署任务重复执行1. 多个调度中心实例时钟不同步。2. 数据库锁竞争异常极低概率。1. 检查各服务器系统时间是否一致。2. 查看调度中心日志关于数据库锁的报错。1. 使用 NTP 服务同步所有服务器时钟。2. 确保使用 InnoDB 引擎并检查数据库事务隔离级别。GLUE模式脚本更新后不生效1. 脚本语法错误。2. 执行器缓存了旧的脚本。1. 在调度中心 Web 界面检查脚本语法高亮是否正常。2. 查看执行器日志是否有脚本编译错误。1. 修正脚本语法。2. 在执行器配置中可以尝试重启执行器以清除缓存。通用排查命令检查端口连通性telnet 调度中心IP 8080和telnet 执行器IP 9999。查看进程ps -ef | grep java或jps -l。查看日志调度中心日志在启动目录的logs/下执行器日志在配置的logpath目录和 Spring Boot 应用日志中。9. 最佳实践与使用建议基于大量项目实践遵循以下建议可以让你更稳定、高效地使用 XXL-JOB。命名规范与分组执行器 AppName使用清晰的服务名环境标识如order-service-prod、>