springboot整合 xxl-job的项目实践_Java

一、xxl-job是什么

xxl-job 是一个分布式任务调度平台，主要用于解决在分布式系统中任务调度和任务管理的问题。

xxl-job 的架构通常包括以下几个组件：
调度中心（scheduler）：负责任务的调度、管理和监控，是整个调度系统的核心。
执行器（executor）：负责具体任务的执行，可以部署在不同的节点上。
web 管理控制台：提供友好的 web 界面，方便用户进行任务的管理和监控。

二、使用步骤

1. 下载并运行管理端代码

项目地址：
1️⃣：【gitee】https://gitee.com/xuxueli0323/xxl-job
2️⃣：【github】https://github.com/xuxueli/xxl-job

项目整体结构

管理端需要注意的地方

在这里插入图片描述

执行sql脚本，tables_xxl_job.sql

修改application.properties配置文件，主要修改两处

### xxl-job, datasource
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/xxl_job?useunicode=true&characterencoding=utf-8&autoreconnect=true&servertimezone=asia/shanghai
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.driver

### xxl-job, access token
xxl.job.accesstoken=default_token

数据库地址对应的是第一步执行脚本创建的库的位置

accesstoken的值需要和执行器中配置的值(后面会写)一致
通过application运行程序，也可以打包后通过jar命令启动

2. 访问管理页面，确认是否启动成功

地址：http://127.0.0.1:8080/xxl-job-admin 【和配置文件一致】
默认账密：admin/123456【忘记密码可以去数据库修改，使用md5加密后填充】

3. 配置执行器【在自己的springboot项目中配置】

引入依赖

        <dependency>
            <groupid>com.xuxueli</groupid>
            <artifactid>xxl-job-core</artifactid>
            <version>2.4.0</version>
        </dependency>

添加配置文件

accesstoken与前面配置一致，address对应管理端访问地址
executor（执行器）的配置与后面在页面上创建执行器时保持一致

### xxl-job admin address list, such as "http://address" or "http://address01,http://address02"
xxl:
  job:
    accesstoken: default_token
    admin:
      addresses: http://127.0.0.1:8080/xxl-job-admin
    executor:
      appname: xxl-job-executor-test-zhu
      address: http://localhost:9999  # 填充地址，假设执行器运行在本地
      ip: 127.0.0.1  # 填充本地ip，确保它与address配置一致
      port: 9999
      logpath: /data/applogs/xxl-job/jobhandler
      logretentiondays: -1

执行器组件配置

package com.zhui.yudada.config;

import com.xxl.job.core.executor.impl.xxljobspringexecutor;
import lombok.extern.slf4j.slf4j;
import org.springframework.beans.factory.annotation.value;
import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;

@slf4j
@configuration
public class xxljobconfig {
    @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() {
        log.info(">>>>>>>>>>> start 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;
    }
}

jobhander配置

package com.zhui.yudada.job;
 
 
import com.xxl.job.core.biz.model.returnt;
import com.xxl.job.core.handler.annotation.xxljob;
import org.springframework.beans.factory.annotation.value;
import org.springframework.stereotype.component;

 
 
@component
public class hellojob {
 
    @value("${server.port}")
    private string port;
 
    @xxljob("demojobhandler")
    public returnt hellojob() {
        system.out.println("简单任务执行了。。。" + port);
        return  returnt.success;
    }
}

启动项目，出现下面的提示说明启动成功

在这里插入图片描述