springboot整合 xxl-job及使用步骤

2025-01-10 04:50

本文主要是介绍springboot整合 xxl-job及使用步骤,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

《springboot整合xxl-job及使用步骤》XXL-JOB是一个分布式任务调度平台,用于解决分布式系统中的任务调度和管理问题,文章详细介绍了XXL-JOB的架构,包括调度中心、执行器和Web...

一、xxl-job是什么

XXL-JOB 是一个分布式任务调度平台,主要用于解决在分布式系统中任务调度和任务管理的问题。

  • XXL-JOB 的架构通常包括以下几个组件:
    调度中心(Scheduler):负责任务的调度、管理和监控,是整个调度系统的核心。
  • 执行器(Executor):负责具体任务的执行,可以部署在不同的节点上。
  • Web 管理控制台:提供友好的 Web 界面,方便用户进行任务的管理和监控。

二、使用步骤

1. 下载并运行管理端代码

项目地址:
1:【gitee】https://gitee.com/xuxueli0323/xxl-job
2:【github】https://github.com/xuxueli/xxl-job

springboot整合 xxl-job及使用步骤

管理端需要注意的地方

springboot整合 xxl-job及使用步骤

执行sql脚本,tabljavascriptes_xxl_job.sql

修改application.properties配置文件,主要修改两处

数据库地址对应的是第一步执行脚本创建的库的位置

xxl-job, datasource

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shwww.chinasem.cnanghai
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

AccessToken的值需要和执行器中配置的值(后面会写)一致

xxl-job, access token

xxl.job.accessToken=default_token

通过Application运行程序,也可以打包后通过jar命令启动

2. 访问管理页面,确认是否启动成功

地址:http://127.0.0.1:8080/xxl-job-admin 【和配置文件一致】
默认账密:admin/123456【忘记密码可以去数据库修改,使用md5加密后填充】

3. 配置执行器【在自己的springboot项目中配置】

引入依赖

    <dependency>
        <groupId>com.xuxueli</groupId>
        <artifactId>xxl-job-core</artifactId>
        <version>2.4.0</version>
    </dependency>

添加配置文件

  • accessToken与前面配置一致,address对应管理端访问地址
  • executor(执行器)的配置与后面在页面上创建执行器时保持一致

xxl-job admin address list, such as “http://address” ojsr “http://address01,http://address02”

xxl:
job:
accessToken: default_token
admin:
addresses: http://127.0.0.1:8080/xxl-job-admin
executor:
appname: xxl-job-executor-test-zhu
address: http://localhost:9999 # 填充地址,假设执行器运行在本地
ip: 127.0.0.1 # 填充本地IP,确保它与address配置一致
port: 9999
logpath: /data/applogs/xxl-job/jobhandler
logretentiondays: -1

执行器组件配置

