文章目录

  • 项目模块介绍
  • 架构思想
  • 部署项目
    • 后台管理部署
      • 执行器管理
      • 任务管理
    • 部署执行器(需要集成到任务代码的项目中)

源码下载地址
https://gitee.com/xuxueli0323/xxl-job
xxl开元社区地址
https://www.xuxueli.com/page/projects.html

项目模块介绍

架构思想

admin后台负责管理执行器和定时任务的增删改查,执行器管理会保存执行器的地址,可以自动录入,即执行器启动时会自动向后台注册,也可以手动录入
执行器即具体的逻辑代码部分,需要引入核心代码依赖,且需要把任务代码逻辑的类放入spring容器,执行器配置会保存后台的地址,

部署项目

后台管理部署

xxl-job-admin模块打包成jar包启动即可
application.properties配置文件解释

### web 端口号和项目根目录
server.port=8080
server.servlet.context-path=/xxl-job-admin
### 调度中心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=xxx@qq.com
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

调度中心访问地址:http://localhost:8080/xxl-job-admin (该地址执行器将会使用到,作为回调地址)
默认登录账号 “admin/123456”, 登录后运行界面如下图所示,修改密码代码DigestUtils.md5DigestAsHex(xxlJobUser.getPassword().getBytes())

执行器管理

新增配置解读

  • AppName: 为下面执行器配置的xxl.job.executor.appname
  • 名称: 随意
  • 注册方式 : 可以自动,也可以手动
  • 机器地址: 执行器的地址,如果自动没有注册到,就改改为手动填写http://127.0.0.1:9999/,ip和端口分别对应下面执行器配置的xxl.job.executor.ip和xxl.job.executor.port

任务管理

  • 执行器: 即执行器管理添加的执行器
  • 任务描述、负责人、报警邮件等:根据需要填写
  • 调度类型:选CRON接口
  • Cron:定时任务的七子表达式
  • 运行模式:选择BEAN即可,任务以JobHandler方式维护在执行器端;需要结合 “JobHandler” 属性匹配执行器中任务;
  • JobHandler: 任务执行逻辑,下面执行器中执行类的@XxlJob(“testQuartz”)注解的值testQuartz

部署执行器(需要集成到任务代码的项目中)

需要引入依赖

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

需要添加的配置文件内容

### 调度中心部署跟地址 [选填]:如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调";为空则关闭自动注册;
xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin
### 执行器通讯TOKEN [选填]:非空时启用, 如果非空需要和后台的一致;
xxl.job.accessToken=
### 执行器AppName [选填]:执行器心跳注册分组依据;为空则关闭自动注册
xxl.job.executor.appname=xxl-job-executor-sample
### 执行器注册 [选填]:优先使用该配置作为注册地址,为空时使用内嵌服务 ”IP:PORT“ 作为注册地址。从而更灵活的支持容器类型执行器动态IP和动态映射端口问题。
xxl.job.executor.address=http://localhost:8080/xxl-job-admin
### 执行器IP [选填]:默认为空表示自动获取IP,多网卡时可手动设置指定IP,该IP不会绑定Host仅作为通讯实用;地址信息用于 "执行器注册" 和 "调度中心请求并触发任务";
xxl.job.executor.ip=
### 执行器端口号 [选填]:小于等于0则自动获取;默认端口为9999,单机部署多个执行器时,注意要配置不同执行器端口;
xxl.job.executor.port=9999
### 执行器运行日志文件存储磁盘路径 [选填] :需要对该路径拥有读写权限;为空则使用默认路径;
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
### 执行器日志文件保存天数 [选填] : 过期日志自动清理, 限制值大于等于3时生效; 否则, 如-1, 关闭自动清理功能;
xxl.job.executor.logretentiondays=30

配置类

packa quartz;import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class XxlJobConfig {private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);@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;@Beanpublic XxlJobSpringExecutor xxlJobExecutor() {logger.info(">>>>>>>>>>> xxl-job config init.");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;}
}

定时任务代码逻辑类

package quartz;import com.xxl.job.core.handler.annotation.XxlJob;
import org.springframework.stereotype.Component;@Component
public class ExecutorTest {@XxlJob("testQuartz")  // 值为在后台新增定时任务时的JobHandlerpublic void testQuartz(){String jobParam = XxlJobHelper.getJobParam();  // 获取任务参数System.out.println("执行的定时任务");}
}

