XXL-JOB 任务调度平台实践

• 一、调度中心(服务端)
• • 1、从gitbub 获取项目源码：[https://github.com/xuxueli/xxl-job](https://github.com/xuxueli/xxl-job)
  • 2、从源码中得到SQL脚本创建和初始化数据库
  • 3、Maven 编译打包 xxl-job-admin 并部署为调度中心
  • 4、启动运行 xxl-job-admin，并访问 http://localhost:8080/xxl-job-admin
• 二、开发XXL-JOB执行器(客户端)
• • 1、创建一个新项目（New Module）
  • 2、配置任务调度中心
  • • ①新增执行器:
    • ②新增任务管理:
    • ③查看调度日记

连接视频

一、调度中心(服务端)

1、从gitbub 获取项目源码：https://github.com/xuxueli/xxl-job

修改 xxl-job项目的配置文件【application.properties】，修改数据库连接为自己的数据库，修改发送邮件配置

### xxl-job, access token #设置访问xxl-job的token设值
xxl.job.accessToken=123456

2、从源码中得到SQL脚本创建和初始化数据库

sql文件位置：

3、Maven 编译打包 xxl-job-admin 并部署为调度中心

4、启动运行 xxl-job-admin，并访问 http://localhost:8080/xxl-job-admin

默认用户名：admin 密码：123456

二、开发XXL-JOB执行器(客户端)

1、创建一个新项目（New Module）

客户端（spring-xxl-job）

pom.xml文件

4.0.0com.zzpspring-xxl-job1.0.0war88com.xuxuelixxl-job-core2.2.0org.springframeworkspring-webmvc5.2.6.RELEASE

拷贝xxl-job-executor.properties配置文件在在resources目录下【参考xxl-job-executor-samples目录下的xxl-job-executor-sample-spring项目的xxl-job-executor.properties配置文件】

xxl-job-executor.properties文件

### xxl-job admin address list, such as "http://address" or "http://address01,http://address02"
# 连接哪个服务中心
xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin ### xxl-job, access token
# 和服务端设置的配置accessToken保持一致
xxl.job.accessToken=123456### xxl-job executor appname
# 执行器的名字
xxl.job.executor.appname=spring-xxl-job
### xxl-job executor registry-address: default use address to registry , otherwise use ip:port if address is null
# 执行器的地址
xxl.job.executor.address=
### xxl-job executor server-info
# 执行器的ip（客户端的ip）
xxl.job.executor.ip=127.0.0.1
# 执行器的端口（客户端的端口）
xxl.job.executor.port=9999
### xxl-job executor log-path
# 日记存储地址
xxl.job.executor.logpath=F:/xxl-job/log
### xxl-job executor log-retention-days
# 日记存储有效天数
xxl.job.executor.logretentiondays=30

在resources目录下添加applicationContext.xml配置文件【参考xxl-job-executor-samples目录下的xxl-job-executor-sample-spring项目的applicationcontext-xxl-job.xml配置文件】

applicationContext.xml文件

classpath*:xxl-job-executor.properties

创建MyJobHandler类【参考xxl-job-executor-samples目录下的xxl-job-executor-sample-spring项目的SampleXxlJob.java类】

MyJobHandler.java类

package com.zzp.executor;import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;
import org.springframework.stereotype.Component;import java.text.SimpleDateFormat;
import java.util.Date;/*** 此类就是真正的定时任务业务处理类（Bean模式）** 也就是真正的定时任务功能逻辑在此类中完成（比如：定时对账，定时发送短信，定时清理）** 开发步骤：*  1、在Spring Bean实例中，开发Job方法，方式格式要求为 "public ReturnT execute(String param)"*  2、为Job方法添加注解 "@XxlJob(value="自定义jobhandler名称", init = "JobHandler初始化方法", destroy = "JobHandler销毁方法")"，注解value值对应的是调度中心新建任务的JobHandler属性的值。*  3、执行日志：需要通过 "XxlJobLogger.log" 打印执行日志；**/
@Component
public class MyJobHandler {private  SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");/*** 1、简单任务示例（Bean模式）*/@XxlJob(value = "myJobHandler")public ReturnT myJobHandler(String param) throws Exception {//在改方法里面编写真正的定时任务功能逻辑 比如：定时对账，定时发送短信，定时清理XxlJobLogger.log("XXL-JOB, myJobHandler start:" + sdf.format(new Date()));XxlJobLogger.log("XXL-JOB, myJobHandler param:" + param);return ReturnT.SUCCESS;}}

因为spring-xxl-job是web项目，需要web【拷贝xxl-job-executor-samples目录下的xxl-job-executor-sample-spring项目的web文件夹】

修改web.xml配置文件

spring-xxl-jobwebAppRootKeyspring-xxl-jobcontextConfigLocationclasspath*:applicationContext.xmlorg.springframework.web.context.ContextLoaderListenerindex.html

打包：

使用Tomcat启动spring-xxl-job项目

浏览器访问：

2、配置任务调度中心

①新增执行器:

②新增任务管理:

启动任务

③查看调度日记

这里失败，因为在执行器设值错误了

执行成功日记：

文件日记输出：