SpringBoot整合XXLJob的實(shí)現(xiàn)示例
XXLJob簡(jiǎn)介
XXLJob是一個(gè)分布式任務(wù)調(diào)度平臺(tái),優(yōu)點(diǎn):開發(fā)迅速、學(xué)習(xí)簡(jiǎn)單、輕量級(jí)、易擴(kuò)展。是大眾點(diǎn)評(píng)員工xxl創(chuàng)建并維護(hù),基于 GPL-3.0 開源,可放心商用,目前已經(jīng)擁有龐大的使用群體。
簡(jiǎn)單來說,就是一個(gè)定時(shí)任務(wù)中間件,類似的產(chǎn)品有當(dāng)當(dāng)網(wǎng)開源的Elastic-Job。

特性
- 簡(jiǎn)單:產(chǎn)品本身基于Java開發(fā)的,鑒于JVM的優(yōu)秀,安裝部署集成簡(jiǎn)單,和其他中間件、框架相比,避免了各種環(huán)境問題;同時(shí)程序員在項(xiàng)目中集成進(jìn)來也很簡(jiǎn)單,有手就行。
- 觸發(fā)策略豐富:按照設(shè)置的Cron表達(dá)式觸發(fā)、固定間隔觸發(fā)、固定延時(shí)觸發(fā)、API(事件)觸發(fā)、人工觸發(fā)、父子任務(wù)觸發(fā)
- 支持失敗重試
- 包含簡(jiǎn)單的告警和豐富的log,玩過定時(shí)任務(wù)的都知道,可觀測(cè)性在實(shí)際項(xiàng)目中是多么的關(guān)鍵
- 支持任務(wù)分片:例如將一個(gè)大任務(wù),拆分為多個(gè)小任務(wù),然后分給不同的執(zhí)行器節(jié)點(diǎn)同時(shí)執(zhí)行
- 數(shù)據(jù)加密:調(diào)度中心和執(zhí)行器之間的通訊進(jìn)行數(shù)據(jù)加密,提升調(diào)度信息安全性
- 豐富的鉤子:各種回調(diào)可細(xì)粒度觀察任務(wù)的生命周期
- 跨語言:調(diào)度中心與執(zhí)行器提供語言無關(guān)的 RESTful API 服務(wù),第三方任意語言可據(jù)此對(duì)接調(diào)度中心或者實(shí)現(xiàn)執(zhí)行器。除此之外,還提供了 “多任務(wù)模式”和“httpJobHandler”等其他跨語言方案;
- 容器化:對(duì)云原生支持友好
- 有webUI管理系統(tǒng)
- 高可用:支持集群部署,可彈性擴(kuò)容
- 自動(dòng)發(fā)現(xiàn):執(zhí)行器會(huì)周期性自動(dòng)注冊(cè)任務(wù), 調(diào)度中心將會(huì)自動(dòng)發(fā)現(xiàn)注冊(cè)上來的執(zhí)行器并將任務(wù)分配給執(zhí)行器同時(shí)觸發(fā)執(zhí)行
模塊
- 調(diào)度中心:管理執(zhí)行器、任務(wù);查看任務(wù)日志、告警、報(bào)表;提供一個(gè)webUI管理系統(tǒng),有簡(jiǎn)單的用戶登錄賬號(hào)管理功能;依賴數(shù)據(jù)庫
- 執(zhí)行器:執(zhí)行器是獨(dú)立的RESTFul服務(wù),一般集成在業(yè)務(wù)服務(wù)中,它會(huì)開辟一個(gè)9999(默認(rèn))端口和調(diào)度中心交互
由上可知,XXLJob為C/S架構(gòu),調(diào)度中心本身可以高可用部署,執(zhí)行器集成在業(yè)務(wù)微服務(wù)中,當(dāng)業(yè)務(wù)微服務(wù)多實(shí)例部署的時(shí)候,執(zhí)行器也就可以達(dá)到分布式和高可用了。
安裝調(diào)度中心
初始化數(shù)據(jù)庫
調(diào)度中心依賴數(shù)據(jù)庫,安裝前需先初始化數(shù)據(jù)庫
表說明:
- xxl_job_lock:任務(wù)調(diào)度鎖表
- xxl_job_group:執(zhí)行器信息表,維護(hù)任務(wù)執(zhí)行器信息
- xxl_job_info:調(diào)度擴(kuò)展信息表: 用于保存XXL-JOB調(diào)度任務(wù)的擴(kuò)展信息,如任務(wù)分組、任務(wù)名、機(jī)器地址、執(zhí)行器、執(zhí)行入?yún)⒑蛨?bào)警郵件等等
- xxl_job_log:調(diào)度日志表: 用于保存XXL-JOB任務(wù)調(diào)度的歷史信息,如調(diào)度結(jié)果、執(zhí)行結(jié)果、調(diào)度入?yún)ⅰ⒄{(diào)度機(jī)器和執(zhí)行器等等
- xxl_job_log_report:調(diào)度日志報(bào)表:用戶存儲(chǔ)XXL-JOB任務(wù)調(diào)度日志的報(bào)表,調(diào)度中心報(bào)表功能頁面會(huì)用到
- xxl_job_logglue:任務(wù)GLUE日志:用于保存GLUE更新歷史,用于支持GLUE的版本回溯功能
- xxl_job_registry:執(zhí)行器注冊(cè)表,維護(hù)在線的執(zhí)行器和調(diào)度中心機(jī)器地址信息
- xxl_job_user:系統(tǒng)用戶表;
配置
- 運(yùn)行端口
- 數(shù)據(jù)庫連接
- 報(bào)警郵箱
- token:一個(gè)串,非必填,設(shè)置之后,執(zhí)行器也需要配置此串,才能和調(diào)度中心交互,相當(dāng)于一個(gè)簡(jiǎn)單的認(rèn)證
- 線程池配置
參見官方文檔,本文重點(diǎn)放在SpringBoot整合XXLJob。調(diào)度中心的部署,尤其是高可用部署,后續(xù)單獨(dú)開篇。
啟動(dòng)
調(diào)度中心就是一個(gè)SpringBoot程序,以xxljob2.4.0版本為例,其依賴的SpringBoot版本為 2.7.9,所以任何啟動(dòng)SpringBoot 的方式都可以,webui的默認(rèn)訪問地址:http://ip:8080/xxl-job-admin
整合執(zhí)行器
pom
<dependency>
<groupId>com.xuxueli</groupId>
<artifactId>xxl-job-core</artifactId>
<version>2.4.0</version>
</dependency>yml
server:
port: 9009
logging:
level:
com.ramble: debug
xxl:
job:
admin:
#調(diào)度中心部署根地址 [選填]:如調(diào)度中心集群部署存在多個(gè)地址則用逗號(hào)分隔。執(zhí)行器將會(huì)使用該地址進(jìn)行"執(zhí)行器心跳注冊(cè)"和"任務(wù)結(jié)果回調(diào)";為空則關(guān)閉自動(dòng)注冊(cè);
addresses: http://127.0.0.1:8080/xxl-job-admin
#執(zhí)行器通訊TOKEN [選填]:非空時(shí)啟用;
accessToken:
executor:
#執(zhí)行器AppName [選填]:執(zhí)行器心跳注冊(cè)分組依據(jù);為空則關(guān)閉自動(dòng)注冊(cè)
appname: xxljob-demo-service
#${spring.application.name}
#執(zhí)行器注冊(cè) [選填]:優(yōu)先使用該配置作為注冊(cè)地址,為空時(shí)使用內(nèi)嵌服務(wù) ”IP:PORT“ 作為注冊(cè)地址。從而更靈活的支持容器類型執(zhí)行器動(dòng)態(tài)IP和動(dòng)態(tài)映射端口問題。
address: ""
#執(zhí)行器IP [選填]:默認(rèn)為空表示自動(dòng)獲取IP,多網(wǎng)卡時(shí)可手動(dòng)設(shè)置指定IP,該IP不會(huì)綁定Host僅作為通訊實(shí)用;地址信息用于 "執(zhí)行器注冊(cè)" 和 "調(diào)度中心請(qǐng)求并觸發(fā)任務(wù)";
ip: ""
#執(zhí)行器端口號(hào) [選填]:小于等于0則自動(dòng)獲取;默認(rèn)端口為9999,單機(jī)部署多個(gè)執(zhí)行器時(shí),注意要配置不同執(zhí)行器端口;
port: 0
###${server-port}
#執(zhí)行器運(yùn)行日志文件存儲(chǔ)磁盤路徑 [選填] :需要對(duì)該路徑擁有讀寫權(quán)限;為空則使用默認(rèn)路徑;
logpath: ./logs/xxl-job/jobhandler
#執(zhí)行器日志文件保存天數(shù) [選填] : 過期日志自動(dòng)清理, 限制值大于等于3時(shí)生效; 否則, 如-1, 關(guān)閉自動(dòng)清理功能;
logretentiondays: 30XxlJobConfig
@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;
}
}啟動(dòng)執(zhí)行器
如果一切順利,將在控制臺(tái)看到如下輸出:
2023-10-09 11:36:23.162 INFO 15736 --- [ Thread-4] com.xxl.job.core.server.EmbedServer : >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999
看到這個(gè),說明執(zhí)行器配置已生效,執(zhí)行器已經(jīng)順利和調(diào)度中心聯(lián)系上了。
實(shí)踐
可以簡(jiǎn)單的將任務(wù)分兩個(gè)步驟,第一在執(zhí)行器中定義一個(gè)任務(wù)具體需要干什么,第二在調(diào)度中心觸發(fā)定義的任務(wù)
簡(jiǎn)單的定時(shí)任務(wù)
在執(zhí)行器創(chuàng)建任務(wù)
在業(yè)務(wù)微服務(wù)中創(chuàng)建
@Slf4j
@Component
public class DemoJob {
/**
* 簡(jiǎn)單的job,調(diào)度器
*/
@XxlJob("job1")
public void job1() {
log.debug("do job1");
}
}在調(diào)度中心創(chuàng)建執(zhí)行器
- 對(duì)于調(diào)度中心來說,執(zhí)行器可能是多實(shí)例的,通過AppName確定為同一個(gè)集群
- 執(zhí)行器可以手動(dòng)指定,也可以自動(dòng)發(fā)現(xiàn)

