xxl-job环境搭建
文章目录
- xxl-job 快速上手
- 1、下载release版本的源码
- 2、打开项目
- 3、初始化数据库
- 4、配置代码工程
- 4.1、调度器xxl-job-admin工程调整
- 4.2 创建执行器
- 引入xxl-job-core依赖
- 在application.properties中新增配置
- 4.3、在页面上添加注册好的执行器
xxl-job 快速上手
xxl-job 源码地址 https://github.com/xuxueli/xxl-job
Xxl-job 中文文档 https://www.xuxueli.com/xxl-job/
1、下载release版本的源码
git clone https://github.com/xuxueli/xxl-job.git
2、打开项目
- /doc 文档资料 包括"调度数据库" 建表脚本
- /xxl-job-core 公共jar依赖
- /xxl-job-admin 调度中心的源代码 是SpringBoot项目 可以直接启动
- /xxl-job-executor-samples 执行器示例代码 包含了基于spring、springboot、jfinal等环境的示例代码。可以直接基于示例代码开发
3、初始化数据库
数据库脚本在doc/db目录下
CREATE database if NOT EXISTS `xxl_job` default character set utf8mb4 collate utf8mb4_unicode_ci;
use `xxl_job`;SET NAMES utf8mb4;CREATE TABLE `xxl_job_info` (`id` int(11) NOT NULL AUTO_INCREMENT,`job_group` int(11) NOT NULL COMMENT '执行器主键ID',`job_cron` varchar(128) NOT NULL COMMENT '任务执行CRON',`job_desc` varchar(255) NOT NULL,`add_time` datetime DEFAULT NULL,`update_time` datetime DEFAULT NULL,`author` varchar(64) DEFAULT NULL COMMENT '作者',`alarm_email` varchar(255) DEFAULT NULL COMMENT '报警邮件',`executor_route_strategy` varchar(50) DEFAULT NULL COMMENT '执行器路由策略',`executor_handler` varchar(255) DEFAULT NULL COMMENT '执行器任务handler',`executor_param` varchar(512) DEFAULT NULL COMMENT '执行器任务参数',`executor_block_strategy` varchar(50) DEFAULT NULL COMMENT '阻塞处理策略',`executor_timeout` int(11) NOT NULL DEFAULT '0' COMMENT '任务执行超时时间,单位秒',`executor_fail_retry_count` int(11) NOT NULL DEFAULT '0' COMMENT '失败重试次数',`glue_type` varchar(50) NOT NULL COMMENT 'GLUE类型',`glue_source` mediumtext COMMENT 'GLUE源代码',`glue_remark` varchar(128) DEFAULT NULL COMMENT 'GLUE备注',`glue_updatetime` datetime DEFAULT NULL COMMENT 'GLUE更新时间',`child_jobid` varchar(255) DEFAULT NULL COMMENT '子任务ID,多个逗号分隔',`trigger_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '调度状态:0-停止,1-运行',`trigger_last_time` bigint(13) NOT NULL DEFAULT '0' COMMENT '上次调度时间',`trigger_next_time` bigint(13) NOT NULL DEFAULT '0' COMMENT '下次调度时间',PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;CREATE TABLE `xxl_job_log` (`id` bigint(20) NOT NULL AUTO_INCREMENT,`job_group` int(11) NOT NULL COMMENT '执行器主键ID',`job_id` int(11) NOT NULL COMMENT '任务,主键ID',`executor_address` varchar(255) DEFAULT NULL COMMENT '执行器地址,本次执行的地址',`executor_handler` varchar(255) DEFAULT NULL COMMENT '执行器任务handler',`executor_param` varchar(512) DEFAULT NULL COMMENT '执行器任务参数',`executor_sharding_param` varchar(20) DEFAULT NULL COMMENT '执行器任务分片参数,格式如 1/2',`executor_fail_retry_count` int(11) NOT NULL DEFAULT '0' COMMENT '失败重试次数',`trigger_time` datetime DEFAULT NULL COMMENT '调度-时间',`trigger_code` int(11) NOT NULL COMMENT '调度-结果',`trigger_msg` text COMMENT '调度-日志',`handle_time` datetime DEFAULT NULL COMMENT '执行-时间',`handle_code` int(11) NOT NULL COMMENT '执行-状态',`handle_msg` text COMMENT '执行-日志',`alarm_status` tinyint(4) NOT NULL DEFAULT '0' COMMENT '告警状态:0-默认、1-无需告警、2-告警成功、3-告警失败',PRIMARY KEY (`id`),KEY `I_trigger_time` (`trigger_time`),KEY `I_handle_code` (`handle_code`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;CREATE TABLE `xxl_job_log_report` (`id` int(11) NOT NULL AUTO_INCREMENT,`trigger_day` datetime DEFAULT NULL COMMENT '调度-时间',`running_count` int(11) NOT NULL DEFAULT '0' COMMENT '运行中-日志数量',`suc_count` int(11) NOT NULL DEFAULT '0' COMMENT '执行成功-日志数量',`fail_count` int(11) NOT NULL DEFAULT '0' COMMENT '执行失败-日志数量',PRIMARY KEY (`id`),UNIQUE KEY `i_trigger_day` (`trigger_day`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;CREATE TABLE `xxl_job_logglue` (`id` int(11) NOT NULL AUTO_INCREMENT,`job_id` int(11) NOT NULL COMMENT '任务,主键ID',`glue_type` varchar(50) DEFAULT NULL COMMENT 'GLUE类型',`glue_source` mediumtext COMMENT 'GLUE源代码',`glue_remark` varchar(128) NOT NULL COMMENT 'GLUE备注',`add_time` datetime DEFAULT NULL,`update_time` datetime DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;CREATE TABLE `xxl_job_registry` (`id` int(11) NOT NULL AUTO_INCREMENT,`registry_group` varchar(50) NOT NULL,`registry_key` varchar(255) NOT NULL,`registry_value` varchar(255) NOT NULL,`update_time` datetime DEFAULT NULL,PRIMARY KEY (`id`),KEY `i_g_k_v` (`registry_group`,`registry_key`,`registry_value`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;CREATE TABLE `xxl_job_group` (`id` int(11) NOT NULL AUTO_INCREMENT,`app_name` varchar(64) NOT NULL COMMENT '执行器AppName',`title` varchar(12) NOT NULL COMMENT '执行器名称',`address_type` tinyint(4) NOT NULL DEFAULT '0' COMMENT '执行器地址类型:0=自动注册、1=手动录入',`address_list` varchar(512) DEFAULT NULL COMMENT '执行器地址列表,多地址逗号分隔',PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;CREATE TABLE `xxl_job_user` (`id` int(11) NOT NULL AUTO_INCREMENT,`username` varchar(50) NOT NULL COMMENT '账号',`password` varchar(50) NOT NULL COMMENT '密码',`role` tinyint(4) NOT NULL COMMENT '角色:0-普通用户、1-管理员',`permission` varchar(255) DEFAULT NULL COMMENT '权限:执行器ID列表,多个逗号分割',PRIMARY KEY (`id`),UNIQUE KEY `i_username` (`username`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;CREATE TABLE `xxl_job_lock` (`lock_name` varchar(50) NOT NULL COMMENT '锁名称',PRIMARY KEY (`lock_name`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;INSERT INTO `xxl_job_group`(`id`, `app_name`, `title`, `address_type`, `address_list`) VALUES (1, 'xxl-job-executor-sample', '示例执行器', 0, NULL);
INSERT INTO `xxl_job_info`(`id`, `job_group`, `job_cron`, `job_desc`, `add_time`, `update_time`, `author`, `alarm_email`, `executor_route_strategy`, `executor_handler`, `executor_param`, `executor_block_strategy`, `executor_timeout`, `executor_fail_retry_count`, `glue_type`, `glue_source`, `glue_remark`, `glue_updatetime`, `child_jobid`) VALUES (1, 1, '0 0 0 * * ? *', '测试任务1', '2018-11-03 22:21:31', '2018-11-03 22:21:31', 'XXL', '', 'FIRST', 'demoJobHandler', '', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', '2018-11-03 22:21:31', '');
INSERT INTO `xxl_job_user`(`id`, `username`, `password`, `role`, `permission`) VALUES (1, 'admin', 'e10adc3949ba59abbe56e057f20f883e', 1, NULL);
INSERT INTO `xxl_job_lock` ( `lock_name`) VALUES ( 'schedule_lock');commit;
执行以上脚本即可在本地环境创建一个基于xxl-job数据库
对生成的表进行说明
表名 | 说明 |
---|---|
xxl_job_info | 调度扩展信息表,用于保存xxl-job调度任务的扩展信息,如任务分组、任务名、机器地址、执行器、执行入参和报警邮件等 |
xxl_job_log | 调度日志表:用于保存xxl-job任务调度的历史信息,如调度结果、执行结果、调度入参、执行器等 |
xxl_job_log_report | 调度日志报表,用户存储xxl-job任务调度日志的报表,调度中心报表功能页面会用到 |
xxl_job_logglue | 任务GLUE日志,用于保存GLUE更新历史,用于支持GLUE的版本回溯功能 |
xxl_job_registry | 执行器注册表,维护在线的执行器和调度中心机器地址信息 |
xxl_job_group | 执行器信息表,维护任务执行器信息 |
xxl_job_user | 系统用户表 |
xxl_job_lock | 任务调度锁表 |
4、配置代码工程
xxl-job的调度器和执行器可以是分开的,调度器决定任务的调度,并且通过HTTP的方式调用执行器接口执行任务
所以这里打算 调度器就使用示例代码xxl-job-admin模块,而执行器我们新起一个工程
我们先配置至少一个调度中心,运行起来 也可以集群部署,然后再配置至少一个执行器,运行起来,同样可以集群部署
4.1、调度器xxl-job-admin工程调整
修改数据源配置文件、将xxl-job默认用户名、密码添加上(已经在创建表时 创建了。用户名、密码: admin/123456)
### web
server.port=28080
server.servlet.context-path=/xxl-job-admin### xxl-job, datasource
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
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driverxxl.job.login.username=admin
xxl.job.login.password=123456
修改logback.xml 日志输出位置 这个可依据个人情况而定
<property name="log.path" value="/Users/wojiushiwo/my-xxl-job/logs/xxl-job-admin.log"/>
随后 启动 工程 ,在浏览器上输入http://localhost:28080/xxl-job-admin
输入用户名、密码 进入
4.2 创建执行器
执行器负责任务的具体执行,分配线程执行任务。执行器需要注册到调度中心,这样调度器才知道怎么选择执行器。执行器的执行结果也需要通过回调的方式通知调度器
引入xxl-job-core依赖
<dependency><groupId>com.xuxueli</groupId><artifactId>xxl-job-core</artifactId><version>2.2.0</version></dependency>
在application.properties中新增配置
server.port=${random.int[30000,39999]}
xxl.job.admin.addresses=http://127.0.0.1:28080/xxl-job-admin
xxl.job.executor.address=
## 执行器名字
xxl.job.executor.appname=xxl-job-executor
xxl.job.executor.ip=
xxl.job.executor.port=${random.int[40000,49999]}
xxl.job.executor.logpath=/Users/wojiushiwo/spring/my-xxl-job/logs/jobhandler
xxl.job.executor.logretentiondays=30
注意:xxl.job.admin.addresses 这里指代的是调度器的地址 一定要与调度器配置的端口和context-path一致
之所以应用端口、执行器端口是随机端口,是为了使用这一个项目 模拟多个执行器
启动两个执行器应用工程
观察xxl_job_registry表发现,我们的两个执行器已经添加上去了
说明我们的执行器项目运行正常。
4.3、在页面上添加注册好的执行器
新增执行器
注意:这里的AppName要跟在执行器配置文件中xxl.job.executor.appname的值一样(其实这是为了查找执行器注册地址,这个后面说)
添加完成
会看到xxl-job-executor这一栏的Online机器地址是无,不用着急,刷新下页面 即可出现
因为xxl-job-admin里 有个线程会每隔30s去刷新执行器机器地址
FAQ:为什么Appname要跟配置中名称一致呢?
原因就是这个线程会去查询xxl-job-registry
表,获取执行器注册信息,并与填入的Appname对比,匹配成功的话 就将机器地址保存下来,存储到xxl-job-group
表。
下面看一下 xxl-job-group表数据
xxl-job环境搭建相关推荐
- Anaconda3+python3.7.10+TensorFlow2.3.0+PyQt5环境搭建
Anaconda3+python3.7.10+TensorFlow2.3.0+PyQt5环境搭建 一.Anaconda 创建 python3.7环境 1.进入 C:\Users\用户名 目录下,找到 ...
- Windows10+Anaconda3+Pycharm环境搭建
Windows10+Anaconda3+Pycharm环境搭建 一.安装Anaconda3 1.进入 anconda官网,下载Anaconda3 2.安装,选项默认继续安装(可以自行更改安装位置),等 ...
- SpringCloud Alibaba微服务实战(一) - 基础环境搭建
说在前面 Spring Cloud Alibaba 致力于提供微服务开发的一站式解决方案.此项目包含开发分布式应用微服务的必需组件,方便开发者通过 Spring Cloud 编程模型轻松使用这些组件来 ...
- 2021年大数据环境搭建(二):分布式环境搭建
2021大数据领域优质创作博客,带你从入门到精通,该博客每天更新,逐渐完善大数据各个知识体系的文章,帮助大家更高效学习. 有对大数据感兴趣的可以关注微信公众号:三帮大数据 目录 分布式环境搭建 集群规 ...
- 2021年大数据Spark(八):环境搭建集群模式 Standalone HA
环境搭建-Standalone HA 高可用HA Spark Standalone集群是Master-Slaves架构的集群模式,和大部分的Master-Slaves结构集群一样,存在着Master单 ...
- 2021年大数据Spark(六):环境搭建集群模式 Standalone
目录 环境搭建-Standalone 前言 Standalone 架构 集群规划 修改配置并分发 修改slaves 分发到其他机器 修改spark-env.sh 集群启动和 ...
- CentOS7环境搭建使用PhpStorm上传代码
一.虚拟机介绍 虚拟机(Virtual Machine)指通过软件模拟的具有完整硬件系统功能的.运行在一个完全隔离环境中的完整计算机系统. 虚拟系统通过生成现有操作系统的全新虚拟镜像,它具有真实win ...
- window10 系统上 ecplise 环境搭建
ecplise 安装需要用到 JDK 环境的搭建以及ecplise 的下载 这两部完成即可 一: JDK环境搭建 到官网上下载JDK并且安装即可(下载的时候注意选择Accept License Ag ...
- centOS7 LNMP+phpmyadmin环境搭建 第三篇phpmyadmin安装
这篇文章主要介绍了CentOS7 LNMP+phpmyadmin环境搭建,第三篇phpmyadmin安装,具有一定的参考价值,感兴趣的小伙伴们可以参考一下 之前我们已经安装了lnmp的环境,现在让我们 ...
- Android环境搭建和Android HelloWorld—Android开发环境搭建
Android_Android开发环境搭建-搭建Android的开发环境 1.我考虑先下载JDK7.0,在JDK的安装中,考虑一般SDK都是向上兼容的,于是选择了最高的版本7.0 这里是我总结的详细的 ...
最新文章
- linux驱动:音频驱动(七)交叉编译alsa库及工具集alsa-utils
- 第十六章、Raid及mdadm命令
- Python爬虫初学(三)—— 模拟登录知乎
- 今晚直播 | 高效视频理解模型的设计及ICCV比赛冠军方案解读
- 处理字符串_9_合并多行到一行
- semaphore的使用
- 基于模板的文字识别结果结构化处理技术
- 分析设计网上书店数据库,并画E-R图
- java迭代器不能修改集合值_关于使用迭代器对集合进行遍历时,不能对集合进行修改的论证...
- TcpTrace实现的基本原理
- jsonp和ajax的区别,dataType jsonp和JSON之间的区别
- wincc中c语言做变量自增,在WinCC中如何利用C动作实现变量自动加1-工业支持中心-西门子中国...
- mysql好玩的代码_MySQL常用命令(1)
- 虚拟机是ubuntu,windows映射盘符方式访问虚拟机
- C++:字符(串)输入和输出
- 深入分析 Spring 基于注解的 AOP 实现原理
- layabox2.0 开发微信小游戏经验分享
- 桌面运维之windows部分常用命令
- Docker学习笔记1-初识Docker
- GEF原理及实现系列(一、GEF概述)