xxl-job项目集成实战，全自动项目集成，可以直接使用到项目中

如果你看官方文档，在研究透，至少也得几天时间，如果你直接看我的文档，快速用到项目中，也就10分钟就搞好了。

xxl-job功能确实很强大，而且使用的人比较多，既然在使用xxl-job，那肯定是基于定时任务比较多，不方便管理，才使用它，让定时任务成为一个独立的服务，其它任务可以快速的使用。

但xxl-job也有自己的问题，问题如下：

1、配置执行器、配置任务，只能在管理界面去操作；也就是说，我如果要使用xxl-job，我代码写好了，还需要手动去xxl-job-admin管理页面手动去配置执行器、配置任务，而且官方文档也没有说通过代码接口的方式创建执行器及任务，这就非常不爽了，我们既然在使用你，那说明我们的定时任务非常多，想快速的集成进来，通过代码自动创建执行器和任务，不要手动去配置。

所以基于上面原因，在实际项目上的使用，本文件就要解决上面的问题，通过代码全自动集成到项目中

在介绍之前，先简单讲一下xxl-job的原理，不是官方一大堆文字，这里说的都是直白话，方便你快速明白如何使用；

1、有两个系统，任务调度中心（xxl-job官方提供）、业务系统（您自己的）

2、使用xxl-job分4步：

（1）在任务调度中心创建执行器（说直白点，就是业务系统在任务调度中心进行一个注册，类似于注册中心）

（2）在任务调度中心创建任务（这个任务，主要是根据cron表达式，定时来调用你的业务系统）

（3）业务系统写代码，先注册，后通过@XxlJob来实现定时任务的具体逻辑，后面会详讲

（4）在任务调度中心启动任务

本文所涉及到的代码会放在文章最后面，欢迎下载；压缩包中有两个工程，分别为xxl-job-admin（官方任务调度中心）、xxl-job-soft（你自已的业务系统），所以本文先介绍启动xxl-job-admin，再介绍xxl-job-soft代码集成，本文xxl-job版本号为：2.4.0

一、xxl-job-admin任务调度中心的环境搭建

1、在xxl-job-admin工程里有一个doc的文件夹，里面有一个tables_xxl_job.sql的数据库脚本文件，直接在mysql数据库上执行，执行完就会创建一个xxl-job的数据库

2、idea打开xxl-job-admin工程，修改application.properties里面的数据库配置，如下：

### web
server.port=8080
server.servlet.context-path=/xxl-job-admin

### actuator
management.server.servlet.context-path=/actuator
management.health.mail.enabled=false