創(chuàng)建成功之后可以在執(zhí)行器列表看到。圖片為編輯頁面,所以可以看到已經(jīng)有機(jī)器地址了。
在調(diào)度中心創(chuàng)建任務(wù)
- JobHandler:需要和業(yè)務(wù)微服務(wù)中創(chuàng)建的任務(wù)名稱一致

新增完畢之后啟動(dòng),如果一切順利,將可以在業(yè)務(wù)微服務(wù)中看到如下log:
2023-10-09 11:50:33.050 DEBUG 34868 --- [6-1696823413294] com.ramble.xxljob.task.DemoJob : do job1 2023-10-09 11:50:38.044 DEBUG 34868 --- [6-1696823413294] com.ramble.xxljob.task.DemoJob : do job1 2023-10-09 11:50:44.100 DEBUG 34868 --- [6-1696823413294] com.ramble.xxljob.task.DemoJob : do job1 2023-10-09 11:50:48.052 DEBUG 34868 --- [6-1696823413294] com.ramble.xxljob.task.DemoJob : do job1 2023-10-09 11:50:53.043 DEBUG 34868 --- [6-1696823413294] com.ramble.xxljob.task.DemoJob : do job1
每5s執(zhí)行了一次任務(wù)
帶前置和后置處理的定時(shí)任務(wù)
XxlJob注解詳解
XxlJob注解有三個(gè)參數(shù):
value:JobHandler的名稱,需要在執(zhí)行器和調(diào)度中心保持一致
init:定時(shí)任務(wù)前置處理,僅在定時(shí)任務(wù)首次運(yùn)行前執(zhí)行一次
destory:定時(shí)任務(wù)后置處理,僅在定時(shí)任務(wù)銷毀的時(shí)候執(zhí)行一次
這里需要注意:
- 一個(gè)定時(shí)任務(wù)可能反復(fù)執(zhí)行多次,例如我們?cè)O(shè)置了固定10s執(zhí)行一次,那么可能每10s就執(zhí)行一次,但是前置處理和后置處理僅執(zhí)行一次,前置處理和后置處理僅針對(duì)整個(gè)任務(wù),而非任務(wù)的一次執(zhí)行
- 在前置處理中拋異常并不會(huì)阻止任務(wù)的創(chuàng)建和執(zhí)行
- 可以在前置處理和后置處理中訪問數(shù)據(jù)庫或者做一些業(yè)務(wù)邏輯
創(chuàng)建帶前(后)置處理的任務(wù)
@Slf4j
@Component
public class DemoJob {
/**
* 創(chuàng)建帶前(后)置處理的任務(wù)
* Job方法添加注解 "@XxlJob(value="自定義jobhandler名稱", init = "JobHandler初始化方法", destroy = "JobHandler銷毀方法")",注解value值對(duì)應(yīng)的是調(diào)度中心新建任務(wù)的JobHandler屬性的值。
* <p>
* 執(zhí)行日志:需要通過 "XxlJobHelper.log" 打印執(zhí)行日志;
* <p>
* 任務(wù)結(jié)果:默認(rèn)任務(wù)結(jié)果為 "成功" 狀態(tài),不需要主動(dòng)設(shè)置;如有訴求,比如設(shè)置任務(wù)結(jié)果為失敗,可以通過 "XxlJobHelper.handleFail/handleSuccess" 自主設(shè)置任務(wù)結(jié)果;
*/
@XxlJob(value = "job2", init = "job2Init", destroy = "job2Destroy")
public void job2() throws InterruptedException {
LocalDateTime now = LocalDateTime.now();
XxlJobHelper.log("進(jìn)入job2,time={}", now.toString());
log.debug("job2 - doSomething ...");
Thread.sleep(2000);
XxlJobHelper.log("離開job2,time={}", now.toString());
}
public void job2Init() {
log.debug("job2Init - doSomething ...");
}
public void job2Destroy() {
log.debug("job2Destroy - doSomething ...");
}
}調(diào)度中心需要?jiǎng)?chuàng)建對(duì)應(yīng)job2的任務(wù)并啟動(dòng)。如果一切順利將在執(zhí)行器控制臺(tái)看到如下log:
2023-10-09 13:31:44.104 DEBUG 35848 --- [7-1696829504104] com.ramble.xxljob.task.DemoJob : job2Init - doSomething ...
2023-10-09 13:31:44.110 DEBUG 35848 --- [7-1696829504104] com.ramble.xxljob.task.DemoJob : job2 - doSomething ...
2023-10-09 13:31:54.052 DEBUG 35848 --- [7-1696829504104] com.ramble.xxljob.task.DemoJob : job2 - doSomething ...
2023-10-09 13:32:04.053 DEBUG 35848 --- [7-1696829504104] com.ramble.xxljob.task.DemoJob : job2 - doSomething ...
2023-10-09 13:32:14.054 DEBUG 35848 --- [7-1696829504104] com.ramble.xxljob.task.DemoJob : job2 - doSomething ...
Disconnected from the target VM, address: '127.0.0.1:50819', transport: 'socket'
2023-10-09 13:32:21.606 INFO 35848 --- [ Thread-4] com.xxl.job.core.server.EmbedServer : >>>>>>>>>>> xxl-job remoting server stop.
2023-10-09 13:32:21.618 INFO 35848 --- [rRegistryThread] c.x.j.c.thread.ExecutorRegistryThread : >>>>>>>>>>> xxl-job registry-remove success, registryParam:RegistryParam{registryGroup='EXECUTOR', registryKey='xxljob-demo-service', registryValue='http://192.168.3.191:9999/'}, registryResult:ReturnT [code=200, msg=null, content=null]
2023-10-09 13:32:21.618 INFO 35848 --- [rRegistryThread] c.x.j.c.thread.ExecutorRegistryThread : >>>>>>>>>>> xxl-job, executor registry thread destroy.
2023-10-09 13:32:21.621 INFO 35848 --- [ionShutdownHook] com.xxl.job.core.server.EmbedServer : >>>>>>>>>>> xxl-job remoting server destroy success.
2023-10-09 13:32:21.622 DEBUG 35848 --- [7-1696829504104] com.ramble.xxljob.task.DemoJob : job2Destroy - doSomething ...
2023-10-09 13:32:21.622 INFO 35848 --- [7-1696829504104] com.xxl.job.core.thread.JobThread : >>>>>>>>>>> xxl-job JobThread stoped, hashCode:Thread[xxl-job, JobThread-27-1696829504104,10,main]
2023-10-09 13:32:21.623 INFO 35848 --- [FileCleanThread] c.x.j.core.thread.JobLogFileCleanThread : >>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destroy.通過log可以觀測(cè)到:
- 執(zhí)行器啟動(dòng)的時(shí)候,在任務(wù)首次運(yùn)行前打印了init方法中的log
- 而后定時(shí)任務(wù)按照既定執(zhí)行策略執(zhí)行
- 當(dāng)執(zhí)行器服務(wù)停止的時(shí)候,打印了destory方法中的log
- 通過XxlJobHelper.log 打印的日志,可以在調(diào)度中心 調(diào)度日志--->操作--->執(zhí)行日志 中看到
父子任務(wù)
當(dāng)兩個(gè)任務(wù)需要關(guān)聯(lián)觸發(fā)的時(shí)候可以使用父子任務(wù)的功能,當(dāng)然了子任務(wù)還可以有子任務(wù)。
這種情況只需要啟動(dòng)父任務(wù),不需要啟動(dòng)子任務(wù),當(dāng)父任務(wù)執(zhí)行成功了,會(huì)觸發(fā)子任務(wù)的啟動(dòng)。當(dāng)父任務(wù)執(zhí)行失敗了,不會(huì)觸發(fā)子任務(wù)的啟動(dòng)。
父子執(zhí)行器
/**
* 父任務(wù)
*/
@XxlJob("jobFather")
public void jobFather() {
// 創(chuàng)建一個(gè)新的隨機(jī)數(shù)生成器
Random random = new Random();
// 生成一個(gè)0到100之間的隨機(jī)整數(shù)
int randomNumber = random.nextInt(101);
if (randomNumber % 2 == 0) {
log.debug("do - jobFather - success");
XxlJobHelper.handleSuccess();
} else {
log.debug("do - jobFather - fail");
XxlJobHelper.handleFail("調(diào)用XxlJobHelper.handleFail,調(diào)度中心就任務(wù)此任務(wù)執(zhí)行失敗");
}
}
/**
* 子任務(wù)
*/
@XxlJob("jobChild")
public void jobChild() {
log.debug("do - jobChild");
}- 父、子執(zhí)行器并沒有什么特殊的地方
- 在調(diào)度中心手動(dòng)關(guān)聯(lián)父、子任務(wù)后,父執(zhí)行器執(zhí)行成功后就會(huì)觸發(fā)子執(zhí)行器執(zhí)行
- 上述父執(zhí)行器中通過XxlJobHelper.handleSuccess() 告訴調(diào)度中心,此任務(wù)執(zhí)行成功了
- 上述父執(zhí)行器中通過XxlJobHelper.handleFail() 告訴調(diào)度中心,此任務(wù)執(zhí)行失敗了,調(diào)度中心將不會(huì)觸發(fā)子任務(wù)
關(guān)聯(lián)父子任務(wù)
- 子任務(wù)、父任務(wù)分別創(chuàng)建
- 然后編輯父任務(wù),將子任務(wù)的id填寫到“子任務(wù)ID”中,此時(shí)就關(guān)聯(lián)上了
- 啟動(dòng)父任務(wù),不需要啟動(dòng)子任務(wù)
- 子任務(wù)的啟動(dòng)交由調(diào)度中心觸發(fā),當(dāng)父任務(wù)執(zhí)行成功了,調(diào)度中心自然會(huì)啟動(dòng)子任務(wù)
- 如果將子任務(wù)啟動(dòng)了,那么子任務(wù)將擁有兩個(gè)觸發(fā)維度,第一是根據(jù)子任務(wù)自身的調(diào)度類型和調(diào)度速度觸發(fā),第二是調(diào)度中心觸發(fā)