package com.zhui.yudada.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;
@Slf4j
@Configuration
public class XxlJobConfig {
@Value(“x x l . j o b . a d m i n . a d d r e s s e s " ) p r i v a t e S t r i n g a d m i n A d d r e s s e s ; @ V a l u e ( " {xxl.job.admin.addresses}") private String adminAddresses; @Value("xxl.job.admin.addresses")privateStringadminAddresses;@Value("{xxl.job.accessToken}”)
private String accessToken;
@Value(“x x l . j o b . e x e c u t o r . a p p n a m e " ) p r i v a t e S t r i n g a p p n a m e ; @ V a l u e ( " {xxl.jojsb.executor.appname}") private String appname; @Value("xxl.job.executojavascriptr.appname")privateStringappname;@Value("{xxl.job.executor.address}”)
private String address;
@Value(“x x l . j o b . e x e c u t o r . i p " ) p r i v a t e S t r i n g i p ; @ V a l u e ( " {xxl.job.executor.ip}") private String ip; @Value("xxl.job.executor.ip")privateStringip;@Value("{xxl.job.executor.port}”)
private int port;
@Value(“x x l . j o b . e x e c u t o r . l o g p a t h " ) p r i v a t e S t r i n g l o g P a t h ; @ V a l u e ( " {xxl.job.executor.logpath}") private String logPath; @Value("xxl.job.executor.logpath")privateStringlogPath;@Value("{xxl.job.executor.logretentiondays}”)
private int logRetentionDays;
@Bean
public XxlJobSpringExecutor xxlJobExecutor() {
log.info(“>>>>>>>>>>> start 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;
}
}

jobhander配置

package com.zhui.yudada.job;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
@Component
public class HelloJob {
@Value("${server.port}")
private String port;
@XxlJob("demoJobHandler")
public ReturnT helloJob() {
    System.out.println("简单任务执行了。。。" + port);
    return  ReturnT.SUCCESS;
}
}

启动项目,出现下面的提示说明启动成功

springboot整合 xxl-job及使用步骤

4. 在页面上创建执行器和任务,与项目中绑定 创建执行器【取值与springboot项目中配置文件一一对应】

springboot整合 xxl-job及使用步骤

创建任务

springboot整合 xxl-job及使用步骤

springboot整合 xxl-job及使用步骤

启动,验证是否执行成功

springboot整合 xxl-job及使用步骤

启动后查看调度日志,或者观察程序控制台数据

springboot整合 xxl-job及使用步骤

springboot整合 xxl-job及使用步骤

总结

如果启动失败,检查配置文件的值是否一致,如accessToken的值

参考 https://developer.aliyun.com/article/1436105https://blog.csdn.net/m0_52985087/article/details/135646151

到此这篇关于springboot整合 xxl-job及使用步骤的文章就介绍到这了,更多相关springboot整合 xxl-job内容请搜索China编程(www.chinasem.cn)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程China编程(www.chinasem.cn)!

这篇关于springboot整合 xxl-job及使用步骤的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1153014

相关文章

怎么用idea创建一个SpringBoot项目

《怎么用idea创建一个SpringBoot项目》本文介绍了在IDEA中创建SpringBoot项目的步骤,包括环境准备(JDK1.8+、Maven3.2.5+)、使用SpringInitializr... 目录如何在idea中创建一个SpringBoot项目环境准备1.1打开IDEA,点击New新建一个项

如何使用Maven创建web目录结构

《如何使用Maven创建web目录结构》:本文主要介绍如何使用Maven创建web目录结构的问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录创建web工程第一步第二步第三步第四步第五步第六步第七步总结创建web工程第一步js通过Maven骨架创pytho

mysql查询使用_rowid虚拟列的示例

《mysql查询使用_rowid虚拟列的示例》MySQL中,_rowid是InnoDB虚拟列,用于无主键表的行ID查询,若存在主键或唯一列,则指向其,否则使用隐藏ID(不稳定),推荐使用ROW_NUM... 目录1. 基本查询(适用于没有主键的表)2. 检查表是否支持 _rowid3. 注意事项4. 最佳实

Java Web实现类似Excel表格锁定功能实战教程

《JavaWeb实现类似Excel表格锁定功能实战教程》本文将详细介绍通过创建特定div元素并利用CSS布局和JavaScript事件监听来实现类似Excel的锁定行和列效果的方法,感兴趣的朋友跟随... 目录1. 模拟Excel表格锁定功能2. 创建3个div元素实现表格锁定2.1 div元素布局设计2.

Spring如何使用注解@DependsOn控制Bean加载顺序

《Spring如何使用注解@DependsOn控制Bean加载顺序》:本文主要介绍Spring如何使用注解@DependsOn控制Bean加载顺序,具有很好的参考价值,希望对大家有所帮助,如有错误... 目录1.javascript 前言2. 代码实现总结1. 前言默认情况下,Spring加载Bean的顺

使用Python进行GRPC和Dubbo协议的高级测试

《使用Python进行GRPC和Dubbo协议的高级测试》GRPC(GoogleRemoteProcedureCall)是一种高性能、开源的远程过程调用(RPC)框架,Dubbo是一种高性能的分布式服... 目录01 GRPC测试安装gRPC编写.proto文件实现服务02 Dubbo测试1. 安装Dubb

HTML中meta标签的常见使用案例(示例详解)

《HTML中meta标签的常见使用案例(示例详解)》HTMLmeta标签用于提供文档元数据,涵盖字符编码、SEO优化、社交媒体集成、移动设备适配、浏览器控制及安全隐私设置,优化页面显示与搜索引擎索引... 目录html中meta标签的常见使用案例一、基础功能二、搜索引擎优化(seo)三、社交媒体集成四、移动

Maven中的profiles使用及说明

《Maven中的profiles使用及说明》:本文主要介绍Maven中的profiles使用及说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录主要用途定义 Profiles示例:多环境配置激活 Profiles示例:资源过滤示例:依赖管理总结Maven 中的

如何使用Haporxy搭建Web群集

《如何使用Haporxy搭建Web群集》Haproxy是目前比较流行的一种群集调度工具,同类群集调度工具有很多如LVS和Nginx,本案例介绍使用Haproxy及Nginx搭建一套Web群集,感兴趣的... 目录一、案例分析1.案例概述2.案例前置知识点2.1 HTTP请求2.2 负载均衡常用调度算法 2.

shell中set -u、set -x、set -e的使用

《shell中set-u、set-x、set-e的使用》本文主要介绍了shell中set-u、set-x、set-e的使用,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参... 目录✅ 1. set -u:防止使用未定义变量 作用: 示例:❌ 报错示例输出:✅ 推荐使用场景:✅ 2. se