SpringBoot2 集成 xxl-job任务调度中心

接上一篇：
搭建xxl-job任务调度中心
https://gblfy.blog.csdn.net/article/details/113809843

文章目录

一、SpringBoot 配置
- 1. maven依赖
- 2. 执行器配置 application.yml
- 3. 执行器组件配置
- 4. 部署执行器项目
二、xxl-job任务调度中心
- 2.1. 执行器管理
- 2.2. 任务管理
三、Springboot创建任务
- 3.1. 创建任务
四、xxl-job任务调度中心
- 4.1. 查看执行器是否注册成功
- 4.2. 执行任务
- 4.3. 执行任务失败
- 4.4. 修改执行器ip
- 4.5. 再次执行任务
- 4.6. 频次执行

一、SpringBoot 配置

Github地址
https://www.xuxueli.com/xxl-job/

1. maven依赖

   <!-- http://repo1.maven.org/maven2/com/xuxueli/xxl-job-core/ --><dependency><groupId>com.xuxueli</groupId><artifactId>xxl-job-core</artifactId><version>2.3.0</version></dependency>

2. 执行器配置 application.yml

server:port: 80xxl:job:admin:addresses: http://192.168.43.119:8080/xxl-job-admin/executor:appname: xxl-job-executor-samplelogpath: H:/data/applogs/xxl-job/jobhandlerlogretentiondays: 30# 具体解释见Github文档

3. 执行器组件配置

package com.gblfy.distributedjob.config;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 final static 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.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.setIp(ip);// xxlJobSpringExecutor.setPort(port);// xxlJobSpringExecutor.setAccessToken(accessToken);xxlJobSpringExecutor.setLogPath(logPath);xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);return xxlJobSpringExecutor;}
}

4. 部署执行器项目

至此“执行器”项目已经部署结束。

二、xxl-job任务调度中心

搭建xxl-job任务调度中心
https://gblfy.blog.csdn.net/article/details/113809843

2.1. 执行器管理

Springboot项目（执行器）启动后，连接xxl-job任务调度中心会有延迟，需要等一会

【执行器管理】-【查看】可以清楚地看到自己的外网ip地址
注：默认显示无

2.2. 任务管理

【任务管理】-【新增】
JobHandler用来连接任务类的标识，自定义即可

三、Springboot创建任务

3.1. 创建任务

package com.gblfy.distributedjob.task;import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;@Component
public class TaskExecute {private final static Logger logger = LoggerFactory.getLogger(TaskExecute.class);@XxlJob("myJobHandler")public void execute() {// 获取参数String param = XxlJobHelper.getJobParam();//控制台输出日志logger.info("myXxlJobHandler execute...");//写日志到调度中心日志中XxlJobHelper.log("myXxlJobHandler execute...");// 设置任务结果XxlJobHelper.handleSuccess();}
}

四、xxl-job任务调度中心

4.1. 查看执行器是否注册成功

4.2. 执行任务

4.3. 执行任务失败

控制台没有输出

查看任务执行日志

发现了，ip(169.254.118.15)居然是公网的,我的ip应该是192.168.43.147

4.4. 修改执行器ip

4.5. 再次执行任务

控制台输出

执行日志

4.6. 频次执行

SpringBoot2 集成 xxl-job任务调度中心相关推荐

SpringBoot集成XxlJob分布式任务调度中心（超详细之手把手教学）
一.前言废话就不多说了,介绍Xxl-Job的网上已经有很多,本文就不多加复制粘贴了,直接步入第二步.(PS:本文包括Xxl-Job分布式定时任务调度中心的搭建,以及SpringBoot集成XxlJo ...
SpringBoot2 集成 xxl-job任务调度中心_参数传递
文章目录一.xxl-job任务调度中心 1. 调度中心创建任务 2. 调度中心创建执行器二.执行器任务编码 2.1. 单参数 2.2. 多参数三.调度中心参数传递测试 3.1. 单个参数传递 3 ...
集成XXL-JOB任务调度中心
关注我,升职加薪就是你! 今天分享一个伟大的项目–XXL-JOB任务调度中心. 一.搞到本地 1.1 下载 git地址:https://github.com/xuxueli/xxl-job 笔者这边的 ...
分布式任务调度中心xxl-job
xxl-job 分布式任务调度中心优点 xxl-job简介部署调度中心执行器的配置任务配置分布式任务调度中心优点 1.多台机器集群部署保证定时任务不被重复执行 2.动态的调整定时任务的执行时间 ...
一、任务调度中心构建示例
任务调度中心构建任务调度中心构建系统架构搞起来一.创建数据库表二.执行器实现三.效果设计原理参见下篇文章因工作需要,需要构建独立于业务系统之外的任务调度中心,解决当前业务系统的痛点,将 ...
springboot集成XXL-JOB分布式任务调度平台
一.使用背景目前许多项目使用的都是微服务架构,中间存在许多的定时任务.但如果定时任务维护在每个微服务下,当微服务部署多个实例的情况下,会出现定事任务多次执行的情况.并且在解决问题的基础上,希望能够实 ...
Springboot2集成minidao持久层
Springboot2集成minidao持久层这里采用springboot版本号: 2.0.4.RELEASE minidao已经提供自定义starter,集成非常简单,直接pom引入minidao ...
java 中心度_任务调度中心 (优化版)【原】
任务调度中心主要依赖quartz.jar相关类判断cron表达式 , 在下次即将执行的时间在指定时间内时, 从线程池中取线程进行调度 (优化版) 为什么要有调度中心因为在集群环境,多server ...
XXL-JOB原理--任务调度中心执行器注册（三）
在上一篇博客XXL-JOB学习--执行器注册(一)中我们介绍了xxl-job执行器注册到任务调度中心的流程及相关注册信息,接下来我们看看任务调度中心接受任务注册后做了哪些事情. 一.注册地址地址:h ...