springboot整合 xxl-job的項(xiàng)目實(shí)踐
一、xxl-job是什么
XXL-JOB 是一個(gè)分布式任務(wù)調(diào)度平臺(tái),主要用于解決在分布式系統(tǒng)中任務(wù)調(diào)度和任務(wù)管理的問(wèn)題。
- XXL-JOB 的架構(gòu)通常包括以下幾個(gè)組件:
調(diào)度中心(Scheduler):負(fù)責(zé)任務(wù)的調(diào)度、管理和監(jiān)控,是整個(gè)調(diào)度系統(tǒng)的核心。 - 執(zhí)行器(Executor):負(fù)責(zé)具體任務(wù)的執(zhí)行,可以部署在不同的節(jié)點(diǎn)上。
- Web 管理控制臺(tái):提供友好的 Web 界面,方便用戶進(jìn)行任務(wù)的管理和監(jiān)控。
二、使用步驟
1. 下載并運(yùn)行管理端代碼
項(xiàng)目地址:
1??:【gitee】https://gitee.com/xuxueli0323/xxl-job
2??:【github】https://github.com/xuxueli/xxl-job

管理端需要注意的地方

執(zhí)行sql腳本,tables_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/Shanghai spring.datasource.username=root spring.datasource.password=123456 spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
### xxl-job, access token xxl.job.accessToken=default_token
數(shù)據(jù)庫(kù)地址對(duì)應(yīng)的是第一步執(zhí)行腳本創(chuàng)建的庫(kù)的位置
- accessToken的值需要和執(zhí)行器中配置的值(后面會(huì)寫)一致
- 通過(guò)Application運(yùn)行程序,也可以打包后通過(guò)jar命令啟動(dòng)
2. 訪問(wèn)管理頁(yè)面,確認(rèn)是否啟動(dòng)成功
地址:http://127.0.0.1:8080/xxl-job-admin 【和配置文件一致】
默認(rèn)賬密:admin/123456【忘記密碼可以去數(shù)據(jù)庫(kù)修改,使用md5加密后填充】
3. 配置執(zhí)行器【在自己的springboot項(xiàng)目中配置】
引入依賴
<dependency>
<groupId>com.xuxueli</groupId>
<artifactId>xxl-job-core</artifactId>
<version>2.4.0</version>
</dependency>
添加配置文件
- accessToken與前面配置一致,address對(duì)應(yīng)管理端訪問(wèn)地址
- executor(執(zhí)行器)的配置與后面在頁(yè)面上創(chuàng)建執(zhí)行器時(shí)保持一致
### xxl-job admin address list, such as "http://address" or "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 # 填充地址,假設(shè)執(zhí)行器運(yùn)行在本地
ip: 127.0.0.1 # 填充本地IP,確保它與address配置一致
port: 9999
logpath: /data/applogs/xxl-job/jobhandler
logretentiondays: -1
執(zhí)行器組件配置
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("${xxl.job.admin.addresses}")
private String adminAddresses;
@Value("${xxl.job.accessToken}")
private String accessToken;
@Value("${xxl.job.executor.appname}")
private String appname;
@Value("${xxl.job.executor.address}")
private String address;
@Value("${xxl.job.executor.ip}")
private String ip;
@Value("${xxl.job.executor.port}")
private int port;
@Value("${xxl.job.executor.logpath}")
private String logPath;
@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("簡(jiǎn)單任務(wù)執(zhí)行了。。。" + port);
return ReturnT.SUCCESS;
}
}
啟動(dòng)項(xiàng)目,出現(xiàn)下面的提示說(shuō)明啟動(dòng)成功

4. 在頁(yè)面上創(chuàng)建執(zhí)行器和任務(wù),與項(xiàng)目中綁定
創(chuàng)建執(zhí)行器【取值與springboot項(xiàng)目中配置文件一一對(duì)應(yīng)】

創(chuàng)建任務(wù)


啟動(dòng),驗(yàn)證是否執(zhí)行成功

啟動(dòng)后查看調(diào)度日志,或者觀察程序控制臺(tái)數(shù)據(jù)


