前言

Hi，大家好，我是希留。

上一篇文章我们介绍了创建定时任务的几种方式，创建定时任务的几种方式，你还不会？介绍了在分布式环境下使用quartz框架创建定时任务调度，但是这种方式有明显的弊端，虽然Quartz可以基于数据库实现作业的高可用，但缺少分布式并行调度的功能，且没有解决任务分片的问题，不能实现水平扩展。不适合大型分布式项目使用。

本篇文章向大家介绍一下在分布式环境中的另一种创建方式，使用xxl-job框架创建定时任务调度。如果对你有帮助的话，还不忘点赞转发支持一下，感谢！文末附有源码

目录

• 一、xxl-job简介
• 二、使用步骤
• 三、总结

一、xxl-job简介

1、xxl-job

xxl-job是一个轻量级分布式任务调度框架 。其核心设计目标是开发迅速、学习简单、轻量级、易扩展，主要分为调度中心和执行器两部分，调度中心在启动初始化的时候，会默认生成执行器的RPC代理对象（http协议调用）， 执行器项目启动之后，调度中心在触发定时器之后通过jobHandle来调用执行器项目里面的代码。

优点：轻量级，支持集群部署，有完整的图形管理界面，支持弹性扩容、分布广播、故障转移等等高级功能。

缺点：调度中心通过获取DB锁来保证集群中执行任务的唯一性，如果短任务很多，随着调度中心集群数量的增加，那么数据库的锁竞争加大，导致性能下降。

二、使用步骤

1、下载源码导入

Github下载地址：https://github.com/xuxueli/xxl-job/
Gitee下载地址：https://gitee.com/xuxueli0323/xxl-job

2、执行sql

执行db下的sql脚本

3、修改xxl-job-admin项目配置

修改admin项目的数据库配置，改成自己的数据库连接，默认的端口号是8080，也可以修改合适的端口号，我把端口改成了8002。

4、启动admin项目

访问 http://localhost:8002/xxl-job-admin/

账号密码：admin / 123456

至此，任务调度中心就搭建好了。

5、自建一个任务示例demo项目

5.1 添加pom依赖

创建一个SpringBoot项目，添加xxl-job依赖

<!-- xxl-job-core  版本号根据自己下载的版本修改 -->
<dependency>
	<groupId>com.xuxueli</groupId>
	<artifactId>xxl-job-core</artifactId>
	<version>2.3.0</version>
</dependency>

5.2 日志配置

添加日志配置文件

<?xml version="1.0" encoding="UTF-8"?>
<configuration debug="false" scan="true" scanPeriod="1 seconds">

    <contextName>logback</contextName>
    <property name="log.path" value="/data/applogs/xxl-job/xxl-job-admin.log"/>

    <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
        <encoder>
            <pattern>%d{HH:mm:ss.SSS} %contextName [%thread] %-5level %logger{36} - %msg%n</pattern>
        </encoder>
    </appender>

    <appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>${log.path}</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <fileNamePattern>${log.path}.%d{yyyy-MM-dd}.zip</fileNamePattern>
        </rollingPolicy>
        <encoder>
            <pattern>%date %level [%thread] %logger{36} [%file : %line] %msg%n
            </pattern>
        </encoder>
    </appender>

    <root level="info">
        <appender-ref ref="console"/>
        <appender-ref ref="file"/>
    </root>

</configuration>

5.3 properties文件修改

application.properties 加入配置

需修改或自定义
xxl-job admin 地址
xxl.job.executor.appname 自定义名称，后台配置必须对应
xxl.job.executor.ip 当前电脑Ip，或部署项目的电脑Ip
xxl.job.executor.port 端口

# 端口号
server.port=8081
# 日志
logging.config=classpath:logback.xml

### xxl-job admin 地址，多个逗号分隔"
xxl.job.admin.addresses=http://127.0.0.1:8002/xxl-job-admin

### xxl-job名称 || socket ip 当前项目部署的ip地址/本机ip || socket 端口号
xxl.job.executor.appname=xxl-job-executor-demo
xxl.job.executor.ip=127.0.0.1
xxl.job.executor.port=9999

### xxl-job, access token
xxl.job.accessToken=
### xxl-job log path
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
### xxl-job log retention days
xxl.job.executor.logretentiondays=-1

5.4 添加pom依赖

@Configuration
public class XxlJobConfig {

    Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);

    @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.accessToken}")
    private String accessToken;

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

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


    @Bean(initMethod = "start", destroyMethod = "destroy")
    public XxlJobSpringExecutor xxlJobExecutor() {
        logger.info(">>>>>>>>>>> xxl-job xxljob.config init.");
        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);
        logger.info(ip+":"+port);
        return xxlJobSpringExecutor;
    }
}

5.5 添加pom依赖

@Component
public class DemoJobHandler {

    static int count = 0;

    @XxlJob("demoJobHandler")
    public void execute(String param) throws Exception {
        System.out.println("hello,demoJobHandler执行job任务"+ count++);
    }
}

6、admin后台配置

打开admin后台管理界面，进行相关任务配置。
先新增一个执行器

在任务管理里新建一个任务，配置对应要执行的时间策略。我配置的是一个每5秒执行一次的策略。

配置完成后，点击启动

可以在示例demo项目的控制台成功输出job被执行的日志，大功告成。

结语

好了，以上就是今天要讲的内容，本文介绍了使用分布式任务调度平台xxl-job创建任务调度的实践。感谢大家的阅读，喜欢的朋友，欢迎点赞转发支持一下。