1. 從零到一為什么我們需要一個(gè)獨(dú)立的定時(shí)任務(wù)調(diào)度器在任何一個(gè)稍具規(guī)模的后端應(yīng)用里定時(shí)任務(wù)都是一個(gè)繞不開(kāi)的話題。你可能需要每天凌晨三點(diǎn)同步一次用戶數(shù)據(jù)或者每隔五分鐘檢查一次訂單狀態(tài)又或者在每周一早上九點(diǎn)給所有用戶發(fā)送一封周報(bào)郵件。最開(kāi)始我們可能會(huì)圖省事直接用Scheduled注解或者在application.yml里配個(gè)cron表達(dá)式項(xiàng)目小的時(shí)候這確實(shí)沒(méi)問(wèn)題。但項(xiàng)目一旦跑起來(lái)問(wèn)題就接踵而至了。最頭疼的就是“單點(diǎn)故障”任務(wù)都跑在一臺(tái)機(jī)器上這臺(tái)機(jī)器一掛所有定時(shí)任務(wù)全停擺業(yè)務(wù)直接受影響。其次是“任務(wù)雪崩”某個(gè)任務(wù)執(zhí)行時(shí)間過(guò)長(zhǎng)或者卡死可能會(huì)拖垮整個(gè)線程池導(dǎo)致其他輕量級(jí)任務(wù)也無(wú)法執(zhí)行。再者就是“管理困難”任務(wù)散落在各個(gè)服務(wù)的代碼里想統(tǒng)一查看執(zhí)行日志、手動(dòng)觸發(fā)一次或者調(diào)整調(diào)度時(shí)間都得去翻代碼、改配置、重啟服務(wù)運(yùn)維成本極高。這時(shí)候一個(gè)中心化的、可視化的、支持高可用的任務(wù)調(diào)度平臺(tái)就成了剛需。XXL-JOB 正是在這種背景下脫穎而出的一款輕量級(jí)分布式任務(wù)調(diào)度框架。它的核心設(shè)計(jì)思想是“調(diào)度中心”與“執(zhí)行器”分離。調(diào)度中心負(fù)責(zé)管理所有任務(wù)的調(diào)度邏輯發(fā)出觸發(fā)指令而執(zhí)行器就是我們的業(yè)務(wù)應(yīng)用它負(fù)責(zé)接收調(diào)度中心的指令執(zhí)行具體的業(yè)務(wù)代碼。這種架構(gòu)天然就支持了分布式部署和水平擴(kuò)展一個(gè)任務(wù)可以被路由到集群中的任何一個(gè)健康實(shí)例上執(zhí)行完美解決了單點(diǎn)問(wèn)題。今天我們不談復(fù)雜的生產(chǎn)集群就從最基礎(chǔ)、也是最關(guān)鍵的第一步開(kāi)始如何在一臺(tái)機(jī)器上快速搭建起一個(gè)可用的 XXL-JOB 調(diào)度中心并且掌握最核心的編程技能——如何用代碼動(dòng)態(tài)地管理任務(wù)。這對(duì)于前期技術(shù)驗(yàn)證、開(kāi)發(fā)測(cè)試環(huán)境搭建乃至一些對(duì)可用性要求不是極高的內(nèi)部應(yīng)用都極具價(jià)值。畢竟不是所有場(chǎng)景都需要一開(kāi)始就上集群。2. 調(diào)度中心的單機(jī)部署避開(kāi)那些“看起來(lái)對(duì)”的坑部署 XXL-JOB 調(diào)度中心本質(zhì)上就是運(yùn)行一個(gè) Spring Boot 應(yīng)用。官方提供了非常便捷的兩種方式下載發(fā)行包直接運(yùn)行或者下載源碼自己編譯。對(duì)于學(xué)習(xí)和測(cè)試我強(qiáng)烈建議選擇前者能幫你避開(kāi)不少環(huán)境依賴的坑。2.1 環(huán)境準(zhǔn)備與源碼獲取首先確保你的機(jī)器上已經(jīng)安裝了 JDK1.8和 Maven3.0。這是編譯和運(yùn)行的基礎(chǔ)。接下來(lái)是獲取代碼。不要想當(dāng)然地去 GitHub 搜一個(gè)看起來(lái)像的倉(cāng)庫(kù)最穩(wěn)妥的方式永遠(yuǎn)是訪問(wèn)官方文檔。XXL-JOB 的官方倉(cāng)庫(kù)在 GitHub 上項(xiàng)目地址是xuxueli/xxl-job。你可以通過(guò)git clone命令拉取或者直接下載 ZIP 壓縮包。這里有個(gè)小技巧直接下載最新 Release 版本的源碼包通常比拉取主分支master更穩(wěn)定因?yàn)?Release 版本是經(jīng)過(guò)測(cè)試的。# 方式一克隆倉(cāng)庫(kù)網(wǎng)絡(luò)需穩(wěn)定 git clone https://github.com/xuxueli/xxl-job.git # 方式二更推薦訪問(wèn) https://github.com/xuxueli/xxl-job/releases # 下載最新版本的 Source code (zip) 文件比如 xxl-job-2.4.0.zip解壓后目錄結(jié)構(gòu)清晰可見(jiàn)。我們重點(diǎn)關(guān)注xxl-job-admin模塊這就是調(diào)度中心的管理后臺(tái)。2.2 數(shù)據(jù)庫(kù)初始化字符集與驅(qū)動(dòng)版本的隱秘陷阱XXL-JOB 的所有調(diào)度數(shù)據(jù)任務(wù)、日志、執(zhí)行器等都需要存儲(chǔ)在關(guān)系型數(shù)據(jù)庫(kù)中它支持 MySQL 等主流數(shù)據(jù)庫(kù)。執(zhí)行目錄/doc/db/tables_xxl_job.sql下的腳本就能創(chuàng)建所需的表。這個(gè)過(guò)程看似簡(jiǎn)單卻有兩個(gè)高頻踩坑點(diǎn)數(shù)據(jù)庫(kù)字符集務(wù)必使用utf8mb4字符集。utf8在 MySQL 中是一個(gè)“閹割版”最大只支持3字節(jié)字符無(wú)法存儲(chǔ)完整的 Emoji 或某些生僻字。如果建表時(shí)沒(méi)指定默認(rèn)可能是latin1或utf8未來(lái)任務(wù)描述等信息一旦包含4字節(jié)字符就會(huì)報(bào)錯(cuò)。安全的做法是在連接數(shù)據(jù)庫(kù)后先執(zhí)行SET NAMES utf8mb4;然后再運(yùn)行建表 SQL。MySQL 驅(qū)動(dòng)版本項(xiàng)目pom.xml中默認(rèn)引用的 MySQL 驅(qū)動(dòng)版本可能較老如mysql-connector-java5.x。如果你本地安裝的是 MySQL 8.0高版本驅(qū)動(dòng)在連接 URL 和身份驗(yàn)證插件上都有變化直接運(yùn)行會(huì)導(dǎo)致Public Key Retrieval is not allowed或Authentication plugin ‘caching_sha2_password‘ cannot be loaded這類錯(cuò)誤。解決方案是在xxl-job-admin的pom.xml中顯式地將驅(qū)動(dòng)依賴升級(jí)到 8.0.x 版本并調(diào)整連接字符串。!-- 在 xxl-job-admin 的 pom.xml 中修改 -- dependency groupIdmysql/groupId artifactIdmysql-connector-java/artifactId version8.0.33/version !-- 版本號(hào)根據(jù)你的MySQL調(diào)整 -- /dependency同時(shí)在配置文件中連接 URL 需要添加時(shí)區(qū)和允許公鑰檢索的參數(shù)spring.datasource.urljdbc:mysql://localhost:3306/xxl_job?useUnicodetruecharacterEncodingUTF-8autoReconnecttrueserverTimezoneAsia/ShanghaiallowPublicKeyRetrievaltrue spring.datasource.usernameroot spring.datasource.passwordyour_password2.3 核心配置修改不止是改個(gè)數(shù)據(jù)庫(kù)地址數(shù)據(jù)庫(kù)準(zhǔn)備好后需要修改調(diào)度中心的配置文件。配置文件位于xxl-job-admin/src/main/resources/application.properties或application.yml。你需要修改的遠(yuǎn)不止數(shù)據(jù)庫(kù)連接。以下幾個(gè)配置項(xiàng)關(guān)乎調(diào)度中心能否正常啟動(dòng)和工作server.port調(diào)度中心服務(wù)端口默認(rèn) 8080按需修改。spring.datasource.*如上所述配置你的數(shù)據(jù)庫(kù)連接。xxl.job.accessToken可選但重要調(diào)度中心和執(zhí)行器之間的通信令牌。如果為空表示不進(jìn)行鑒權(quán)。在生產(chǎn)環(huán)境或任何有安全顧慮的環(huán)境務(wù)必設(shè)置一個(gè)強(qiáng)令牌。否則任何知道調(diào)度中心地址的程序都可以偽裝成執(zhí)行器來(lái)注冊(cè)或觸發(fā)任務(wù)存在安全風(fēng)險(xiǎn)。xxl.job.i18n默認(rèn)是zh_CN中文如果你需要英文界面可以改為en。logging.level.com.xxl.job調(diào)試時(shí)可以設(shè)置為DEBUG能看到更詳細(xì)的調(diào)度日志方便排查問(wèn)題。2.4 編譯與啟動(dòng)區(qū)分“編譯環(huán)境”與“運(yùn)行環(huán)境”配置修改完成后在項(xiàng)目根目錄執(zhí)行mvn clean package -DskipTests進(jìn)行編譯打包。打包成功后在xxl-job-admin/target/目錄下會(huì)生成xxl-job-admin-2.4.0.jar版本號(hào)可能不同。這里有一個(gè)關(guān)鍵認(rèn)知編譯環(huán)境和運(yùn)行環(huán)境是分離的。你完全可以在 A 機(jī)器上編譯好這個(gè) JAR 包然后復(fù)制到 B 機(jī)器甚至是沒(méi)有 Maven、沒(méi)有源碼的機(jī)器上去運(yùn)行。運(yùn)行命令非常簡(jiǎn)單java -jar xxl-job-admin-2.4.0.jar啟動(dòng)后訪問(wèn)http://localhost:8080/xxl-job-admin端口根據(jù)你的配置就能看到登錄界面。默認(rèn)賬號(hào)密碼是admin/123456。登錄成功后一個(gè)功能完整的調(diào)度中心管理后臺(tái)就展現(xiàn)在你面前了。至此調(diào)度中心單機(jī)部署完成。但我們的目標(biāo)不止于此我們要讓這個(gè)調(diào)度中心能指揮我們的業(yè)務(wù)代碼干活。3. 執(zhí)行器集成你的業(yè)務(wù)應(yīng)用如何“被調(diào)度”調(diào)度中心是“大腦”執(zhí)行器就是“手腳”。我們需要在自己的 Spring Boot 業(yè)務(wù)應(yīng)用中集成 XXL-JOB 的執(zhí)行器客戶端讓它能夠接收大腦的指令。3.1 依賴引入與基礎(chǔ)配置首先在你的業(yè)務(wù)項(xiàng)目的pom.xml中添加 XXL-JOB 執(zhí)行器客戶端的依賴。同樣請(qǐng)注意版本與調(diào)度中心保持一致。dependency groupIdcom.xuxueli/groupId artifactIdxxl-job-core/artifactId version2.4.0/version /dependency接著在application.yml中配置執(zhí)行器的核心參數(shù)。這些參數(shù)決定了執(zhí)行器是誰(shuí)、在哪、如何聯(lián)系調(diào)度中心。xxl: job: admin: addresses: http://localhost:8080/xxl-job-admin # 調(diào)度中心地址集群用逗號(hào)分隔 accessToken: # 與調(diào)度中心配置的accessToken一致若無(wú)則留空 executor: appname: xxl-job-executor-sample # 執(zhí)行器AppName是調(diào)度中心識(shí)別該集群的唯一標(biāo)識(shí) address: # 執(zhí)行器地址默認(rèn)自動(dòng)注冊(cè)時(shí)留空 ip: # 執(zhí)行器IP自動(dòng)注冊(cè)時(shí)留空調(diào)度中心會(huì)自動(dòng)獲取 port: 9999 # 執(zhí)行器端口默認(rèn)9999內(nèi)置Jetty服務(wù)器用于接收調(diào)度請(qǐng)求 logpath: /data/applogs/xxl-job/jobhandler # 任務(wù)日志文件存儲(chǔ)路徑 logretentiondays: 30 # 日志保留天數(shù)重點(diǎn)解析appname和addressappname這是一個(gè)邏輯名稱代表一組執(zhí)行器實(shí)例。比如你的“訂單服務(wù)”部署了3臺(tái)機(jī)器它們都應(yīng)該配置相同的appname如order-service-executor。調(diào)度中心會(huì)根據(jù)這個(gè)名稱來(lái)找到這一組執(zhí)行器進(jìn)行任務(wù)的路由和故障轉(zhuǎn)移。address這是執(zhí)行器的網(wǎng)絡(luò)地址格式為IP:PORT。這里有個(gè)非常重要的模式選擇自動(dòng)注冊(cè)vs手動(dòng)錄入。自動(dòng)注冊(cè)推薦將address留空。執(zhí)行器啟動(dòng)后會(huì)主動(dòng)向調(diào)度中心admin.addresses發(fā)起注冊(cè)上報(bào)自己的ip:port。調(diào)度中心會(huì)動(dòng)態(tài)維護(hù)這個(gè)執(zhí)行器地址列表。這種方式適合動(dòng)態(tài)伸縮的云環(huán)境。手動(dòng)錄入在配置文件中寫死address: 192.168.1.100:9999。同時(shí)你還需要提前到調(diào)度中心管理后臺(tái)的“執(zhí)行器管理”頁(yè)面手動(dòng)添加一個(gè)AppName為xxl-job-executor-sample的執(zhí)行器并在其下“手動(dòng)錄入”這個(gè)地址。這種方式更靜態(tài)常用于網(wǎng)絡(luò)隔離嚴(yán)格的環(huán)境。3.2 配置類與執(zhí)行器Bean聲明光有配置還不夠需要在 Spring 的上下文中聲明執(zhí)行器組件。創(chuàng)建一個(gè)配置類例如XxlJobConfigimport com.xxl.job.core.executor.impl.XxlJobSpringExecutor; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; Configuration public class XxlJobConfig { private Logger logger LoggerFactory.getLogger(XxlJobConfig.class); 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() { logger.info( 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; } }這個(gè)XxlJobSpringExecutorBean 在初始化時(shí)會(huì)完成與調(diào)度中心的連接和注冊(cè)?？吹娇刂婆_(tái)打印出 xxl-job config init.以及后續(xù)的注冊(cè)成功日志就說(shuō)明執(zhí)行器集成成功了。3.3 定義你的第一個(gè)任務(wù)處理器JobHandler執(zhí)行器準(zhǔn)備好了接下來(lái)要定義它具體能執(zhí)行什么任務(wù)。XXL-JOB 的任務(wù)以“JobHandler”為單位一個(gè) Handler 對(duì)應(yīng)一種業(yè)務(wù)邏輯。創(chuàng)建任務(wù)處理器非常簡(jiǎn)單只需在方法上添加X(jué)xlJob注解。import com.xxl.job.core.handler.annotation.XxlJob; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; Component public class SampleXxlJob { private static Logger logger LoggerFactory.getLogger(SampleXxlJob.class); /** * 一個(gè)簡(jiǎn)單的示例任務(wù) * 1. 在調(diào)度中心新增一個(gè)任務(wù)JobHandler 填寫此處注解的值 “demoJobHandler” * 2. 調(diào)度中心觸發(fā)調(diào)度時(shí)會(huì)自動(dòng)調(diào)用此方法 */ XxlJob(demoJobHandler) public void demoJobHandler() throws Exception { logger.info(XXL-JOB, Hello World.); // 這里編寫你的業(yè)務(wù)邏輯比如調(diào)用某個(gè)Service // 任務(wù)執(zhí)行結(jié)果默認(rèn)返回 ReturnT.SUCCESS 即表示成功 // 可以通過(guò) ReturnT.FAIL 返回失敗并可在管理后臺(tái)查看失敗日志 } /** * 一個(gè)帶參數(shù)的任務(wù)示例 * 調(diào)度中心觸發(fā)時(shí)可以將參數(shù)傳遞過(guò)來(lái) */ XxlJob(paramJobHandler) public ReturnTString paramJobHandler(String param) throws Exception { logger.info(XXL-JOB, 接收到的參數(shù)是{}, param); if (error.equals(param)) { // 模擬任務(wù)失敗 return new ReturnT(ReturnT.FAIL_CODE, 任務(wù)執(zhí)行失敗參數(shù)為error); } // 模擬一些處理 String result 處理成功參數(shù)是 param; return new ReturnT(result); } }關(guān)鍵點(diǎn)說(shuō)明XxlJob注解的 value 是JobHandler 的名稱這個(gè)名稱必須在整個(gè)執(zhí)行器應(yīng)用內(nèi)唯一。它是調(diào)度中心調(diào)用任務(wù)時(shí)的“鑰匙”。方法返回值可以是void或ReturnTString。返回ReturnT.SUCCESS或void默認(rèn)成功表示任務(wù)執(zhí)行成功返回ReturnT.FAIL表示失敗調(diào)度中心會(huì)記錄失敗次數(shù)并根據(jù)任務(wù)配置的重試策略決定是否重試。方法可以接收一個(gè)String param參數(shù)這個(gè)參數(shù)來(lái)自于調(diào)度中心任務(wù)配置里的“任務(wù)參數(shù)”字段。你可以用它來(lái)動(dòng)態(tài)控制任務(wù)行為。啟動(dòng)你的業(yè)務(wù)應(yīng)用如果配置正確在調(diào)度中心管理后臺(tái)的“執(zhí)行器管理”頁(yè)面應(yīng)該能看到你配置的appname對(duì)應(yīng)的執(zhí)行器并且其地址列表里已經(jīng)自動(dòng)注冊(cè)上了你的應(yīng)用地址IP:9999。至此執(zhí)行器就緒任務(wù)處理器就緒就差最后一步在調(diào)度中心創(chuàng)建任務(wù)將它們關(guān)聯(lián)起來(lái)。4. 在調(diào)度中心手動(dòng)創(chuàng)建與管理任務(wù)在能夠用代碼操控一切之前我們先通過(guò)管理后臺(tái)熟悉一下任務(wù)的核心屬性。登錄調(diào)度中心進(jìn)入“任務(wù)管理”頁(yè)面點(diǎn)擊“新增”。一個(gè)任務(wù)的核心配置包括執(zhí)行器選擇你剛剛注冊(cè)上來(lái)的那個(gè)執(zhí)行器 AppName。任務(wù)描述給人看的任務(wù)說(shuō)明。路由策略當(dāng)執(zhí)行器有多個(gè)實(shí)例時(shí)調(diào)度請(qǐng)求發(fā)給誰(shuí)常用“第一個(gè)”、“輪詢”、“隨機(jī)”等。Cron任務(wù)的調(diào)度時(shí)間表達(dá)式如0 0 3 * * ?表示每天凌晨3點(diǎn)執(zhí)行。運(yùn)行模式最常用的是 “BEAN”對(duì)應(yīng)我們代碼中用XxlJob注解定義的方法。JobHandler填寫你的任務(wù)處理器方法上XxlJob注解里定義的名稱如demoJobHandler。任務(wù)參數(shù)傳遞給任務(wù)處理器的字符串參數(shù)。阻塞處理策略如果上一次調(diào)度還沒(méi)執(zhí)行完下一次調(diào)度時(shí)間又到了怎么辦“單機(jī)串行”會(huì)排隊(duì)“丟棄后續(xù)調(diào)度”會(huì)忽略“覆蓋之前調(diào)度”會(huì)終止上一次運(yùn)行慎用。失敗重試次數(shù)任務(wù)執(zhí)行失敗后自動(dòng)重試的次數(shù)。報(bào)警郵箱任務(wù)失敗后通知誰(shuí)的郵箱。填寫完畢保存后任務(wù)處于“停止”狀態(tài)。你需要點(diǎn)擊操作欄的“啟動(dòng)”按鈕調(diào)度中心才會(huì)開(kāi)始按照 Cron 表達(dá)式進(jìn)行調(diào)度。點(diǎn)擊“執(zhí)行一次”可以手動(dòng)立即觸發(fā)一次用于測(cè)試。在“調(diào)度日志”里可以查看每一次觸發(fā)的詳細(xì)記錄、執(zhí)行結(jié)果和耗時(shí)。手動(dòng)操作雖然直觀但在實(shí)際開(kāi)發(fā)中我們常常需要更靈活的控制比如根據(jù)系統(tǒng)條件動(dòng)態(tài)創(chuàng)建臨時(shí)任務(wù)或者在應(yīng)用啟動(dòng)時(shí)自動(dòng)初始化一批任務(wù)。這就需要我們通過(guò) XXL-JOB 提供的 API 來(lái)編程式地操作任務(wù)。5. 編程式任務(wù)管理深入調(diào)度中心API的調(diào)用細(xì)節(jié)XXL-JOB 調(diào)度中心提供了一套 RESTful 風(fēng)格的 HTTP API允許我們遠(yuǎn)程進(jìn)行任務(wù)的管理操作。官方源碼中的xxl-job-admin模塊其實(shí)就包含了這些 API 的調(diào)用示例XxlJobInfoController我們可以從中學(xué)習(xí)并封裝自己的客戶端。5.1 API調(diào)用原理與認(rèn)證所有對(duì)調(diào)度中心的操作本質(zhì)上都是向特定的 URL 發(fā)送 HTTP 請(qǐng)求。這些 API 接口位于調(diào)度中心項(xiàng)目?jī)?nèi)通常以/jobinfo、/jobgroup等為路徑。最重要的安全環(huán)節(jié)是認(rèn)證。調(diào)度中心默認(rèn)開(kāi)啟了登錄攔截。這意味著你直接調(diào)用/jobinfo/add接口會(huì)返回登錄頁(yè)面。因此你的調(diào)用程序必須首先模擬登錄獲取到有效的 CookieSession并在后續(xù)的請(qǐng)求中攜帶這個(gè) Cookie。模擬登錄的流程是POST請(qǐng)求到/login接口攜帶表單數(shù)據(jù)userNameadminpassword123456ifRememberon。從響應(yīng)頭中提取Set-Cookie字段的值通常是XXL_JOB_LOGIN_IDENTITYxxxxxxxx。將這個(gè) Cookie 字符串設(shè)置為后續(xù)所有 API 請(qǐng)求的Cookie請(qǐng)求頭。這是一個(gè)非常關(guān)鍵且容易被忽略的步驟。很多同學(xué)調(diào)用 API 失敗第一個(gè)要檢查的就是登錄狀態(tài)和 Cookie 是否正確傳遞。5.2 封裝一個(gè)簡(jiǎn)易的Java客戶端為了方便我們可以封裝一個(gè)簡(jiǎn)單的工具類。這里使用 Spring 的RestTemplate作為 HTTP 客戶端。import org.springframework.http.*; import org.springframework.util.LinkedMultiValueMap; import org.springframework.util.MultiValueMap; import org.springframework.web.client.RestTemplate; import java.util.List; public class XxlJobClient { private String adminAddresses; // 調(diào)度中心地址如 http://localhost:8080/xxl-job-admin private String cookie; // 登錄后的Cookie private RestTemplate restTemplate; public XxlJobClient(String adminAddresses, String username, String password) { this.adminAddresses adminAddresses.endsWith(/) ? adminAddresses : adminAddresses /; this.restTemplate new RestTemplate(); login(username, password); } private void login(String username, String password) { String loginUrl adminAddresses login; HttpHeaders headers new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED); MultiValueMapString, String params new LinkedMultiValueMap(); params.add(userName, username); params.add(password, password); params.add(ifRemember, on); HttpEntityMultiValueMapString, String request new HttpEntity(params, headers); ResponseEntityString response restTemplate.postForEntity(loginUrl, request, String.class); ListString cookies response.getHeaders().get(HttpHeaders.SET_COOKIE); if (cookies ! null !cookies.isEmpty()) { // 通常我們只需要 XXL_JOB_LOGIN_IDENTITY 這個(gè)Cookie for (String c : cookies) { if (c.startsWith(XXL_JOB_LOGIN_IDENTITY)) { this.cookie c.split(;)[0]; // 取分號(hào)前的部分 break; } } } if (this.cookie null) { throw new RuntimeException(XXL-JOB Admin 登錄失敗無(wú)法獲取Cookie); } } private HttpHeaders createHeadersWithCookie() { HttpHeaders headers new HttpHeaders(); headers.add(HttpHeaders.COOKIE, this.cookie); headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED); return headers; } // 后續(xù)的增刪改查方法都將使用 createHeadersWithCookie() 來(lái)構(gòu)建請(qǐng)求頭 }這個(gè)客戶端在構(gòu)造時(shí)自動(dòng)完成登錄并保存了有效的 Cookie。接下來(lái)我們基于它來(lái)實(shí)現(xiàn)核心的增、刪、啟、停操作。5.3 核心操作一添加任務(wù)Add添加任務(wù)對(duì)應(yīng)調(diào)度中心的“新增”操作。我們需要構(gòu)建一個(gè)包含所有任務(wù)參數(shù)的請(qǐng)求體。import com.alibaba.fastjson.JSON; import org.springframework.util.LinkedMultiValueMap; import org.springframework.util.MultiValueMap; import java.util.HashMap; import java.util.Map; public class XxlJobClient { // ... 之前的 login 和 createHeadersWithCookie 方法 /** * 添加一個(gè)調(diào)度任務(wù) * param jobInfo 任務(wù)信息Map * return 操作結(jié)果 */ public String addJob(MapString, String jobInfo) { String url adminAddresses jobinfo/add; HttpHeaders headers createHeadersWithCookie(); // 注意調(diào)度中心接收的是 form-data 格式 MultiValueMapString, String params new LinkedMultiValueMap(); // 將Map中的所有鍵值對(duì)放入MultiValueMap jobInfo.forEach(params::add); HttpEntityMultiValueMapString, String request new HttpEntity(params, headers); ResponseEntityString response restTemplate.postForEntity(url, request, String.class); return response.getBody(); // 返回的通常是JSON包含code和msg } // 使用示例 public void testAddJob() { MapString, String job new HashMap(); job.put(jobGroup, 2); // 執(zhí)行器ID需要在“執(zhí)行器管理”頁(yè)面查看對(duì)應(yīng)執(zhí)行器的ID job.put(jobDesc, 動(dòng)態(tài)創(chuàng)建的測(cè)試任務(wù)); job.put(author, 開(kāi)發(fā)者); job.put(scheduleType, CRON); // 調(diào)度類型CRON 或 FIX_RATE job.put(scheduleConf, 0/30 * * * * ?); // Cron表達(dá)式每30秒一次 job.put(glueType, BEAN); // 運(yùn)行模式 job.put(executorHandler, demoJobHandler); // JobHandler名稱 job.put(executorParam, testParam123); // 任務(wù)參數(shù) job.put(executorRouteStrategy, FIRST); // 路由策略 job.put(misfireStrategy, DO_NOTHING); // 調(diào)度過(guò)期策略 job.put(executorBlockStrategy, SERIAL_EXECUTION); // 阻塞處理策略 job.put(executorTimeout, 0); // 任務(wù)執(zhí)行超時(shí)時(shí)間(秒)0為不限制 job.put(executorFailRetryCount, 0); // 失敗重試次數(shù) String result addJob(job); System.out.println(添加任務(wù)結(jié)果 result); // 成功結(jié)果示例{code:200, msg:success, content:null} // 失敗結(jié)果示例{code:500, msg:執(zhí)行器不存在, content:null} } }關(guān)鍵參數(shù)解析jobGroup這是執(zhí)行器ID一個(gè)數(shù)字。它不是你配置的appname而是調(diào)度中心數(shù)據(jù)庫(kù)xxl_job_group表的主鍵 ID。你必須在調(diào)用 API 前通過(guò)管理后臺(tái)或查詢數(shù)據(jù)庫(kù)找到你目標(biāo)執(zhí)行器對(duì)應(yīng)的id。這是 API 調(diào)用中最容易出錯(cuò)的地方之一。scheduleConf當(dāng)scheduleType為CRON時(shí)這里填 Cron 表達(dá)式為FIX_RATE時(shí)這里填一個(gè)整數(shù)秒表示固定速率。glueType我們使用代碼定義 Handler所以固定填BEAN。如果是“GLUE”模式在線編輯腳本則填其他類型。5.4 核心操作二啟動(dòng)與停止任務(wù)Start/Stop啟動(dòng)和停止任務(wù)實(shí)際上是更新任務(wù)的“狀態(tài)”字段。在 XXL-JOB 中任務(wù)狀態(tài)triggerStatus為 0 表示停止1 表示啟動(dòng)。public class XxlJobClient { // ... /** * 啟動(dòng)任務(wù) * param jobId 任務(wù)ID添加任務(wù)成功后返回的ID或從列表查詢得到 * return 操作結(jié)果 */ public String startJob(int jobId) { return updateJobStatus(jobId, 1); // 1 代表啟動(dòng) } /** * 停止任務(wù) * param jobId 任務(wù)ID * return 操作結(jié)果 */ public String stopJob(int jobId) { return updateJobStatus(jobId, 0); // 0 代表停止 } private String updateJobStatus(int jobId, int status) { String url adminAddresses jobinfo/start; // 啟動(dòng)和停止是同一個(gè)接口通過(guò)參數(shù)控制 HttpHeaders headers createHeadersWithCookie(); MultiValueMapString, String params new LinkedMultiValueMap(); params.add(id, String.valueOf(jobId)); // 接口根據(jù)傳入的 status 值判斷是啟動(dòng)還是停止 // 但查看源碼發(fā)現(xiàn)/start 接口內(nèi)部是固定將狀態(tài)改為1/stop 接口改為0 // 因此更準(zhǔn)確的做法是調(diào)用不同的端點(diǎn) if (status 1) { url adminAddresses jobinfo/start; } else { url adminAddresses jobinfo/stop; } HttpEntityMultiValueMapString, String request new HttpEntity(params, headers); ResponseEntityString response restTemplate.postForEntity(url, request, String.class); return response.getBody(); } }注意啟動(dòng)/停止接口需要的是任務(wù)的id。這個(gè)id在你調(diào)用addJob成功后的返回值里content字段可能會(huì)包含但官方接口返回的content通常是null。更通用的做法是在添加任務(wù)后通過(guò)“任務(wù)描述”等字段調(diào)用查詢接口獲取到新創(chuàng)建任務(wù)的完整信息其中就包含id。5.5 核心操作三刪除任務(wù)Remove刪除任務(wù)的 API 相對(duì)簡(jiǎn)單。public class XxlJobClient { // ... /** * 刪除任務(wù) * param jobId 任務(wù)ID * return 操作結(jié)果 */ public String removeJob(int jobId) { String url adminAddresses jobinfo/remove; HttpHeaders headers createHeadersWithCookie(); MultiValueMapString, String params new LinkedMultiValueMap(); params.add(id, String.valueOf(jobId)); HttpEntityMultiValueMapString, String request new HttpEntity(params, headers); ResponseEntityString response restTemplate.postForEntity(url, request, String.class); return response.getBody(); } }5.6 核心操作四觸發(fā)執(zhí)行一次Trigger除了定時(shí)調(diào)度我們經(jīng)常需要手動(dòng)觸發(fā)一次任務(wù)執(zhí)行用于測(cè)試或應(yīng)急處理。public class XxlJobClient { // ... /** * 觸發(fā)執(zhí)行一次任務(wù) * param jobId 任務(wù)ID * param executorParam 本次觸發(fā)執(zhí)行的參數(shù)可覆蓋任務(wù)默認(rèn)參數(shù) * return 操作結(jié)果 */ public String triggerJob(int jobId, String executorParam) { String url adminAddresses jobinfo/trigger; HttpHeaders headers createHeadersWithCookie(); MultiValueMapString, String params new LinkedMultiValueMap(); params.add(id, String.valueOf(jobId)); params.add(executorParam, executorParam); // 可選參數(shù) HttpEntityMultiValueMapString, String request new HttpEntity(params, headers); ResponseEntityString response restTemplate.postForEntity(url, request, String.class); return response.getBody(); } }這個(gè)調(diào)用會(huì)立即向執(zhí)行器發(fā)送一次調(diào)度請(qǐng)求并在“調(diào)度日志”中生成一條記錄。executorParam參數(shù)是可選的如果傳遞了會(huì)臨時(shí)覆蓋任務(wù)配置中的默認(rèn)參數(shù)。6. 實(shí)戰(zhàn)中的避坑指南與進(jìn)階思考將上述代碼片段組合起來(lái)你就能在自己的業(yè)務(wù)系統(tǒng)中通過(guò)編程的方式動(dòng)態(tài)管理 XXL-JOB 的任務(wù)了。但在實(shí)際集成和使用中還有一些細(xì)節(jié)需要特別注意。6.1 Cookie 過(guò)期與會(huì)話管理通過(guò)模擬登錄獲取的 CookieSession是有有效期的。調(diào)度中心默認(rèn)的會(huì)話超時(shí)時(shí)間可以在其配置文件中設(shè)置。如果你的客戶端程序是長(zhǎng)時(shí)間運(yùn)行的服務(wù)比如一個(gè)常駐的后臺(tái)管理服務(wù)就需要處理 Cookie 過(guò)期的問(wèn)題。有兩種思路被動(dòng)刷新在每次 API 調(diào)用后檢查返回值。如果返回的 HTTP 狀態(tài)碼是 302 跳轉(zhuǎn)到登錄頁(yè)或者返回的 JSON 中code是特定的未登錄錯(cuò)誤碼則重新調(diào)用login方法獲取新的 Cookie并重試失敗的請(qǐng)求。主動(dòng)刷新啟動(dòng)一個(gè)定時(shí)任務(wù)每隔一段時(shí)間比如會(huì)話超時(shí)時(shí)間的一半重新登錄一次刷新本地的 Cookie 緩存。6.2 執(zhí)行器IDjobGroup的動(dòng)態(tài)獲取如前所述jobGroup是數(shù)字 ID 而非appname。硬編碼顯然不可取。更優(yōu)雅的方式是在程序初始化時(shí)通過(guò)調(diào)用調(diào)度中心的“執(zhí)行器管理”相關(guān) API如查詢接口根據(jù)appname查詢到對(duì)應(yīng)的id并緩存起來(lái)。調(diào)度中心提供了/jobgroup/pageList等接口可以查詢執(zhí)行器列表。6.3 錯(cuò)誤處理與重試機(jī)制網(wǎng)絡(luò)調(diào)用總是不穩(wěn)定的。你的客戶端需要對(duì) HTTP 超時(shí)、連接拒絕、服務(wù)端返回錯(cuò)誤等情況進(jìn)行妥善處理。對(duì)于非冪等的操作如添加任務(wù)重試需要謹(jǐn)慎最好結(jié)合唯一性校驗(yàn)比如通過(guò)“任務(wù)描述”先查詢是否已存在。對(duì)于啟動(dòng)、停止、觸發(fā)等操作可以加入簡(jiǎn)單的重試邏輯。6.4 任務(wù)配置的版本管理與回滾當(dāng)你通過(guò)代碼批量創(chuàng)建或修改了大量任務(wù)后如何管理這些配置一種好的實(shí)踐是將任務(wù)的核心配置如jobDesc,scheduleConf,executorHandler等以配置文件或數(shù)據(jù)庫(kù)表的形式進(jìn)行管理。你的客戶端程序在啟動(dòng)時(shí)讀取這份“期望狀態(tài)”的配置與調(diào)度中心現(xiàn)有的任務(wù)進(jìn)行對(duì)比通過(guò)查詢 API然后進(jìn)行同步增、刪、改。這類似于 Infrastructure as Code (IaC) 的思想便于版本控制和回滾。6.5 面向生產(chǎn)環(huán)境的考量本文聚焦于單機(jī)部署和代碼集成這是理解和上手 XXL-JOB 的絕佳起點(diǎn)。但一旦邁向生產(chǎn)環(huán)境你需要考慮更多調(diào)度中心高可用部署多個(gè)調(diào)度中心實(shí)例通過(guò) Nginx 等負(fù)載均衡器做代理并共享同一個(gè)數(shù)據(jù)庫(kù)。這樣即使一個(gè)調(diào)度中心宕機(jī)其他的可以立刻接管。執(zhí)行器彈性伸縮在 Kubernetes 或云平臺(tái)上執(zhí)行器實(shí)例可以動(dòng)態(tài)擴(kuò)縮容。只要它們配置相同的appname并正確注冊(cè)調(diào)度中心就能自動(dòng)感知。任務(wù)分片廣播XXL-JOB 支持“分片廣播”任務(wù)這對(duì)于處理海量數(shù)據(jù)非常有用。一個(gè)任務(wù)可以被所有執(zhí)行器實(shí)例同時(shí)執(zhí)行每個(gè)實(shí)例通過(guò)分片參數(shù)知道自己該處理哪一部分?jǐn)?shù)據(jù)。任務(wù)依賴復(fù)雜的工作流可以通過(guò)“子任務(wù)”功能實(shí)現(xiàn)依賴一個(gè)任務(wù)成功執(zhí)行后會(huì)自動(dòng)觸發(fā)下一個(gè)任務(wù)。從單機(jī)安裝到代碼集成再到思考生產(chǎn)實(shí)踐這條路徑清晰地展示了一個(gè)工具如何從一個(gè)簡(jiǎn)單的需求點(diǎn)逐步演變?yōu)橹侮P(guān)鍵業(yè)務(wù)的基礎(chǔ)設(shè)施。XXL-JOB 的魅力在于它的簡(jiǎn)潔與強(qiáng)大并存通過(guò)清晰的架構(gòu)設(shè)計(jì)它讓復(fù)雜的分布式任務(wù)調(diào)度變得易于理解和掌控。當(dāng)你親手通過(guò)代碼讓一個(gè)任務(wù)在遠(yuǎn)程服務(wù)器上按時(shí)跑起來(lái)時(shí)那種對(duì)系統(tǒng)掌控感的確立正是后端工程師成長(zhǎng)的樂(lè)趣所在。