XXL-Job执行器部署

XXL-Job执行器部署

执行器项目demo配置：
将依赖导入demo-biz的pom
1、导入xxl-job定时任务依赖，自行百度查找

2、加入执行器配置：配置中的addresses要与调度中心的地址保持一致，appname要与调度中心web页面中创建执行器时的appname保持一致
#执行器配置
xxl:
job:
admin: #接口地址,执行器将会使用该地址进行"执行器心跳注册"和"任务结果回调"
addresses: http://${MYSQL-HOST:newx-mysql}:9080/xxl-job-admin
accessToken:
executor: #分别配置执行器的名称、ip地址、端口号,如果配置多个执行器时，防止端口冲突
ip:
port: 9990
appname: xxl-job-executor-test
logpath: /data/applogs/xxl-job/jobhandler #执行器运行日志文件存储的磁盘位置，需要对该路径拥有读写权限
logretentiondays: 30 #执行器Log文件定期清理功能,调度中心日志表数据保存天数,-1表示永不删除

配置执行器组件：
@Configuration
public class XxlJobConfig {
private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);

@Value("${xxl.job.admin.addresses}")
private String adminAddresses;

@Value("${xxl.job.executor.appname}")
private String appName;

@Value("${xxl.job.executor.ip}")
private String ip;

@Value("${xxl.job.executor.port}")
private int port;

@Value("${xxl.job.accessToken}")
private String accessToken;

@Value("${xxl.job.executor.logpath}")
private String logPath;

@Value("${xxl.job.executor.logretentiondays}")
private int logRetentionDays;

@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;
}
}

3、在调度中心创建执行器

4、开发一个demo任务：
@Component
public class TestTask {
@XxlJob(“testHandler”)
public ReturnT demoJobHandler(String param) throws Exception {
XxlJobLogger.log(“XXL-JOB, Hello World.”);
System.out.println(“zxxxx”);
XxlJobLogger.log(“XXL-JOB, Hello World end.”);
return ReturnT.SUCCESS;
}
}

5、在调度中心选定刚才创建的执行器，创建一个任务：@XxlJob注解里的值与调度中心任务中的值保持一致

XXL-Job执行器部署相关推荐

分布式任务调度平台之 xxl-job配置部署
目录导航一.xxl-job安装部署二.openapi配置三.BEAN模式开发四.操作指南五.xxl-job实现高可用六.xxl-job高可用测试一.xxl-job安装部署 1.数据库创建 ...
docker-compose部署xxl-job-admin 分布式任务调度平台
应用场景: 时间驱动的场景:某个时间点发送优惠券,发送短信等等. 批量处理数据:批量统计上个月的账单,统计上个月销售数据等等. 固定频率的场景:每隔5分钟需要执行一次. 所以定时任务在平时开发中并不少 ...
xxl-job调度中心、执行器源码详解
文章目录简介调度中心一.程序启动初始化 1.初始化入口类 2.初始化I18n 3.初始化快慢调度线程池 4.初始化处理执行器注册或移除线程池+更新执行器最新在线的守护线程 5.初始化监控任务调度 ...
物联网国赛AIOT智能家居系统部署
前言 8月刚刚结束的物联网国赛中首次出现AIOT部署智能家居系统,由于6月新大陆AIOT平台大更新,新版智能家居部署文档过长,且没有相关更好的教学,特制此文章.注:该文章主要是以国赛题目作为讲解,其中 ...
Serverless Job—— 传统任务新变革
Job 作为一种运完即停的负载类型,在企业级开发中承载着丰富的使用场景.SAE Job 将 Serverless 技术所带来的普惠红利从应用领域向外延展至任务领域,通过结合 longrun + sho ...
xxljob分布式配置文件
xxljob分布式配置文件配置文件名称:XxlJobConfig.java package com.chinaunicom.rxcx.monitor.daemon.config;import com ...
基于Spring Cloud的微服务架构脚手架实践
文章目录 1 前言 2 脚手架主要提供哪些功能 3 如何使用该脚手架 3.1 项目统一依赖管理 3.2 集成基础模块功能到自己的项目中 4 基础核心功能模块的使用 4.1 集成缓存管理模块 4.1.1 ...
工作中zzzzzz后端问题
持续更新中基础理论 VO DTO DO PO 的区别数据库问题 mysql多条件查询筛选 UUID()重复和去掉'-' 多表联合更新在调用redis的工具类时,RedisTemplate无法注入 ...
618技术特辑（三）直播带货王，“OMG买它”的背后，为什么是一连串技术挑战？
[本期推荐]为什么一到大促,我们的钱包总是被掏空?是大家自制力不够,还是电商平台太会读懂人心,从技术维度,抽丝剥茧一探究竟. 摘要:动辄几十上百万人同时在线的直播间,让所有人能同时公平的去抢购,并且还 ...

XXL-Job执行器部署

XXL-Job执行器部署相关推荐

最新文章

热门文章