xxlJob的简单使用相关推荐

  1. xxl-job 定时任务简单使用

    相关博文连接:https://blog.csdn.net/jzx937345232/article/details/99292049 由于之前一直使用的是Quartz实现定时任务,本次项目中使用了xx ...

  2. 分布式任务调度平台XXL-JOB的简单使用

    推荐使用xxl2.2.0版本 参考地址: 分布式任务调度平台XXL-JOB xxl-job安装到本地打开项目工程对yml配置文件进行修改 主要修改数据库地址和告警邮件地址 将服务注册到xxl-job ...

  3. 3千字带你搞懂XXL-JOB任务调度平台

    思维导图 文章已收录Github精选,欢迎Star:https://github.com/yehongzhi/learningSummary 一.概述 在平时的业务场景中,经常有一些场景需要使用定时任 ...

  4. hadoop 依赖式job_每天一学:一个轻量级分布式任务调度框架 XXL-JOB

    概述 XXL-JOB是一个轻量级分布式任务调度平台,其核心设计目标是开发迅速.学习简单.轻量级.易扩展.现已开放源代码并接入多家公司线上产品线,开箱即用. 官方地址中文版:http://www.xux ...

  5. 调度失败:执行器地址为空_三千字带你搞懂XXL-JOB任务调度平台

    思维导图 文章已收录Github精选,欢迎Star:https://github.com/yehongzhi/learningSummary 一.概述 在平时的业务场景中,经常有一些场景需要使用定时任 ...

  6. xxljob默认登录_三千字带你搞懂XXL-JOB任务调度平台

    思维导图 文章已收录Github精选,欢迎Star:https://github.com/yehongzhi/learningSummary 一.概述 在平时的业务场景中,经常有一些场景需要使用定时任 ...

  7. XXL-Job 分布式任务调度(一)本地执行

    1.概述 1.1 什么是任务调度 我们可以考虑一下业务场景的解决方案: 某电商系统需要在每天的上午10点,下午3点,晚上8点发放一批优惠券. 某银行系统需要在信用卡到期日的三天进行短信提醒,每天早上8 ...

  8. 数据拉取之xxl-job+工厂模式+token实现拉取(三)

    xxl-job+工厂模式+token实现拉取(三) 目录 前言 整体设计 xxl-job说明 表设计 工厂模式设计 码上有戏 核心代码 测试 简单说明 源码地址 目录 前言 通过前面总结我们知道,已经 ...

  9. 开关配置springboot定时任务

    题外话 这是我第五篇原创文章,计划写定时任务内容,想想只要打开自己的有道云笔记,复制粘贴,整理排版一下就能轻松搞定了,这样做有意义吗?自己写文章的价值点是什么呢?考虑了很长时间,主要希望做到一下几点: ...

最新文章

  1. CVPR 2021 论文大盘点-行人技术篇
  2. 区块链在天猫国际商品溯源中的应用
  3. Android3个页面跳转代码,从零开始Android组件化改造(三) - 页面跳转与路由组件...
  4. 解决eclipse + pydev 编译过程中有中文的问题
  5. LeetCode 942. 增减字符串匹配
  6. java kafka 拉取_java获取kafka consumer lag
  7. golang 面向接口编程
  8. java 时间 转化成数字_java时间转化数字
  9. 代码校验工具 SublimeLinter 的安装与使用
  10. 初学者,学哪一种3d模型设计软件比较好?
  11. 【java复习笔记】总目录
  12. spring cloud学习-什么是Spring Cloud Eureka?
  13. 从返利网站看如何经营用户
  14. python机器学习之回归预测:电池续航里程问题
  15. 数据存储- 存储文件概述
  16. 在IE中打开或下载文件
  17. 江苏计算机一级证书考试试题,2016年江苏省计算机一级考试试题
  18. Navicat导出ncx解析数据库密码
  19. Imagine Cup 2013
  20. USB 中MTP和UMS 模式

热门文章

  1. linux安装系统修改u盘盘符,U盘安装Centos系统时,如何快速确认U盘盘符
  2. 高德地图, 点聚合效果,以及给点添加点击事件
  3. Jquery文档处理操作
  4. 使用maven来进行JavaSE增删改查
  5. 怎么屏蔽还有照片_你的朋友圈屏蔽了谁?
  6. 深圳市公租房申请流程
  7. 手机关闭java 功能吗,关闭手机这几个功能,马上省电80%!很多人不知道
  8. JavaScript:简单实现弹出窗口div
  9. 关于SUID SGID
  10. vue ajax如何设置同步,vue axios同步请求解决方案