springboot整合xxl-job分布式任务调度平台

柔情只为你懂 2023-09-30 10:13 38阅读 0赞

#### springboot整合xxl-job分布式任务调度平台 ####

*   *   *  1、下载xxl-job源码
         *  2、运行数据库文件、修改propertis为自己数据库
         *  3、在自己工程新建xxl-job模块
         *  4、引入xxl-job依赖，添加yml配置
         *  5、xxl-job配置类
         *  6、定时任务小测试
         *  7、启动两个项目，xxl-job默认端口链接:
         *  8、配置执行器
         *  9、配置任务管理

#### 1、下载xxl-job源码 ####

链接: [https://www.xuxueli.com/xxl-job/][https_www.xuxueli.com_xxl-job]

XXL-JOB是一个`分布式`任务调度平台，其核心设计目标是开发迅速、学习简单、轻量级、易扩展、开箱即用。

#### 2、运行数据库文件、修改propertis为自己数据库 ####

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6LS154y_5qKm_size_20_color_FFFFFF_t_70_g_se_x_16]

#### 3、在自己工程新建xxl-job模块 ####

因为xxl-job就是一个项目，我们连接连到他的地址，帮我们管理，  
部署需要把xxl-job和我们工程一起部署  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6LS154y_5qKm_size_15_color_FFFFFF_t_70_g_se_x_16]

#### 4、引入xxl-job依赖，添加yml配置 ####

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

xxl:
      job:
        accessToken: ''
        admin:
          addresses: http://127.0.0.1:8080/xxl-job-admin
        executor:
          address: ''
          appname: xxl-job-executor-sample
          ip: ''
          logpath: /data/applogs/xxl-job/jobhandler
          logretentiondays: 30  
          port: 9999   #xxl-job连接端口
          
    或propertis
    
        ### 调度中心部署跟地址 [选填]：如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调"；为空则关闭自动注册；
        xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin
        ### 执行器通讯TOKEN [选填]：非空时启用；
        xxl.job.accessToken=
        ### 执行器AppName [选填]：执行器心跳注册分组依据；为空则关闭自动注册
        xxl.job.executor.appname=xxl-job-executor-sample
        ### 执行器注册 [选填]：优先使用该配置作为注册地址，为空时使用内嵌服务 ”IP:PORT“ 作为注册地址。从而更灵活的支持容器类型执行器动态IP和动态映射端口问题。
        xxl.job.executor.address=
        ### 执行器IP [选填]：默认为空表示自动获取IP，多网卡时可手动设置指定IP，该IP不会绑定Host仅作为通讯实用；地址信息用于 "执行器注册" 和 "调度中心请求并触发任务"；
        xxl.job.executor.ip=
        ### 执行器端口号 [选填]：小于等于0则自动获取；默认端口为9999，单机部署多个执行器时，注意要配置不同执行器端口；
        xxl.job.executor.port=9999
        ### 执行器运行日志文件存储磁盘路径 [选填] ：需要对该路径拥有读写权限；为空则使用默认路径；
        xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
        ### 执行器日志文件保存天数 [选填] ： 过期日志自动清理, 限制值大于等于3时生效; 否则, 如-1, 关闭自动清理功能；
        xxl.job.executor.logretentiondays=30

#### 5、xxl-job配置类 ####

package com.example.executor.core.config;
    
    import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class XxlJobConfig {
        
    	@Value("${xxl.job.admin.addresses}")
    	private String adminAddresses;
    
    	@Value("${xxl.job.executor.appname}")
    	private String appName;
    
    	@Value("${xxl.job.executor.ip}")
    	private String ip;
    
    	@Value("${xxl.job.executor.port}")
    	private int port;
    
    	@Value("${xxl.job.executor.logretentiondays}")
    	private int logRetentionDays;
    
    	@Bean(initMethod = "start", destroyMethod = "destroy")
    	public XxlJobSpringExecutor xxlJobExecutor() {
        
    		XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
    		xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
    		xxlJobSpringExecutor.setAppname(appName);
    		xxlJobSpringExecutor.setIp(ip);
    		xxlJobSpringExecutor.setPort(port);
    		xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
    		return xxlJobSpringExecutor;
    	}
    }

#### 6、定时任务小测试 ####

@Component记得要写  
@XxlJob(“testTask”) 就是你任务管理配置的JobHandler  
![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAaG1i4oaR_size_20_color_FFFFFF_t_70_g_se_x_16]

#### 7、启动两个项目，xxl-job默认端口链接: ####

[http://localhost:8080/xxl-job-admin][http_localhost_8080_xxl-job-admin]  
账号：admin  
密码：123456

#### 8、配置执行器 ####

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAaG1i4oaR_size_20_color_FFFFFF_t_70_g_se_x_16 1]

#### 9、配置任务管理 ####

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6LS154y_5qKm_size_20_color_FFFFFF_t_70_g_se_x_16 1]  
此时你的定时器就会被xxl-job管理了

[https_www.xuxueli.com_xxl-job]: https://www.xuxueli.com/xxl-job/
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6LS154y_5qKm_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/844b6205e14d4dfeb5935d8015d53e2b.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA6LS154y_5qKm,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6LS154y_5qKm_size_15_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/16a050c40865420f9478459858ed8a82.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA6LS154y_5qKm,size_15,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAaG1i4oaR_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/df900867add64e92b085ad81d21278ea.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAaG1i4oaR,size_20,color_FFFFFF,t_70,g_se,x_16
[http_localhost_8080_xxl-job-admin]: http://localhost:8080/xxl-job-admin
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBAaG1i4oaR_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/1fc7514dc83f4be8bb8e8e63023d786f.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBAaG1i4oaR,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6LS154y_5qKm_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/931d446cc0cf47e4a3f5e64122987e44.png?x-oss-process=image/watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA6LS154y_5qKm,size_20,color_FFFFFF,t_70,g_se,x_16