xxl-job 任务调度搭建及简单使用

  xxl-job是开源架构，可以通过它实现调度中心和执行器。 git地址和 官网中进行了详细的技术说明。
  xxl-job支持单机部署和集群式部署，在集群式部署中又可以实现调度中心集群式部署和执行器集群式部署。本文主要针对调度中心和执行器分离单机部署方式进行说明。

简介

  xxl-job中存在调度中心和执行器两个概念，其中调度中心负责定时调度，执行器负责具体的执行工作。调度中心本质上就是一个spring boot项目。在使用xxl-job时在调度中心配置调度规则及执行内容，然后再在执行器中实现具体的执行作业。
  本demo中在调度中心配置每隔一分钟执行一次，执行的具体内容为调用某个service的方法，在执行其中需要实现service的具体方法。

调度中心搭建

  调度中心的搭建可以分为四部分进行分别是：

• 数据库创建
• 配置文件编写
• docker容器启动
• 启动测试
  下面将针对上述四个过程中进行详细说明。

数据库创建

  数据库创建SQL文件可以通过git查找，位于\xxl-job-master\doc\db路径下，可以在mysql中创建一个数据库然后执行该SQL文件实现数据库表结构及基础数据的初始化。

配置文件编写

  通过查看xxl-job-admin项目的pom文件包含以下内容：

		<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency>

  可知调度中心本质上就是一个springboot项目。其docker构建文件如下：

FROM openjdk:8-jre-slim
MAINTAINER xuxueli
ENV PARAMS=""
ENV TZ=PRC
RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo $TZ > /etc/timezone
ADD target/xxl-job-admin-*.jar /app.jar
ENTRYPOINT ["sh","-c","java -jar $JAVA_OPTS /app.jar $PARAMS"]

  可通过-e PARAMS设置docker启动命令中调度中心的执行参数。既然调度中心本质上一个spring boot程序，因此可以配置该程序运行的配置文件，即application.properties文件。根据官网指出xxl-job提供了以下特有配置内容：

### 调度中心JDBC链接：链接地址请保持和 2.1章节 所创建的调度数据库的地址一致
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=root_pwd
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
### 报警邮箱
spring.mail.host=smtp.qq.com
spring.mail.port=25
spring.mail.username=[e-mail]
spring.mail.password=xxx
spring.mail.properties.mail.smtp.auth=true
spring.mail.properties.mail.smtp.starttls.enable=true
spring.mail.properties.mail.smtp.starttls.required=true
spring.mail.properties.mail.smtp.socketFactory.class=javax.net.ssl.SSLSocketFactory
### 调度中心通讯TOKEN [选填]：非空时启用；
xxl.job.accessToken=
### 调度中心国际化配置 [必填]： 默认为 "zh_CN"/中文简体, 可选范围为 "zh_CN"/中文简体, "zh_TC"/中文繁体 and "en"/英文；
xxl.job.i18n=zh_CN
## 调度线程池最大线程配置【必填】
xxl.job.triggerpool.fast.max=200
xxl.job.triggerpool.slow.max=100
### 调度中心日志表数据保存天数 [必填]：过期日志自动清理；限制大于等于7时生效，否则, 如-1，关闭自动清理功能；
xxl.job.logretentiondays=30

  除此之外我们还可以进行spring boot的启动项配置，如下设置启动使用数据库连接内容：

### xxl-job, datasource
spring.datasource.url=jdbc:mysql://mysql:3306/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=password
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

docker容器启动

  在docker启动的过程中我们主要需要注意的点有以下内容：

• 指定配置文件
• 端口映射
• 网络配置

  由于spring boot启动可以指定配置文件，在进行docker部署调度中心时需要配置数据库连接、token等相关内容，因此我们需要实现自己的配置文件，可以通过文件卷挂载+ -e配置变量的形式实现进行配置文件自定义。
  spring boot web项目启动的端口默认是8080，使用docker部署需要将容器内端口映射出来。
  此外，由于xxl-job-admin调度中心需要使用到数据库，因此我们需要将调度中心容器和mysql容器实现网络通信，为方便两个容器之间的通信，将MySQL容器和调度中心容器放到同一网络下，因此需要配置–net参数。
  部署命令如下：

docker run -d --net=nacos-mysql --name=xxl-job-admin -p 8081:8080 -v D:\docker\xxl-job\application.properties:/application.properties  -e PARAMS='--spring.config.location=/application.properties' xuxueli/xxl-job-admin:2.4.0

注意：需要将mysql容器也放到nacos-mysql网络下，并且创建数据库。调度中心的容器创建过程中必须指定版本号，不能使用last进行获取。

启动测试

进行管理员客户端访问。

http://localhost:8081/xxl-job-admin/
用户名：admin
密码：123456

运行界面如下：

执行器搭建

依赖引入

  执行器实际就是执行任务的具体程序，在实现执行器搭建的过程中需要在项目中引入：

  		<!-- xxl-job-core --><dependency><groupId>com.xuxueli</groupId><artifactId>xxl-job-core</artifactId><version>2.4.0</version></dependency><!-- 作为一个spring cloud项目，使用openfeign进行api调用具体的服务-->

配置

@Configuration
public class XxlJobConfig {@Beanpublic XxlJobSpringExecutor xxlJobExecutor() {XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();// 调度中心urlxxlJobSpringExecutor.setAdminAddresses("http://127.0.0.1:8081/xxl-job-admin");// 执行器名称xxlJobSpringExecutor.setAppname("imos-job");
//        xxlJobSpringExecutor.setAddress("");
//        xxlJobSpringExecutor.setIp("192.168.1.56");
//        xxlJobSpringExecutor.setPort(7999);// token，该配置必须和调度中心的配置文件总的token配置一致xxlJobSpringExecutor.setAccessToken("default_token");
//        xxlJobSpringExecutor.setLogPath(logPath);
//        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);return xxlJobSpringExecutor;}
}

  通过以上操作及完成了执行器的搭建过程，可以将执行器理解为一个spring 项目，在里面编写我们具体的业务代码即可。
  在本demo中执行器将通过openfeign调用其他微服务的相关接口实现定时任务，因此pom文件中还需要引入其他相关依赖。
  在执行器的搭建过程中，我们发现除了引入job-core依赖配置bean之外，并没有为执行器做什么其他相关配置，执行器某个业务的定时执行是由调度中心进行配置的，执行器本身并没有定时配置，简单来讲，执行器仅给调度中心提供原料和执行的作用。
  本demo的实现采用glue模式进行实现，该模式下，使用者在调度中心编写java代码，java代码中可以通过@autowire的形式引入执行器定义的service，因此可以理解为执行器为调度中心提供原料。待定时任务执行时，调度中心其实是将java代码发送给执行器，执行器接受到代码后通过反射等形式进行执行代码。

使用说明

运行调度中心

  启动调度中心docker容器，登录调度中心管理界面，并添加一个执行器，该执行器名称和我们执行器中设定的名称需要一致，注册方式选择自动注入即可：

运行执行器

  运行执行器后，OnLine 机器地址应该存在一组ip字段。如下图
## 新增任务
  在调度中心中新增任务并选择glue模式，如下图

编写任务代码

  在任务管理列表中点击操作进入GULE模式，进行java代码编写：

  在编写代码的过程中可以引入执行器中存在的service或者new执行器中的对象，需要注意的是在使用执行器的类或者方法的过程中需要import相关类，类的全限定名和执行器中需要严格保持一致。

执行

  在任务管理操作进行执行任务，执行器将执行该代码并在控制台展示相关内容如下图：