springboot整合xxl-job實(shí)現(xiàn)分布式定時(shí)任務(wù)的過程
一、前言
定時(shí)任務(wù)有很多種,有一些大的框架也有一些簡(jiǎn)單的實(shí)現(xiàn)。
比如常見的:
- JDK的
Timer和TimerTask Quartz異步任務(wù)調(diào)度框架- 分布式定時(shí)任務(wù)
XXL-JOB - Spring Task注解
@Scheduled
小編也就知道這些,歡迎大佬補(bǔ)充哈??!
今天小編就以現(xiàn)在比較火的分布式定時(shí)任務(wù)xxl-job,優(yōu)點(diǎn)比較輕量級(jí),但是從21年到現(xiàn)在沒有比較大的更新!
現(xiàn)在最新的好像是2.4.0。
二、xxl-job介紹
XXL-JOB是一個(gè)分布式任務(wù)調(diào)度平臺(tái),其核心設(shè)計(jì)目標(biāo)是開發(fā)迅速、學(xué)習(xí)簡(jiǎn)單、輕量級(jí)、易擴(kuò)展?,F(xiàn)已開放源代碼并接入多家公司線上產(chǎn)品線,開箱即用。
它是美團(tuán)大佬:許雪里開發(fā)出來的!
本篇以實(shí)踐教學(xué)為主,介紹大家感興趣可以去官方文檔去看看!
總體架構(gòu)圖:

大家自行拉去最新代碼即可:
三、修改配置
1. 運(yùn)行sql文件

導(dǎo)出到本地?cái)?shù)據(jù)庫:

XXL-JOB調(diào)度模塊基于自研調(diào)度組件并支持集群部署,調(diào)度數(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)用戶表;
2. 修改xxl-job-admin配置
小編修改了一下端口號(hào):
server.port=8087
記得調(diào)整成自己的數(shù)據(jù)庫密碼:
spring.datasource.password=root
由于sql文件導(dǎo)入的直接是個(gè)數(shù)據(jù)庫,不需要我們?cè)谡{(diào)整數(shù)據(jù)庫的名稱!
3. 需修改xxl-job-executor-sample-springboot配置
小編這里修改了端口號(hào):
server.port=8086
第11行:修改為admin的端口
xxl.job.admin.addresses=http://127.0.0.1:8087/xxl-job-admin
第22行:小編9999端口被占用,修改了一下端口
xxl.job.executor.port=9998
4. 添加自己的定時(shí)任務(wù)
@XxlJob("testJobHandler")
public void testJobHandler() throws Exception {
for (int i = 0; i < 5; i++) {
XxlJobHelper.log("這是第" + i + 1 + "條日志!");
System.out.println("這是第" + i + 1 + "次看到我了!");
}
System.out.println("定時(shí)任務(wù)結(jié)束??!");
}
四、運(yùn)行項(xiàng)目
1. 啟動(dòng)項(xiàng)目

2. 登錄
根據(jù)上一步的配置,我們直接端口號(hào)加服務(wù)名字進(jìn)行訪問:
http://localhost:8087/xxl-job-admin/
賬號(hào):admin
密碼:123456

3. xxl-job的好處
自己寫完的定時(shí)任務(wù),可以交給這個(gè)管理,這樣什么時(shí)候運(yùn)行,定時(shí)任務(wù)的執(zhí)行規(guī)則,都可以在可視化的界面進(jìn)行管理和操作,更加的人性化!可以動(dòng)態(tài)的修改cron表達(dá)式,還有日志執(zhí)行情況,這是真的香啊??!
4. 查看執(zhí)行器獲取網(wǎng)址
默認(rèn)已經(jīng)把springboot整合上來了,如果大家是自己新建的模塊可以新增一條,讓管理器管理咱們自己項(xiàng)目的定時(shí)任務(wù),也就是使用@XxlJob的任務(wù)!

5. 新增任務(wù)管理
這里比較智能,一些基本的cron表達(dá)式都可以幫你寫,非常的人性??!
JobHandler:填@XxlJob里面的名字即可,小編這里是:@XxlJob("testJobHandler"),所以是testJobHandler

6. 執(zhí)行任務(wù)
我們這次執(zhí)行一次,看看控制臺(tái)是否打印記錄,看看我們寫的任務(wù)是否執(zhí)行了?。?/p>

任務(wù)參數(shù)隨便輸入,機(jī)器地址為:http://192.168.1.207:9998/,第4步查看的,也就是管理端的地址加端口??!

7. 執(zhí)行成功
我們看到方法成功被執(zhí)行了!!

8. 查看日志

五、總結(jié)
大家看到我的日志還是有執(zhí)行失敗的,原因是開始端口被占用,沒有注意,一直在測(cè)試,一直失?。?!
大家運(yùn)行后一定看看控制臺(tái)有沒有報(bào)錯(cuò),如果是java.net.BindException: Address already in use: bind
那就是端口號(hào)被占用,換一個(gè)就行了!!
也可以看看小編這篇文章,詳細(xì)解決了這個(gè)問題??!
到此這篇關(guān)于springboot整合xxl-job分布式定時(shí)任務(wù)的文章就介紹到這了,更多相關(guān)springboot整合xxl-job定時(shí)任務(wù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- springboot整合 xxl-job及使用步驟
- springboot整合 xxl-job的項(xiàng)目實(shí)踐
- SpringBoot集成xxl-job實(shí)現(xiàn)超牛的定時(shí)任務(wù)的步驟詳解
- springboot整合xxl-job的實(shí)現(xiàn)示例
- xxl-job的部署及springboot集成使用示例詳解
- SpringBoot部署xxl-job方法詳細(xì)講解
- springboot整合xxl-job的示例代碼
- SpringBoot整合Xxl-job實(shí)現(xiàn)定時(shí)任務(wù)的全過程
- Springboot整合xxl-job實(shí)現(xiàn)動(dòng)態(tài)傳參
相關(guān)文章
Spring連接Mysql數(shù)據(jù)庫的實(shí)現(xiàn)步驟
本文主要介紹了Spring連接Mysql數(shù)據(jù)庫的實(shí)現(xiàn)步驟,文中根據(jù)實(shí)例編碼詳細(xì)介紹的十分詳盡,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2022-03-03
Spring Boot詳解各類請(qǐng)求和響應(yīng)的處理方法
平時(shí)只是在用SpringBoot框架,但并沒有詳細(xì)研究過請(qǐng)求和響應(yīng)執(zhí)行的一個(gè)具體過程,所以本文主要來梳理一下SpringBoot請(qǐng)求和響應(yīng)的處理過程2022-07-07
java使用MulticastSocket實(shí)現(xiàn)基于廣播的多人聊天室
這篇文章主要為大家詳細(xì)介紹了java使用MulticastSocket實(shí)現(xiàn)基于廣播的多人聊天室,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2019-01-01

