
一、环境准备
基础环境配置:
请确保您的系统中已安装以下软件:
JDK 1.8及以上版本
Maven 3及以上版本
MySQL 5.7及以上版本
源码获取:
从GitHub或Gitee上下载源码,推荐选择稳定版本如2.3.0。源码下载方式如下:
使用git命令克隆项目:`git clone /xu0323/xxl-job.git`,并切换至2.3.0分支:`git checkout -b 2.3.0 origin/2.3.0`。
二、调度中心部署流程
数据库初始化:
执行源码中提供的 /xxl-job/doc/db/tables_xxl_job.sql 脚本,以创建名为xxl_job的数据库。
配置调度中心:
启动调度中心:
编译打包项目后运行,并通过浏览器访问localhost:8080/xxl-job-admin,使用默认账号登录。
三、执行器配置步骤
添加依赖:
在Spring Boot项目中引入相应的依赖,确保版本与调度中心一致,依赖信息如下:com.xu的xxl-job-core,版本号为2.3.0。
配置文件设置:
初始化执行器组件:
创建一个配置类XxlJobConfig.java,注入XxlJobSpringExecutor并设置相关参数(如Admin地址、AppName等)。
四、任务开发与测试流程
任务处理器编写:
使用@XxlJob注解定义任务方法,例如:
`@Component public class MyJobHandler { @XxlJob(“myJobHandler”) public void execute() {…} }`
在执行方法中编写任务逻辑。
任务注册:
在调度中心界面添加执行器,确保执行器名称与配置文件中一致。然后配置任务,包括Cron表达式、路由策略、任务参数等。
运行与监控:
启动执行器后,任务会自动注册至调度中心。通过调度中心手动触发任务,并查看日志以了解任务执行结果。
五、常见问题及解决方案
执行器未注册:检查xxl.job.admin.addresses地址配置是否正确,以及网络是否通畅。
数据库连接失败:确保MySQL版本兼容,且调度中心集群强制连接主库。
扩展功能介绍:
分片任务:通过XxlJobHelper.getShardIndex()实现分布式任务分片。
动态参数:任务运行时通过XxlJobHelper.getJobParam()获取参数。
失败告警:配置邮件通知,任务失败时自动触发邮件报警。
