急速掌握-新版分布式调度XXL-Job+SpringBoot2.X项目实战-当你的定时任务在集群中"各自为政"、重复执行、无人监管时

bash# 1. 下载源码（GitHub：xuxueli/xxl-job，切换到2.4.0标签）
git clone https://github.com/xuxueli/xxl-job.git
cd xxl-job
git checkout tags/2.4.0

# 2. 初始化数据库（MySQL 5.7+）
mysql -u root -p < doc/db/tables_xxl_job.sql
# 核心表：xxl_job_info（任务表）、xxl_job_log（日志表）、xxl_job_registry（执行器注册表）等

# 3. 修改配置文件 xxl-job-admin/src/main/resources/application.properties
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/xxl_job?useUnicode=true&characterEncoding=UTF8
spring.datasource.username=root
spring.datasource.password=your_password
server.port=8080

# 4. 编译启动
mvn clean package -Dmaven.test.skip=true
java -jar xxl-job-admin/target/xxl-job-admin-2.4.0.jar

xml<dependency>
    <groupId>com.xuxueli</groupId>
    <artifactId>xxl-job-core</artifactId>
    <version>2.4.0</version>
</dependency>

yamlspring:
  application:
    name: xxl-job-demo

xxl:
  job:
    admin:
      addresses: http://127.0.0.1:8080/xxl-job-admin
      access-token: default_token  # 安全校验，建议生产环境修改
    executor:
      appname: ${spring.application.name}
      port: 9999
      logpath: /data/applogs/xxl-job/jobhandler
      logretentiondays: 30

java@Configuration
public class XxlJobConfig {

    @Value("${xxl.job.admin.addresses}")
    private String adminAddresses;

    @Value("${xxl.job.executor.appname}")
    private String appname;

    @Value("${xxl.job.executor.port}")
    private int port;

    @Value("${xxl.job.executor.logpath}")
    private String logPath;

    @Bean
    public XxlJobSpringExecutor xxlJobExecutor() {
        XxlJobSpringExecutor executor = new XxlJobSpringExecutor();
        executor.setAdminAddresses(adminAddresses);
        executor.setAppname(appname);
        executor.setPort(port);
        executor.setLogPath(logPath);
        executor.setLogRetentionDays(30);
        return executor;
    }
}

java@Component
public class SampleJobHandler {

    @XxlJob("demoJobHandler")
    public void demoJobHandler() throws Exception {
        XxlJobHelper.log("XXL-Job 任务执行成功！当前时间：{}", System.currentTimeMillis());
        // 你的业务逻辑写在这里
    }

    // 支持参数传递
    @XxlJob("paramJobHandler")
    public void paramJobHandler() throws Exception {
        String param = XxlJobHelper.getJobParam();
        XxlJobHelper.log("接收到参数：{}", param);
    }
}

执行器启动 → 自动注册到调度中心（汇报IP、端口、任务列表）
        ↓
调度中心解析CRON → 到达触发时间 → 从xxl_job_registry选择执行器
        ↓
HTTP调用执行器 → 反射执行@XxlJob标记的方法
        ↓
执行结果回调 → 调度中心写入xxl_job_log → 失败则触发告警