### resources
spring.mvc.servlet.load-on-startup=0
spring.mvc.static-path-pattern=/static/**
spring.resources.static-locations=classpath:/static/

### freemarker
spring.freemarker.templateLoaderPath=classpath:/templates/
spring.freemarker.suffix=.ftl
spring.freemarker.charset=UTF-8
spring.freemarker.request-context-attribute=request
spring.freemarker.settings.number_format=0.##########

### mybatis
mybatis.mapper-locations=classpath:/mybatis-mapper/*Mapper.xml
#mybatis.type-aliases-package=com.xxl.job.admin.core.model

### xxl-job, datasource
spring.datasource.url=jdbc:mysql://192.168.137.202:3306/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

### datasource-pool
spring.datasource.type=com.zaxxer.hikari.HikariDataSource
spring.datasource.hikari.minimum-idle=10
spring.datasource.hikari.maximum-pool-size=30
spring.datasource.hikari.auto-commit=true
spring.datasource.hikari.idle-timeout=30000
spring.datasource.hikari.pool-name=HikariCP
spring.datasource.hikari.max-lifetime=900000
spring.datasource.hikari.connection-timeout=10000
spring.datasource.hikari.connection-test-query=SELECT 1
spring.datasource.hikari.validation-timeout=1000

### xxl-job, email
spring.mail.host=smtp.qq.com
spring.mail.port=25
spring.mail.username=xxx@qq.com
spring.mail.from=xxx@qq.com
spring.mail.password=xxx
spring.mail.properties.mail.smtp.auth=true
spring.mail.properties.mail.smtp.starttls.enable=true
spring.mail.properties.mail.smtp.starttls.required=true
spring.mail.properties.mail.smtp.socketFactory.class=javax.net.ssl.SSLSocketFactory

### xxl-job, access token
xxl.job.accessToken=default_token

### xxl-job, i18n (default is zh_CN, and you can choose "zh_CN", "zh_TC" and "en")
xxl.job.i18n=zh_CN

## xxl-job, triggerpool max size
xxl.job.triggerpool.fast.max=200
xxl.job.triggerpool.slow.max=100

### xxl-job, log retention days
xxl.job.logretentiondays=30

3、运行XxlJobAdminApplication.java，服务就启动了，在页面访问：http://localhost:8080/xxl-job-admin

默认用户名为admin，密码为123456

二、xxl-job-soft工程的使用，代码集成xxl-job

说明：xxl-job-soft中的TaskController，里面方法，使用了Map，这是硬编码，实际项目上不要这样用，这只是为了方便看到向xxl-job-admin请求传参，创建执行器和任务等的方便，你主要是要关心创建执行器后返回的executorId（执行器id）和创建任务返回的taskId（任务id），这两个id需要您存储到你的业务数据库，方便后面，比如启动任务、停止任务、删除任务等等使用；

代码集成也和上面说的原理一样，分4步，分别为：

第一步：创建执行器
第二步：创建任务
第三步，业务执行代码和注册
第四步：启动任务

服务启动，运行XxlJobExecutorApplication.java，打开页面

http://localhost:8081/ck/swagger-ui.html

controller代码

@RestController
@RequestMapping("/task")
@Api(tags = "TaskController", description = "任务管理")
public class TaskController {

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

    @GetMapping("/createExecutor")
    @ApiOperation("第一步：创建执行器")
    public String createExecutor(String title) {
        Map<String,Object> map = new HashMap<>();
        map.put("title",title);
        map.put("appname",appname);
        map.put("addressType",0);
        String info = xxlJobClient.xxlJobPost(Constants.XXL_JOB_URL.EXECUTOR_CREATE,map);//返回执行器id，删除执行器时，要用此id,根据你的业务保存在业务库
        String executorId = xxlJobClient.getContent(info);
        System.out.println("执行器Id:"+executorId);
        return "执行器Id:"+executorId;
    }

    @GetMapping("/createTask")
    @ApiOperation("第二步：创建任务")
    public String createTask(@ApiParam(value = "执行器Id")@RequestParam String executorId,
                             @ApiParam(value = "任务名称")@RequestParam String jobDesc,
                             @ApiParam(value = "cron表达式")@RequestParam(defaultValue ="0 * * * * ?" ) String cron,
                             @ApiParam(value = "处理器")@RequestParam(defaultValue ="myHandler" )String executorHandler,
                             @ApiParam(value = "执行参数")@RequestParam String executorParam) {
        Map<String,Object> map = new HashMap<>();
        map.put("jobGroup",executorId);//第一步，创建执行器返回的executorId
        map.put("jobDesc",jobDesc);//任务名称
        map.put("scheduleConf",cron);//0 * * * * ? 每分钟执行一次，自定义
        map.put("cronGen_display",cron);
        map.put("executorHandler",executorHandler);//在第三步，通过 @XxlJob("myHandler")注册的处理器，此处传myHandler，根据自己需要换名称
        map.put("executorParam",executorParam);//此时传的什么值，在第三步，执行时，可以原样获取，获取代码 String param = XxlJobHelper.getJobParam();
        map.put("author","admin");//默认值
        map.put("glueType","BEAN");//默认值
        map.put("scheduleType","CRON");//默认值
        map.put("executorRouteStrategy","FIRST");//默认值
        map.put("misfireStrategy","DO_NOTHING");//默认值
        map.put("executorBlockStrategy","SERIAL_EXECUTION");//默认值
        map.put("executorTimeout","0");//默认值
        map.put("executorFailRetryCount","0");//默认值
        String info = xxlJobClient.xxlJobPost(Constants.XXL_JOB_URL.TASK_CREATE,map);//返回任务id，删除执行器时，要用此id,根据你的业务保存在业务库
        String taskId = xxlJobClient.getContent(info);
        System.out.println("任务Id:"+taskId);
        return "任务Id:"+taskId;
    }

    @GetMapping("/startTask")
    @ApiOperation("第四步：启动任务")
    public String startTask(String taskId) {
        Map<String,Object> map = new HashMap<>();
        map.put("id",taskId);//第二步，创建任务返回的taskId
        xxlJobClient.xxlJobPost(Constants.XXL_JOB_URL.TASK_START,map);
        return "启动成功";
    }

    @GetMapping("/stoptTask")
    @ApiOperation("停止任务")
    public String stoptTask(String taskId) {
        Map<String,Object> map = new HashMap<>();
        map.put("id",taskId);//第二步，创建任务返回的taskId
        xxlJobClient.xxlJobPost(Constants.XXL_JOB_URL.TASK_STOP,map);
        return "停止成功";
    }

    @GetMapping("/deleteTask")
    @ApiOperation("删除任务")
    public String deleteTask(String taskId) {
        Map<String,Object> map = new HashMap<>();
        map.put("id",taskId);//第二步，创建任务返回的taskId
        xxlJobClient.xxlJobPost(Constants.XXL_JOB_URL.TASK_DELETE,map);
        return "停止成功";
    }

    @GetMapping("/deleteExecutor")
    @ApiOperation("删除执行器")
    public String deleteExecutor(String executorId) {
        Map<String,Object> map = new HashMap<>();
        map.put("id",executorId);//第二步，创建任务返回的taskId
        xxlJobClient.xxlJobPost(Constants.XXL_JOB_URL.EXECUTOR_DELETE,map);
        return "停止成功";
    }
}

执行器注册代码

@Bean
    public XxlJobSpringExecutor xxlJobExecutor() {
        logger.info(">>>>>>>>>>> xxl-job config init.");
        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
        xxlJobSpringExecutor.setAppname(appname);
        xxlJobSpringExecutor.setAddress(address);
        xxlJobSpringExecutor.setIp(ip);
        xxlJobSpringExecutor.setPort(port);
        xxlJobSpringExecutor.setAccessToken(accessToken);
        xxlJobSpringExecutor.setLogPath(logPath);
        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
        return xxlJobSpringExecutor;
    }

定时任务具体的业务代码

//第三步，业务执行代码
    @XxlJob("myHandler")
    public void demoJobHandler() throws Exception {
        XxlJobHelper.log("XXL-JOB, Hello World.");
        String param = XxlJobHelper.getJobParam();
        String msg ="收到第二步创建任务时executorParam的参数："+param+"  当前任务执行结束";
        XxlJobHelper.log(msg);
        System.out.println(msg);
    }
三，测试使用，在swagger中操作

第一步：创建执行器，记住执行器Id返回为2，具体返回多少，根据你自己的执行结果：

在任务调度中心，也可以看到执行器了


第二步：创建任务，任务id为3，并在任务调度中心，查看任务状态是停止状态


第三步，业务执行代码和注册

上面代码已列出


第四步：启动任务

第五步：在业务系统，查看任务是否执行，查看已运行

四、代码下载地址：

链接：https://pan.baidu.com/s/1qZHQmzBF0UrSDHdYobmYlQ?pwd=ka1u 
提取码：ka1u

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mfbz.cn/a/104486.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

pytorch 入门 （四）案例二：人脸表情识别-VGG16实现

pytorch 入门 （四）案例二：人脸表情识别-VGG16实现

实战教案二&#xff1a;人脸表情识别-VGG16实现 本文为&#x1f517;小白入门Pytorch内部限免文章 参考本文所写记录性文章&#xff0c;请在文章开头注明以下内容&#xff0c;复制粘贴即可 &#x1f368; 本文为&#x1f517;小白入门Pytorch中的学习记录博客&#x1f366; 参…
阅读更多...
ruoyi-nbcio版本从RuoYi-Flowable-Plus迁移过程记录

ruoyi-nbcio版本从RuoYi-Flowable-Plus迁移过程记录

更多ruoyi-nbcio功能请看演示系统 gitee源代码地址 前后端代码&#xff1a; https://gitee.com/nbacheng/ruoyi-nbcio 演示地址&#xff1a;RuoYi-Nbcio后台管理系统 从KonBAI / RuoYi-Flowable-Plus 项目移植过来&#xff0c;开始用yarn install之后yarn run dev 还是有问…
阅读更多...
腾讯云价格计算器有用过的吗？好用！

腾讯云价格计算器有用过的吗？好用！

腾讯云服务器价格计算器可以一键计算出云服务器的精准报价&#xff0c;包括CVM实例规格价格、CPU内存费用、公网带宽收费、存储系统盘和数据盘详细费用&#xff0c;腾讯云百科txybk.com分享腾讯云价格计算器链接入口、使用方法说明&#xff1a; 腾讯云服务器价格计算器 打开腾…
阅读更多...
Java八股文 ---Java并发篇

Java八股文 ---Java并发篇

线程安全 线程安全就是多个线程去执行某类&#xff0c;这个类始终能表现出正确的行为&#xff0c;那么这个类就是线程安全的 我们判断是否要处理线程安全问题&#xff0c;就看有没有多个线程同时访问一个共享变量 能不能保证操作的原子性&#xff0c;考虑atomic包下的类够不够我…
阅读更多...
Kubernetes技术与架构-网络 3

Kubernetes技术与架构-网络 3

Kubernetes集群支持为Pod或者Service申请IPV4或者IPV6的地址空间。 kube-apiserver --service-cluster-ip-range<IPv4 CIDR>,<IPv6 CIDR> kube-controller-manager --cluster-cidr<IPv4 CIDR>,<IPv6 CIDR> --service-cluster-ip-range<IPv4 CI…
阅读更多...
架构风格区别-架构案例（五十九）

架构风格区别-架构案例（五十九）

管道-过滤器和仓库的区别&#xff1f; 独立的数据仓库&#xff0c;处理流独立&#xff0c;处理数据用连接仓库工具数据与处理在一起&#xff0c;改动的话需要重启系统需要仓库工具与仓库连接&#xff0c;数据与处理分离&#xff0c;性能差可以支持并发连接访问仓库&#xff0c…
阅读更多...
MSQL系列(八) Mysql实战-SQL存储引擎

MSQL系列(八) Mysql实战-SQL存储引擎

Mysql实战-SQL存储引擎 前面我们讲解了索引的存储结构&#xff0c;BTree的索引结构&#xff0c;我们一般都知道Mysql的存储引擎有两种&#xff0c;MyISAM和InnoDB,今天我们来详细讲解下Mysql的存储引擎 文章目录 Mysql实战-SQL存储引擎1.存储引擎2.MyISAM的特点3. InnoDB的特…
阅读更多...
基于单片机设计的防煤气泄漏装置

基于单片机设计的防煤气泄漏装置

一、前言 煤气泄漏是一个严重的安全隐患&#xff0c;可能导致火灾、爆炸以及对人体健康的威胁。为了提高家庭和工业环境中煤气泄漏的检测和预防能力&#xff0c;设计了一种基于单片机的防煤气泄漏装置。 单片机选择STC89C52作为主控芯片。为了检测煤气泄漏&#xff0c;采用了…
阅读更多...
kuaishou web端did注册激活 学习记录

kuaishou web端did注册激活 学习记录

快手web端 did 注册激活的流程大概如下&#xff1a; 1.访问web端的接口&#xff0c;主动触发滑块&#xff0c;拿到滑块信息 2.然后滑块验证did 获取captchaToken 3.携带captchaToken访问接口 4.最后校验web端的did 是否激活 最后激活以后的效果如下&#xff1a; 经过测试&…
阅读更多...
我是这样保持精力充沛的

我是这样保持精力充沛的

精力管理就好比是计算机的内存清理&#xff0c;你以为关掉一些程序就行了&#xff0c;结果你还是卡成翔。 我的现状 雷猴啊&#xff0c;我是一个临期程序员。打过几年工&#xff0c;被好几个同事问过我为什么精力这么旺盛。 这两年我大多数情况都是早上8点前就到公司*(原本9点上…
阅读更多...
摄影测量编码点源文件

摄影测量编码点源文件

源文件下载链接。
阅读更多...
《红蓝攻防对抗实战》三.内网探测协议出网之HTTP/HTTPS协议探测出网

《红蓝攻防对抗实战》三.内网探测协议出网之HTTP/HTTPS协议探测出网

目录 一. 在 Windows 操作系统中探测 HTTP/HTTPS 出网 1. Bitsadmin 命令 2.Certuil 命令 2.Linux系统探测HTTP/HTTPS出网 1.Curl命令 2.Wget命令 对目标服务器探测 HTTP/HTTPS 是否出网时&#xff0c;要根据目标系统类型执行命令&#xff0c;不同类型的操作系统使用的探…
阅读更多...
一文说尽零售数据分析指标体系

一文说尽零售数据分析指标体系

零售的本质业务模式是通过在各种渠道上吸引客户来购买我们的商品来实现盈利&#xff0c;其实就是客户-渠道-商品&#xff0c;也就是我们常说的“人、场、货”&#xff0c;除此之外还有供应链、财务等起到重要的辅助作用。因此如果要构建起系统化的零售数据分析指标体系&#xf…
阅读更多...
单片机设计基于STM32的空气净化器设计

单片机设计基于STM32的空气净化器设计

**单片机设计介绍&#xff0c;1615[毕设课设]基于STM32的空气净化器设计 文章目录 一 概要二、功能设计设计思路 三、 软件设计原理图pcb设计图 五、 程序六、 文章目录 一 概要 此设计资料主要包含原理图、PCB、源程序、元器件清等资料&#xff0c; 二、功能设计 设计思路 …
阅读更多...
[AutoSAR系列] 1.3 AutoSar 架构

[AutoSAR系列] 1.3 AutoSar 架构

依AutoSAR及经验辛苦整理&#xff0c;原创保护&#xff0c;禁止转载。 专栏 《深入浅出AutoSAR》 1. 整体架构 ​ 图片来源&#xff1a; AutoSar 官网 从官往图中可以看出autosar作为汽车ECU软件架构&#xff0c;是通过分层来实现软硬件隔离。就像大多数操作系统一样&#xff…
阅读更多...
深度学习_5_模型拟合_梯度下降原理

深度学习_5_模型拟合_梯度下降原理

需求: 想要找到一条直线&#xff0c;能更好的拟合这一些点 如何确定上述直线就是最优解呢&#xff1f; 由计算机算出所有点与我们拟合直线的误差&#xff0c;常见的是均方误差 例如&#xff1a;P1与直线之间的误差为e1 将P1坐标带入直线并求误差得&#xff1a; 推广到所有点&a…
阅读更多...
Pico示波器 汽车振动异响(NVH)解决方案

Pico示波器 汽车振动异响(NVH)解决方案

汽车振动异响故障可能有多个潜在原因&#xff0c;包括发动机、传动系统、悬挂系统、制动系统等等。技师需要对汽车各个方面有全面的了解&#xff0c;才能更好地进行故障排查。 振动和异响可能由多个因素引起。例如&#xff0c;可能是零部件损坏、松脱、磨损或者不正确安装。这…
阅读更多...
某全球领先的晶圆代工企业：替代FTP实现大规模文件的高效传输

某全球领先的晶圆代工企业：替代FTP实现大规模文件的高效传输

全球领先的集成电路晶圆代工企业之一 该企业不仅是全球领先的集成电路晶圆代工企业之一&#xff0c;也是中国内地技术最先进、配套最完善、规模最大、跨国经营的集成电路制造企业集团。主要业务是根据客户本身或第三者的集成电路设计&#xff0c;为客户制造集成电路芯片&#…
阅读更多...
Opencv-图像插值与LUT查找表

Opencv-图像插值与LUT查找表

图像像素的比较 白色是255&#xff0c;黑色是0 min(InputArray src1,InputArray src2,OutputArray dst) max(InputArray src1,InputArray src2,OutpurArray dstsrc1:第一个图像矩阵&#xff0c;通道数任意src2&#xff1a;第二个图像矩阵&#xff0c;尺寸和通道数以及数据类型…
阅读更多...
面试题：Java 类加载过程是怎么样的？

面试题：Java 类加载过程是怎么样的？

首先&#xff0c;我们编写好的Java代码&#xff0c;经过编译变成.class文件&#xff0c;然后类加载器把.class字节码文件加载到JVM中&#xff0c;接着执行我们的代码&#xff0c;最后将类卸载出JVM。而从类加载到虚拟机到卸载出虚拟机的这一整个生命周期总共可以分为7个步骤&am…
阅读更多...
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站