總結(jié)
如果啟動(dòng)失敗,檢查配置文件的值是否一致,如accessToken的值
參考
- https://developer.aliyun.com/article/1436105
- https://blog.csdn.net/m0_52985087/article/details/135646151
到此這篇關(guān)于springboot整合 xxl-job的項(xiàng)目實(shí)踐的文章就介紹到這了,更多相關(guān)springboot整合 xxl-job內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- springboot整合 xxl-job及使用步驟
- SpringBoot集成xxl-job實(shí)現(xiàn)超牛的定時(shí)任務(wù)的步驟詳解
- springboot整合xxl-job的實(shí)現(xiàn)示例
- xxl-job的部署及springboot集成使用示例詳解
- SpringBoot部署xxl-job方法詳細(xì)講解
- springboot整合xxl-job實(shí)現(xiàn)分布式定時(shí)任務(wù)的過(guò)程
- springboot整合xxl-job的示例代碼
- SpringBoot整合Xxl-job實(shí)現(xiàn)定時(shí)任務(wù)的全過(guò)程
- Springboot整合xxl-job實(shí)現(xiàn)動(dòng)態(tài)傳參
相關(guān)文章
spring mvc利用ajax向controller傳遞對(duì)象的方法示例
這篇文章主要給大家介紹了關(guān)于spring mvc利用ajax向controller傳遞對(duì)象的相關(guān)資料,文中通過(guò)示例代碼將步驟介紹的非常詳細(xì),對(duì)大家具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來(lái)跟著小編一起學(xué)習(xí)學(xué)習(xí)吧。2017-07-07
JAVA通過(guò)Filter實(shí)現(xiàn)允許服務(wù)跨域請(qǐng)求的方法
這里的域指的是這樣的一個(gè)概念:我們認(rèn)為若協(xié)議 + 域名 + 端口號(hào)均相同,那么就是同域即我們常說(shuō)的瀏覽器請(qǐng)求的同源策略。這篇文章主要介紹了JAVA通過(guò)Filter實(shí)現(xiàn)允許服務(wù)跨域請(qǐng)求,需要的朋友可以參考下2018-11-11
詳解IntelliJ IDEA 自帶的 HTTP Client 接口調(diào)用插件吊打 Postman
HTTP Client 是 IDEA 自帶的一款簡(jiǎn)潔輕量級(jí)的接口調(diào)用插件,通過(guò)它,我們能在 IDEA 上開發(fā),調(diào)試,測(cè)試 RESTful Web 服務(wù),接下來(lái)通過(guò)本文給大家分享IntelliJ IDEA 自帶的 HTTP Client 接口調(diào)用插件吊打 Postman的知識(shí),感興趣的朋友一起看看吧2021-05-05
在SpringBoot中如何利用Redis實(shí)現(xiàn)互斥鎖
當(dāng)我們利用Redis存儲(chǔ)熱點(diǎn)數(shù)據(jù)時(shí),突然就過(guò)期失效或者被刪除了,導(dǎo)致大量請(qǐng)求同時(shí)訪問(wèn)數(shù)據(jù)庫(kù),增加了數(shù)據(jù)庫(kù)的負(fù)載,為減輕數(shù)據(jù)庫(kù)的負(fù)載我們利用互斥鎖,本文重點(diǎn)介紹在SpringBoot中如何利用Redis實(shí)現(xiàn)互斥鎖,感興趣的朋友一起看看吧2023-09-09
Java實(shí)現(xiàn)分布式系統(tǒng)限流
這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)分布式系統(tǒng)限流,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-08-08
調(diào)用java.lang.Runtime.exec的正確姿勢(shì)分享
這篇文章主要介紹了調(diào)用java.lang.Runtime.exec的正確姿勢(shì),具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-11-11
一文讀懂a(chǎn)va中的Volatile關(guān)鍵字使用
volatile關(guān)鍵字的作用保證了變量的可見(jiàn)性(visibility)。被volatile關(guān)鍵字修飾的變量,如果值發(fā)生了變更,其他線程立馬可見(jiàn),避免出現(xiàn)臟讀的現(xiàn)象。這篇文章主要介紹了ava中的Volatile關(guān)鍵字使用,需要的朋友可以參考下2020-03-03

