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

相关文章

Spring boot整合dubbo+zookeeper的详细过程

《Springboot整合dubbo+zookeeper的详细过程》本文讲解SpringBoot整合Dubbo与Zookeeper实现API、Provider、Consumer模式,包含依赖配置、... 目录Spring boot整合dubbo+zookeeper1.创建父工程2.父工程引入依赖3.创建ap

SpringBoot3.X 整合 MinIO 存储原生方案

《SpringBoot3.X整合MinIO存储原生方案》本文详细介绍了SpringBoot3.X整合MinIO的原生方案,从环境搭建到核心功能实现,涵盖了文件上传、下载、删除等常用操作,并补充了... 目录SpringBoot3.X整合MinIO存储原生方案:从环境搭建到实战开发一、前言:为什么选择MinI

C#连接SQL server数据库命令的基本步骤

《C#连接SQLserver数据库命令的基本步骤》文章讲解了连接SQLServer数据库的步骤,包括引入命名空间、构建连接字符串、使用SqlConnection和SqlCommand执行SQL操作,... 目录建议配合使用:如何下载和安装SQL server数据库-CSDN博客1. 引入必要的命名空间2.

使用Python删除Excel中的行列和单元格示例详解

《使用Python删除Excel中的行列和单元格示例详解》在处理Excel数据时,删除不需要的行、列或单元格是一项常见且必要的操作,本文将使用Python脚本实现对Excel表格的高效自动化处理,感兴... 目录开发环境准备使用 python 删除 Excphpel 表格中的行删除特定行删除空白行删除含指定

SpringBoot结合Docker进行容器化处理指南

《SpringBoot结合Docker进行容器化处理指南》在当今快速发展的软件工程领域,SpringBoot和Docker已经成为现代Java开发者的必备工具,本文将深入讲解如何将一个SpringBo... 目录前言一、为什么选择 Spring Bootjavascript + docker1. 快速部署与

深入理解Go语言中二维切片的使用

《深入理解Go语言中二维切片的使用》本文深入讲解了Go语言中二维切片的概念与应用,用于表示矩阵、表格等二维数据结构,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧... 目录引言二维切片的基本概念定义创建二维切片二维切片的操作访问元素修改元素遍历二维切片二维切片的动态调整追加行动态

Spring Boot spring-boot-maven-plugin 参数配置详解(最新推荐)

《SpringBootspring-boot-maven-plugin参数配置详解(最新推荐)》文章介绍了SpringBootMaven插件的5个核心目标(repackage、run、start... 目录一 spring-boot-maven-plugin 插件的5个Goals二 应用场景1 重新打包应用

prometheus如何使用pushgateway监控网路丢包

《prometheus如何使用pushgateway监控网路丢包》:本文主要介绍prometheus如何使用pushgateway监控网路丢包问题,具有很好的参考价值,希望对大家有所帮助,如有错误... 目录监控网路丢包脚本数据图表总结监控网路丢包脚本[root@gtcq-gt-monitor-prome

SpringBoot+EasyExcel实现自定义复杂样式导入导出

《SpringBoot+EasyExcel实现自定义复杂样式导入导出》这篇文章主要为大家详细介绍了SpringBoot如何结果EasyExcel实现自定义复杂样式导入导出功能,文中的示例代码讲解详细,... 目录安装处理自定义导出复杂场景1、列不固定,动态列2、动态下拉3、自定义锁定行/列,添加密码4、合并

Spring Boot集成Druid实现数据源管理与监控的详细步骤

《SpringBoot集成Druid实现数据源管理与监控的详细步骤》本文介绍如何在SpringBoot项目中集成Druid数据库连接池,包括环境搭建、Maven依赖配置、SpringBoot配置文件... 目录1. 引言1.1 环境准备1.2 Druid介绍2. 配置Druid连接池3. 查看Druid监控