1. 部署

就是这个地址: https://gitee.com/xuxueli0323/xxl-job
由于xxl-job的思想是 调度中心负责调度任务,然后有执行器负责接受调度的信息,然后根据调度,执行任务中的具体逻辑

将 xl-job-admin 启动起来,操作xl-job-admin这个文件夹下的配置文件即可:

创建数据库
执行sql文件
修改yml配置
启动这个服务
访问,http://127.0.0.1:8080/xxl-job-admin/
并登录 admin/123456

2.SpringBoot集成

1引入xxl-job核心依赖
   <dependency>
            <groupId>com.xuxueli</groupId>
            <artifactId>xxl-job-core</artifactId>
            <version>2.3.1</version>
        </dependency>

2 创建服务,配置yml

xxl.job.admin.addresses = http://127.0.0.1:8080/xxl-job-admin
xxl.job.executor.port = 9999
xxl.job.executor.appname = xxljob
xxl.job.executor.logpath = /data/applogs/xxl-job/jobhandler
xxl.job.executor.logretentiondays = 30

3 配置job

@Slf4j
@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;

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

    @Bean
    @ConditionalOnExpression("${xxl-job.enabled:true}")
    public XxlJobSpringExecutor xxlJobSpringExecutor() {
        log.info("xxl-job config init =====");
        XxlJobSpringExecutor executor = new XxlJobSpringExecutor();
        executor.setAdminAddresses(adminAddresses);
        executor.setAppname(appName);
        executor.setPort(port);
        executor.setLogPath(logPath);
        executor.setLogRetentionDays(logRetentionDays);
        return executor;
    }
}

4 测试

@Component
public class TestJob {

    // 测试xxlJob是否配置成功
    @XxlJob(value = "firstTestJob")
    public ReturnT<String> firstTestJob(String param){
        System.out.println("执行触发器："+param);
        return ReturnT.SUCCESS;
    }

}