執(zhí)行器側(cè)log
2023-10-10 09:13:00.276 INFO 19228 --- [ Thread-4] com.xxl.job.core.server.EmbedServer : >>>>>>>>>>> xxl-job remoting server start success, nettype = class com.xxl.job.core.server.EmbedServer, port = 9999 2023-10-10 09:13:23.549 INFO 19228 --- [Pool-1699379094] c.xxl.job.core.executor.XxlJobExecutor : >>>>>>>>>>> xxl-job regist JobThread success, jobId:29, handler:com.xxl.job.core.handler.impl.MethodJobHandler@2b43f314[class com.ramble.xxljob.task.DemoJob#jobFather] 2023-10-10 09:13:23.552 DEBUG 19228 --- [9-1696900403549] com.ramble.xxljob.task.DemoJob : do - jobFather - fail 2023-10-10 09:13:28.495 DEBUG 19228 --- [9-1696900403549] com.ramble.xxljob.task.DemoJob : do - jobFather - fail 2023-10-10 09:13:34.500 DEBUG 19228 --- [9-1696900403549] com.ramble.xxljob.task.DemoJob : do - jobFather - success 2023-10-10 09:13:34.511 INFO 19228 --- [Pool-1699379094] c.xxl.job.core.executor.XxlJobExecutor : >>>>>>>>>>> xxl-job regist JobThread success, jobId:30, handler:com.xxl.job.core.handler.impl.MethodJobHandler@7e3d2ebd[class com.ramble.xxljob.task.DemoJob#jobChild] 2023-10-10 09:13:34.512 DEBUG 19228 --- [0-1696900414511] com.ramble.xxljob.task.DemoJob : do - jobChild 2023-10-10 09:13:38.494 DEBUG 19228 --- [9-1696900403549] com.ramble.xxljob.task.DemoJob : do - jobFather - fail 2023-10-10 09:13:43.526 DEBUG 19228 --- [9-1696900403549] com.ramble.xxljob.task.DemoJob : do - jobFather - success 2023-10-10 09:13:43.539 DEBUG 19228 --- [0-1696900414511] com.ramble.xxljob.task.DemoJob : do - jobChild
通過日志可以觀察到:
- 一開始僅將父任務(wù)的 JobThread注冊(cè)到了調(diào)度中心
- 而后父任務(wù)按照調(diào)度速度執(zhí)行
- 當(dāng)父任務(wù)執(zhí)行失敗沒有觸發(fā)子任務(wù)執(zhí)行
- 當(dāng)父任務(wù)執(zhí)行成功首先將子任務(wù)的 JobThread 注冊(cè)到了調(diào)度中心,隨即執(zhí)行了子任務(wù)
調(diào)度中心-任務(wù)管理詳解
執(zhí)行器
任務(wù)需要綁定到執(zhí)行器,任務(wù)觸發(fā)調(diào)度時(shí)將會(huì)自動(dòng)發(fā)現(xiàn)注冊(cè)成功的執(zhí)行器, 實(shí)現(xiàn)任務(wù)自動(dòng)發(fā)現(xiàn)功能; 另一方面也可以方便的進(jìn)行任務(wù)分組。每個(gè)任務(wù)必須綁定一個(gè)執(zhí)行器, 可在 "執(zhí)行器管理" 進(jìn)行設(shè)置
路由策略
當(dāng)執(zhí)行器集群部署時(shí),提供豐富的路由策略,包括:
- FIRST(第一個(gè)):固定選擇第一個(gè)機(jī)器;
- LAST(最后一個(gè)):固定選擇最后一個(gè)機(jī)器;
- ROUND(輪詢);
- RANDOM(隨機(jī)):隨機(jī)選擇在線的機(jī)器;
- CONSISTENT_HASH(一致性HASH):每個(gè)任務(wù)按照Hash算法固定選擇某一臺(tái)機(jī)器,且所有任務(wù)均勻散列在不同機(jī)器上。
- LEAST_FREQUENTLY_USED(最不經(jīng)常使用):使用頻率最低的機(jī)器優(yōu)先被選舉;
- LEAST_RECENTLY_USED(最近最久未使用):最久未使用的機(jī)器優(yōu)先被選舉;
- FAILOVER(故障轉(zhuǎn)移):按照順序依次進(jìn)行心跳檢測(cè),第一個(gè)心跳檢測(cè)成功的機(jī)器選定為目標(biāo)執(zhí)行器并發(fā)起調(diào)度;
- BUSYOVER(忙碌轉(zhuǎn)移):按照順序依次進(jìn)行空閑檢測(cè),第一個(gè)空閑檢測(cè)成功的機(jī)器選定為目標(biāo)執(zhí)行器并發(fā)起調(diào)度;
- SHARDING_BROADCAST(分片廣播):廣播觸發(fā)對(duì)應(yīng)集群中所有機(jī)器執(zhí)行一次任務(wù),同時(shí)系統(tǒng)自動(dòng)傳遞分片參數(shù);可根據(jù)分片參數(shù)開發(fā)分片任務(wù);
調(diào)度過期策略
忽略:調(diào)度過期后,忽略過期的任務(wù),從當(dāng)前時(shí)間開始重新計(jì)算下次觸發(fā)時(shí)間
立即執(zhí)行一次:調(diào)度過期后,立即執(zhí)行一次,并從當(dāng)前時(shí)間開始重新計(jì)算下次觸發(fā)時(shí)間
阻塞處理策略
調(diào)度過于密集執(zhí)行器來不及處理時(shí)的處理策略
- 單機(jī)串行(默認(rèn)):調(diào)度請(qǐng)求進(jìn)入單機(jī)執(zhí)行器后,調(diào)度請(qǐng)求進(jìn)入FIFO隊(duì)列并以串行方式運(yùn)行
- 丟棄后續(xù)調(diào)度:調(diào)度請(qǐng)求進(jìn)入單機(jī)執(zhí)行器后,發(fā)現(xiàn)執(zhí)行器存在運(yùn)行的調(diào)度任務(wù),本次請(qǐng)求將會(huì)被丟棄并標(biāo)記為失敗
- 覆蓋之前調(diào)度:調(diào)度請(qǐng)求進(jìn)入單機(jī)執(zhí)行器后,發(fā)現(xiàn)執(zhí)行器存在運(yùn)行的調(diào)度任務(wù),將會(huì)終止運(yùn)行中的調(diào)度任務(wù)并清空隊(duì)列,然后運(yùn)行本次調(diào)度任務(wù)
超時(shí)和重試
- 任務(wù)超時(shí)時(shí)間:支持自定義任務(wù)超時(shí)時(shí)間,任務(wù)運(yùn)行超時(shí)將會(huì)主動(dòng)中斷任務(wù)
- 失敗重試次數(shù);支持自定義任務(wù)失敗重試次數(shù),當(dāng)任務(wù)失敗時(shí)將會(huì)按照預(yù)設(shè)的失敗重試次數(shù)主動(dòng)進(jìn)行重試
到此這篇關(guān)于SpringBoot整合XXLJob的實(shí)現(xiàn)示例的文章就介紹到這了,更多相關(guān)SpringBoot整合XXLJob內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
spring Data jpa簡(jiǎn)介_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
這篇文章主要介紹了spring Data jpa簡(jiǎn)介的相關(guān)資料,需要的朋友可以參考下2017-09-09
使用Java實(shí)現(xiàn)獲取excel附件并解析
在Java中,我們經(jīng)常需要讀取Excel文件中的數(shù)據(jù),進(jìn)行處理和分析,本文將介紹如何使用Java代碼來獲取與解析Excel文件中的附件,希望對(duì)大家有所幫助2025-04-04
Springboot使用java.ext.dirs方式的漏洞解析
文中給大家介紹了java.ext.dirs在Java9后被棄用,導(dǎo)致兼容性、安全性和管理問題,建議采用SpringBoot的自定義類加載器、模塊化系統(tǒng)或容器化技術(shù)(如Docker)替代,以提升隔離性與可維護(hù)性,下文重點(diǎn)解析Springboot使用java.ext.dirs方式的缺陷,感興趣的朋友一起看看吧2025-08-08
MyBatis批量插入/修改/刪除MySql數(shù)據(jù)
這篇文章主要給大家介紹了關(guān)于MyBatis批量插入/修改/刪除MySql數(shù)據(jù)的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-05-05
Spring boot中@Conditional和spring boot的自動(dòng)配置實(shí)例詳解
本文通過實(shí)例給大家介紹了Spring boot中@Conditional和spring boot的自動(dòng)配置,需要的朋友可以參考下2018-05-05

