xxl-job任务调度

伏加特遇上西柚

2807人浏览 · 2021-04-17 23:45:29

伏加特遇上西柚 · 2021-04-17 23:45:29 发布

一、xxl-job-admin

资源文件及代码

链接：点我呀
提取码：bg2y
复制这段内容后打开百度网盘手机App，操作更方便哦

1.创建xxl-job需要的数据库

xxl-job.sql

2.更改xxl-job-admin的数据库连接

在这里插入图片描述

3.运行xxl-job-admin

cmd命令打开，直接cd到xxl-job-admin.jar对应的目录，运行java -jar xxl-job-admin.jar
在这里插入图片描述

服务端口号可以在properties中修改

4.访问xxl-job

http://localhost:8091/xxl-job-admin/
在这里插入图片描述

二、业务集成

1.添加maven依赖包

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

2.application.xml配置

xxl:
  job:
    enabled: true
    executor:
      appname: xxJob-executor  #此处名字在xxjob控制台会用到
      port: 9999
      logpath: ${user.home}/xxl-job/logs
      logretentiondays: -1
    admin:
      addresses: http://localhost:8091/xxl-job-admin

3.xxl-job配置类

创建一个类名为XxlConfig的配置类，配置文件来自官方

package cn.job.xxl.config;

import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@ConditionalOnProperty(name = "xxl.job.enabled", havingValue = "true")
public class XxlConfig {
    @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(initMethod = "start", destroyMethod = "destroy")
    public XxlJobSpringExecutor xxlJobExecutor() {
        XxlJobSpringExecutor xxlJobExecutor = new XxlJobSpringExecutor();
        xxlJobExecutor.setAdminAddresses(adminAddresses);
        xxlJobExecutor.setAppName(appName);
        xxlJobExecutor.setIp("");
        xxlJobExecutor.setPort(port);
        xxlJobExecutor.setAccessToken("");
        xxlJobExecutor.setLogPath(logPath);
        xxlJobExecutor.setLogRetentionDays(logRetentionDays);
        return xxlJobExecutor;
    }

}

4.编写一个job

方式一：

package cn.job.xxl.job;

import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.JobHandler;
import org.springframework.stereotype.Component;

@JobHandler(value = "xxl.job.test") //此处值在控制台中的任务管理器中会用到
@Component
public class MyJob  extends IJobHandler {
        @Override
        public ReturnT<String> execute(String s) throws Exception {
            System.out.println("任务开启--------------");
            return SUCCESS;
        }
}

方式二

import com.ifly.mdm.modules.system.util.DateUtils;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.springframework.stereotype.Component;

import static com.xxl.job.core.biz.model.ReturnT.SUCCESS;

@Component
public class MyJob {

    @XxlJob("xxl.job.test")
    public ReturnT<String> execute(String s) throws Exception {
        XxlJobHelper.log("==>任务开启开始>........时间：" + DateUtils.getNowTime());
        System.out.println("执行任务--------------");
        XxlJobHelper.log("==>任务开启结束>........时间：" + DateUtils.getNowTime());
        return SUCCESS;
    }
}

5.启动程序

package cn.job.xxl;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class XxlMain {

    public static void main(String[] args) {
        SpringApplication.run(XxlMain.class, args);
        System.out.println("======xxl job 启动------------");
    }
}

在这里插入图片描述

三、控制台维护job

控制台地址：http://localhost:8091/xxl-job-admin/

1.新增执行器

在这里插入图片描述

2.新增定时任务

在这里插入图片描述

3.开启定时任务

在这里插入图片描述

四、cron表达式

cron表达式是一个字符串，字符串以5或6个空格隔开，分为6或7个域，每一个域代表一个含义.

corn从左到右（用空格隔开）：秒分小时月份中的日期月份星期中的日期年份
在这里插入图片描述
每个域都有自己允许的值和一些特殊字符构成,使用这些特殊字符可以使我们定义的表达式更加灵活。

下面是对这些特殊字符的介绍：

	（1）*：表示匹配该域的任意值。假如在Minutes域使用*, 即表示每分钟都会触发事件。

　　（2）?：只能用在DayofMonth和DayofWeek两个域。它也匹配域的任意值，但实际不会。因为DayofMonth和DayofWeek会相互影响。例如想在每月的20日触发调度，不管20日到底是星期几，则只能使用如下写法： 13 13 15 20 * ?, 其中最后一位只能用？，而不能使用*，如果使用*表示不管星期几都会触发，实际上并不是这样。

　　（3）-：表示范围。例如在Minutes域使用5-20，表示从5分到20分钟每分钟触发一次 

　　（4）/：表示起始时间开始触发，然后每隔固定时间触发一次。例如在Minutes域使用5/20,则意味着5分钟触发一次，而25，45等分别触发一次. 

　　（5）,：表示列出枚举值。例如：在Minutes域使用5,20，则意味着在5和20分每分钟触发一次。 

　　（6）L：表示最后，只能出现在DayofWeek和DayofMonth域。如果在DayofWeek域使用5L,意味着在最后的一个星期四触发。 

　　（7）W:表示有效工作日(周一到周五),只能出现在DayofMonth域，系统将在离指定日期的最近的有效工作日触发事件。例如：在 DayofMonth使用5W，如果5日是星期六，则将在最近的工作日：星期五，即4日触发。如果5日是星期天，则在6日(周一)触发；如果5日在星期一到星期五中的一天，则就在5日触发。另外一点，W的最近寻找不会跨过月份 。

　　（8）LW:这两个字符可以连用，表示在某个月最后一个工作日，即最后一个星期五。 

　　（9）#:用于确定每个月第几个星期几，只能出现在DayofMonth域。例如在4#2，表示某月的第二个星期三。