文成网站建设,重庆交通建设监理协会网站,网站建设需要哪些工具与知识,做钢材的网站有哪些SpringBoot集成xxl-job实现
一、xxl-job介绍
xxl-job是一个分布式任务调度平台#xff0c;核心设计目标是开发迅速、学习简单、轻量级、易扩展。源码#xff1a;下载地址编译环境#xff1a;Maven3、Jdk1.8、MySQL5.7
二、调度中心
初始化调度数据库#xff0c;执行指定…SpringBoot集成xxl-job实现
一、xxl-job介绍
xxl-job是一个分布式任务调度平台核心设计目标是开发迅速、学习简单、轻量级、易扩展。源码下载地址编译环境Maven3、Jdk1.8、MySQL5.7
二、调度中心
初始化调度数据库执行指定目录下的SQL脚本调度中心支持集群部署各节点需要连接到同一个mysql实例如果mysql做主从调度中心集群节点强制走主库。
/xxl-job/doc/db/tables_xxl_job.sql调度中心项目xxl-job-admin配置修改其中的数据库连接。
/xxl-job/xxl-job-admin/src/main/resources/application.propertiesspring.datasource.urljdbc:mysql://127.0.0.1:3306/xxl_job?useUnicodetruecharacterEncodingUTF-8autoReconnecttrueserverTimezoneAsia/Shanghai
spring.datasource.usernameroot
spring.datasource.passwordroot_pwd
spring.datasource.driver-class-namecom.mysql.jdbc.Driver调度中心项目编译打包部署访问调度中心访问地址http://localhost:8080/xxl-job-admin 默认登录账号admin/123456。
三、配置部署执行器项目
添加maven依赖
dependencygroupIdcom.xuxueli/groupIdartifactIdxxl-job-core/artifactIdversion${project.parent.version}/version
/dependency修改项目的application.properties配置
### 调度中心部署根地址 [选填]如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行执行器心跳注册和任务结果回调为空则关闭自动注册
xxl.job.admin.addresseshttp://127.0.0.1:8080/xxl-job-admin
### 执行器通讯TOKEN [选填]非空时启用
xxl.job.accessToken
### 执行器AppName [选填]执行器心跳注册分组依据为空则关闭自动注册
xxl.job.executor.appnamexxl-job-executor-sample
### 执行器注册 [选填]优先使用该配置作为注册地址为空时使用内嵌服务 ”IP:PORT“ 作为注册地址。从而更灵活的支持容器类型执行器动态IP和动态映射端口问题。
xxl.job.executor.address
### 执行器IP [选填]默认为空表示自动获取IP多网卡时可手动设置指定IP该IP不会绑定Host仅作为通讯实用地址信息用于 执行器注册 和 调度中心请求并触发任务
xxl.job.executor.ip
### 执行器端口号 [选填]小于等于0则自动获取默认端口为9999单机部署多个执行器时注意要配置不同执行器端口
xxl.job.executor.port9999
### 执行器运行日志文件存储磁盘路径 [选填] 需要对该路径拥有读写权限为空则使用默认路径
xxl.job.executor.logpath/data/applogs/xxl-job/jobhandler
### 执行器日志文件保存天数 [选填] 过期日志自动清理, 限制值大于等于3时生效; 否则, 如-1, 关闭自动清理功能
xxl.job.executor.logretentiondays30添加执行器配置
//XxlJobConfig.java
Bean
public XxlJobSpringExecutor xxlJobExecutor() {logger.info( xxl-job 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);return xxlJobSpringExecutor;
}在需要执行的方法上添加XxlJob注解并且指定value属性值然后执行器项目编译打包执行 进入调度中心管理界面新增执行器与任务
