营销型网站图片,互联网公司排名2014,锦阳商城网站,wordpress宠物插件文章目录 xxl-job 简介引入xxl-job依赖配置xxl-job config添加properties文件配置BEAN模式#xff08;方法形式#xff09;步骤一#xff1a;执行器项目中#xff0c;开发Job方法#xff1a;步骤二#xff1a;调度中心#xff0c;新建调度任务 xxl-job 简介 官网:https:… 文章目录 xxl-job 简介引入xxl-job依赖配置xxl-job config添加properties文件配置BEAN模式方法形式步骤一执行器项目中开发Job方法步骤二调度中心新建调度任务 xxl-job 简介 官网:https://www.xuxueli.com/xxl-job/ XXL-JOB是一个分布式任务调度平台其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线开箱即用。 引入xxl-job依赖 dependencygroupIdcom.xuxueli/groupIdartifactIdxxl-job-core/artifactIdversion2.4.0/version/dependency配置xxl-job config
import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** Author: hrd* CreateTime: 2023/9/28 11:10* Description:*/
Configuration
Slf4j
public class XxlJobConfig {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() {log.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;}
}
添加properties文件配置
### 调度中心部署根地址 [选填]如调度中心集群部署存在多个地址则用逗号分隔。执行器将会使用该地址进行执行器心跳注册和任务结果回调为空则关闭自动注册
xxl.job.admin.addresseshttp://dev.xxx.com:8080/xxl-job-admin
### 执行器通讯TOKEN [选填]非空时启用
xxl.job.accessTokendefault_token
### 执行器AppName [选填]执行器心跳注册分组依据为空则关闭自动注册
xxl.job.executor.appnamexxl-job-executor-sample-sharing
### 执行器注册 [选填]优先使用该配置作为注册地址为空时使用内嵌服务 ”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/apps/xxl-job-admin/log/jobhandler
### 执行器日志文件保存天数 [选填] 过期日志自动清理, 限制值大于等于3时生效; 否则, 如-1, 关闭自动清理功能
xxl.job.executor.logretentiondays30BEAN模式方法形式 Bean模式任务支持基于方法的开发方式每个任务对应一个方法。 优点 每个任务只需要开发一个方法并添加”XxlJob”注解即可更加方便、快速。 支持自动扫描任务并注入到执行器容器。缺点要求Spring容器环境 基于方法开发的任务底层会生成JobHandler代理和基于类的方式一样任务也会以JobHandler的形式存在于执行器任务容器中。 步骤一执行器项目中开发Job方法 1、任务开发在Spring Bean实例中开发Job方法 2、注解配置为Job方法添加注解 “XxlJob(value“自定义jobhandler名称”, init “JobHandler初始化方法”, destroy “JobHandler销毁方法”)”注解value值对应的是调度中心新建任务的JobHandler属性的值。 3、执行日志需要通过 “XxlJobHelper.log” 打印执行日志 4、任务结果默认任务结果为 “成功” 状态不需要主动设置如有诉求比如设置任务结果为失败可以通过 “XxlJobHelper.handleFail/handleSuccess” 自主设置任务结果 // 可参考Sample示例执行器中的 com.xxl.job.executor.service.jobhandler.SampleXxlJob 如下
XxlJob(demoJobHandler)
public void demoJobHandler() throws Exception {XxlJobHelper.log(XXL-JOB, Hello World.);
}步骤二调度中心新建调度任务 参考上文“配置属性详细说明”对新建的任务进行参数配置运行模式选中 “BEAN模式”JobHandler属性填写任务注解“XxlJob”中定义的值
