xxl-job学习（一篇文章解决）

news2024/11/25 6:58:19

前言：学习xxl-job需要有git，springboot的基础，学起来就很简单

xxl-job是一个分布式的任务调度平台，其核心设计目标是：学习简单、开发迅速、轻量级、易扩展，现在已经开放源代码并接入多家公司的线上产品线，开箱即用。xxl是xxl-job的开发者大众点评的许雪里名称的拼音开头。

源码下载地址（放在下面了）

xxl-job: 一个分布式任务调度平台，其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线，开箱即用。 (gitee.com)

然后把sql文件运行一下（也就是所需要的数据库），效果如下

直接启动（原神！启动.jpg），启动后输入 http://localhost:8090/xxl-job-admin

效果如下，账号admin密码123456

登录后效果如下

下面我们就来基于自己的操作xxl-job，新建一个springboot项目

添加所需要的依赖

<!--        使用xxl-job-->
        <dependency>
            <groupId>com.xuxueli</groupId>
            <artifactId>xxl-job-core</artifactId>
            <version>2.3.1</version>
        </dependency>

新建job，config两个文件夹

XxljobConfig如下，SimpleXxlJob如下

@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() {

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;

}

}

@Component
public class SimpleXxlJob {

    @XxlJob("demoJobHandler")
    public void demoJobHandler() throws Exception {
        System.out.println("执行定时任务,执行时间:"+new Date());
    }

}

我们直接启动我们的springboot项目，如果看到我们注册上去的demoJobHandler，就表示成功了

下面我们来添加一个任务

点击任务管理的新增，填写我们所需要的东西

设置好了如下，然后点击保存

就会在idea里面看到，看到有日志就表示成功了

到这里就操作成功了，恭喜各位小伙伴

下面我们GLUE模式来操作

任务以源码方式维护在调度中心，支持通过Web IDE在线更新，实时编译和生效，因此不需要指定JobHandler。（ “GLUE模式(Java)” 运行模式的任务实际上是一段继承自IJobHandler的Java类代码，它在执行器项目中运行，可使用[@Resource][@Autowire]注入执行器里中的其他服务.

我们在任务管理新建一个GlUE模式的，

写一个service文件夹，编写HelloService类

@Service
public class HelloService {

    public void methodA(){
        System.out.println("执行MethodA的方法");
    }

    public void methodB(){
        System.out.println("执行MethodB的方法");
    }

}

在刚刚创建的任务管理，选择GLUE IDE，

效果如下，我们需要注册我们的HelloService。

包也要记得引入

package com.xxl.job.service.handler;

import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.IJobHandler;
import cn.wolfcode.xxljobdemo.service.HelloService;
import org.springframework.beans.factory.annotation.Autowired;

public class DemoGlueJobHandler extends IJobHandler {

@Autowired
private HelloService helloService;


   @Override
   public void execute() throws Exception {
       XxlJobHelper.log("XXL-JOB, Hello World.");
   }

}

package com.xxl.job.service.handler;

import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.IJobHandler;
import cn.wolfcode.xxljobdemo.service.HelloService;
import org.springframework.beans.factory.annotation.Autowired;

public class DemoGlueJobHandler extends IJobHandler {

@Autowired
private HelloService helloService;


   @Override
   public void execute() throws Exception {

helloService.methodA();

   }

}