6.springboot整合xxjob

1.xxjob环境配置

1.1源码下载

xxjob源码下载传送门

1.2初始化数据库

在xxl-job-2.0.1\doc\db\tables_xxl_job.sql执行这个sql文件到

1.3项目中配置数据源

1.3启动项目

登录http://localhost:8080/xxl-job-admin/jobinfo 配置成功

2.项目中引入xxjob

2.1导入xxjob依赖

<!-- xxl-job-core -->

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

2.1application.yaml中配置

xxl-job:
  #xxjob的地址
  address: 127.0.0.1:8888/xxl-job-admin/
  #执行器的名字
  executor-appname: xx-job-ext
  #注册的地址 自动注入可以不写
  executor-ip: 
  executor-port: 8081
  accessToken:
  executor-logpath: D:/tmp
  executor-logretentionday: 1

package com.zrp.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;

/**
 * @author 赵锐鹏
 * @date 2021/11/3 0003
 */
@Configuration
public class XxJobConfig {
    @Value("${xxl-job.address}")
    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.accessToken}")
    private String accessToken;


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


    @Value("${xxl-job.executor-logretentionday}")
    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.setAccessToken(accessToken);
        xxlJobSpringExecutor.setLogPath(logPath);
        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
        return xxlJobSpringExecutor;

    }
}