什么是定時(shí)任務(wù) xxl-job架構(gòu)設(shè)計(jì)方案

一.定時(shí)任務(wù)概述

1.定時(shí)任務(wù)認(rèn)識(shí)

1.1.什么是定時(shí)任務(wù)

定時(shí)任務(wù)是按照指定時(shí)間周期運(yùn)行任務(wù)。使用場景為在某個(gè)固定時(shí)間點(diǎn)執(zhí)行，或者周期性的去執(zhí)行某個(gè)任務(wù)，比如：每天晚上24點(diǎn)做數(shù)據(jù)匯總，定時(shí)發(fā)送短信等。

1.2.常見定時(shí)任務(wù)方案

While + Sleep : 通過循環(huán)加休眠的方式定時(shí)執(zhí)行

Timer和TimerTask實(shí)現(xiàn) ：JDK自帶的定時(shí)任務(wù)，可以實(shí)現(xiàn)簡單的間隔執(zhí)行任務(wù)（在指定時(shí)間點(diǎn)執(zhí)行某一任務(wù)，也能定時(shí)的周期性執(zhí)行），無法實(shí)現(xiàn)按日歷去調(diào)度執(zhí)行任務(wù)。

ScheduledExecutorService : Java并發(fā)包下，JDK1.5出現(xiàn)，是比較理想的定時(shí)任務(wù)實(shí)現(xiàn)方案。Eureka就使用的是它

QuartZ : 使用Quartz，它是一個(gè)異步任務(wù)調(diào)度框架，功能豐富，可以實(shí)現(xiàn)按日歷調(diào)度,支持持久化。

使用Spring Task ，Spring 3.0后提供Spring Task實(shí)現(xiàn)任務(wù)調(diào)度，支持按日歷調(diào)度，相比Quartz功能稍簡單，但是在開發(fā)基本夠用，支持注解編程方式。

SpringBoot中的Schedule ： 通過@EnableScheduling+@Scheduled最實(shí)現(xiàn)定時(shí)任務(wù)，底層使用的是Spring Task

2.分布式定時(shí)任務(wù)

2.1.遇到什么問題

上述的定時(shí)任務(wù)都是集中式(單體項(xiàng)目使用)的定時(shí)任務(wù)，在分布式中將會(huì)面臨一些問題或不足

業(yè)務(wù)量大，單機(jī)性能瓶頸需要擴(kuò)展

多臺(tái)機(jī)器部署如何保證定時(shí)任務(wù)不重復(fù)執(zhí)行

定時(shí)任務(wù)時(shí)間需要可調(diào)整，可以暫停

機(jī)器發(fā)生故障down機(jī)，定時(shí)任務(wù)依然可用，如何實(shí)現(xiàn)故障轉(zhuǎn)移

定時(shí)任務(wù)，執(zhí)行日志是否可監(jiān)控

2.2.分布式定時(shí)任務(wù)xxl-job

XXL-JOB是一個(gè)分布式任務(wù)調(diào)度平臺(tái)，于2015問世，其核心設(shè)計(jì)目標(biāo)是開發(fā)迅速、學(xué)習(xí)簡單、輕量級(jí)、易擴(kuò)展?，F(xiàn)已開放源代碼并接入多家公司線上產(chǎn)品線，開箱即用。其具備且不止如下能力

簡單 ：支持通過Web頁面對(duì)任務(wù)進(jìn)行CRUD操作，操作簡單，一分鐘上手；

動(dòng)態(tài) ：支持動(dòng)態(tài)修改任務(wù)狀態(tài)、啟動(dòng)/停止任務(wù)，以及終止運(yùn)行中任務(wù)，即時(shí)生效；

調(diào)度中心HA（中心式） ：調(diào)度采用中心式設(shè)計(jì)，“調(diào)度中心”基于集群Quartz實(shí)現(xiàn)并支持集群部署，可保證調(diào)度中心HA；執(zhí)行器HA（分布式）：任務(wù)分布式執(zhí)行，任務(wù)"執(zhí)行器"支持集群部署，可保證任務(wù)執(zhí)行HA；

彈性擴(kuò)容縮容 ：一旦有新執(zhí)行器機(jī)器上線或者下線，下次調(diào)度時(shí)將會(huì)重新分配任務(wù)；

路由策略 ：執(zhí)行器集群部署時(shí)提供豐富的路由策略，包括：第一個(gè)、最后一個(gè)、輪詢、隨機(jī)、一致性HASH、最不經(jīng)常使用、最近最久未使用、故障轉(zhuǎn)移、忙碌轉(zhuǎn)移等；

故障轉(zhuǎn)移 ：任務(wù)路由策略選擇"故障轉(zhuǎn)移"情況下，如果執(zhí)行器集群中某一臺(tái)機(jī)器故障，將會(huì)自動(dòng)Failover切換到一臺(tái)正常的執(zhí)行器發(fā)送調(diào)度請(qǐng)求。

任務(wù)失敗告警 ：默認(rèn)提供郵件方式失敗告警，同時(shí)預(yù)留擴(kuò)展接口，可方面的擴(kuò)展短信、釘釘?shù)雀婢绞剑?/p>

具體見：https://github.com/xuxueli/xxl-job/tree/v2.0.0

基于 Spring Boot + MyBatis Plus + Vue & Element 實(shí)現(xiàn)的后臺(tái)管理系統(tǒng) + 用戶小程序，支持 RBAC 動(dòng)態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能

項(xiàng)目地址：https://github.com/YunaiV/ruoyi-vue-pro

視頻教程：https://doc.iocoder.cn/video/

二.XXL-JOB初體驗(yàn)

1.xxl-job架構(gòu)設(shè)計(jì)

1.1.設(shè)計(jì)思想

將調(diào)度行為抽象形成“調(diào)度中心”公共平臺(tái)，而平臺(tái)自身并不承擔(dān)業(yè)務(wù)邏輯，“調(diào)度中心”負(fù)責(zé)發(fā)起調(diào)度請(qǐng)求。

將任務(wù)抽象成分散的JobHandler，交由“執(zhí)行器”統(tǒng)一管理，“執(zhí)行器”負(fù)責(zé)接收調(diào)度請(qǐng)求并執(zhí)行對(duì)應(yīng)的JobHandler中業(yè)務(wù)邏輯。因此，“調(diào)度”和“任務(wù)”兩部分可以相互解耦，提高系統(tǒng)整體穩(wěn)定性和擴(kuò)展性；

1.2.架構(gòu)設(shè)計(jì)圖

xxl-job分為 調(diào)度中心和執(zhí)行器兩大模塊

調(diào)度模塊（調(diào)度中心）

負(fù)責(zé)管理調(diào)度信息，按照調(diào)度配置發(fā)出調(diào)度請(qǐng)求，自身不承擔(dān)業(yè)務(wù)代碼。調(diào)度系統(tǒng)與任務(wù)解耦，提高了系統(tǒng)可用性和穩(wěn)定性，同時(shí)調(diào)度系統(tǒng)性能不再受限于任務(wù)模塊；

支持可視化、簡單且動(dòng)態(tài)的管理調(diào)度信息，包括任務(wù)新建，更新，刪除，GLUE開發(fā)和任務(wù)報(bào)警等，所有上述操作都會(huì)實(shí)時(shí)生效，同時(shí)支持監(jiān)控調(diào)度結(jié)果以及執(zhí)行日志，支持執(zhí)行器Failover(故障轉(zhuǎn)移)。

執(zhí)行模塊（執(zhí)行器）

負(fù)責(zé)接收調(diào)度請(qǐng)求并執(zhí)行任務(wù)邏輯。任務(wù)模塊專注于任務(wù)的執(zhí)行等操作，開發(fā)和維護(hù)更加簡單和高效；

接收“調(diào)度中心”的執(zhí)行請(qǐng)求、終止請(qǐng)求和日志請(qǐng)求等。

調(diào)度中心高可用

基于數(shù)據(jù)庫的集群方案，數(shù)據(jù)庫選用Mysql；集群分布式并發(fā)環(huán)境中進(jìn)行定時(shí)任務(wù)調(diào)度時(shí)，會(huì)在各個(gè)節(jié)點(diǎn)會(huì)上報(bào)任務(wù)，存到數(shù)據(jù)庫中，執(zhí)行時(shí)會(huì)從數(shù)據(jù)庫中取出觸發(fā)器來執(zhí)行，如果觸發(fā)器的名稱和執(zhí)行時(shí)間相同，則只有一個(gè)節(jié)點(diǎn)去執(zhí)行此任務(wù)。

并行調(diào)度

調(diào)度采用線程池方式實(shí)現(xiàn)，避免單線程因阻塞而引起任務(wù)調(diào)度延遲。XXL-JOB調(diào)度模塊默認(rèn)采用并行機(jī)制，在多線程調(diào)度的情況下，調(diào)度模塊被阻塞的幾率很低，大大提高了調(diào)度系統(tǒng)的承載量。

XXL-JOB的不同任務(wù)之間并行調(diào)度、并行執(zhí)行。XXL-JOB的單個(gè)任務(wù)，針對(duì)多個(gè)執(zhí)行器是并行運(yùn)行的，針對(duì)單個(gè)執(zhí)行器是串行執(zhí)行的。同時(shí)支持任務(wù)終止。

執(zhí)行器(任務(wù))高可用

執(zhí)行器如若集群部署，調(diào)度中心將會(huì)感知到在線的所有執(zhí)行器，如“127.0.0.1:9997, 127.0.0.1:9998, 127.0.0.1:9999”。多個(gè)執(zhí)行器可以選擇“路由策略”來采用輪詢，隨機(jī)等方式進(jìn)行多機(jī)器調(diào)度。

當(dāng)任務(wù)”路由策略”選擇”故障轉(zhuǎn)移(FAILOVER)”時(shí)，當(dāng)調(diào)度中心每次發(fā)起調(diào)度請(qǐng)求時(shí)，會(huì)按照順序?qū)?zhí)行器發(fā)出心跳檢測請(qǐng)求，第一個(gè)檢測為存活狀態(tài)的執(zhí)行器將會(huì)被選定并發(fā)送調(diào)度請(qǐng)求。調(diào)度成功后，可在日志監(jiān)控界面查看“調(diào)度備注”

2.xxl-job安裝

2.1.下載源碼

請(qǐng)下載項(xiàng)目源碼并解壓，使用IDEA工具導(dǎo)入項(xiàng)目

源碼倉庫地址

https://github.com/xuxueli/xxl-job

http://gitee.com/xuxueli0323/xxl-job

項(xiàng)目代碼結(jié)構(gòu)如下

doc ：文檔，即SQL腳本所在目錄

db : “調(diào)度數(shù)據(jù)庫”建表腳本

xxl-job-admin : 調(diào)度中心項(xiàng)目源碼

xxl-job-core : 核心模塊,公共Jar依賴

xxl-job-executor-samples : 執(zhí)行器，Sample示例項(xiàng)目（大家可以在該項(xiàng)目上進(jìn)行開發(fā)，也可以將現(xiàn)有項(xiàng)目改造生成執(zhí)行器項(xiàng)目）

2.2.導(dǎo)入數(shù)據(jù)庫

打開項(xiàng)目代碼，獲取 “調(diào)度數(shù)據(jù)庫初始化SQL腳本” 并執(zhí)行即可?！罢{(diào)度數(shù)據(jù)庫初始化SQL腳本” 位置為: /xxl-job/doc/db/tables_xxl_job.sql ，數(shù)據(jù)庫名：xxl_job

數(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.3.啟動(dòng)調(diào)度中心

打開 xxl-job-admin 的配置文件，/xxl-job/xxl-job-admin/src/main/resources/application.properties 對(duì)調(diào)度中心進(jìn)行配置，重要配置如下

server.port : 根據(jù)情況修改端口

spring.datasource.url ：指向剛才準(zhǔn)備的數(shù)據(jù)庫

spring.datasource.password : 記得修改成自己的數(shù)據(jù)庫密碼

spring.mail.username ：配置自己的郵件賬號(hào)

spring.mail.password ：郵件的授權(quán)碼，我下面是以qq郵箱為例

下面根據(jù)自己的情況進(jìn)行修改，不要直接復(fù)制

##?調(diào)度中心JDBC鏈接：鏈接地址請(qǐng)保持和?2.1章節(jié)?所創(chuàng)建的調(diào)度數(shù)據(jù)庫的地址一致
spring.datasource.url=jdbc//127.0.0.1:3306/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=root_pwd
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
##?報(bào)警郵箱
spring.mail.host=smtp.qq.com
spring.mail.port=25
spring.mail.username=xxx@qq.com
spring.mail.password=郵箱授權(quán)碼，不是登錄密碼
spring.mail.properties.mail.smtp.auth=true
spring.mail.properties.mail.smtp.starttls.enable=true
spring.mail.properties.mail.smtp.starttls.required=true
spring.mail.properties.mail.smtp.socketFactory.class=javax.net.ssl.SSLSocketFactory
##?調(diào)度中心通訊TOKEN?[選填]：非空時(shí)啟用；
xxl.job.accessToken=
##?調(diào)度中心國際化配置?[必填]：?默認(rèn)為?"zh_CN"/中文簡體,?可選范圍為?"zh_CN"/中文簡體,?"zh_TC"/中文繁體?and?"en"/英文；
xxl.job.i18n=zh_CN

>?基于?Spring?Cloud?Alibaba?+?Gateway?+?Nacos?+?RocketMQ?+?Vue?&?Element?實(shí)現(xiàn)的后臺(tái)管理系統(tǒng)?+?用戶小程序，支持?RBAC?動(dòng)態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能
>
>?*?項(xiàng)目地址：
>?*?視頻教程：

#?調(diào)度線程池最大線程配置【必填】
xxl.job.triggerpool.fast.max=200
xxl.job.triggerpool.slow.max=100
##?調(diào)度中心日志表數(shù)據(jù)保存天數(shù)?[必填]：過期日志自動(dòng)清理；限制大于等于7時(shí)生效，否則,?如-1，關(guān)閉自動(dòng)清理功能；
xxl.job.logretentiondays=30

然后啟動(dòng)調(diào)度中心 ，執(zhí)行 XxlJobAdminApplication#main 方法 ， 啟動(dòng)之后，瀏覽器訪問 http://localhost:18080/xxl-job-admin/jobinfo?jobGroup=2 ；注意URL中有個(gè)上下文路徑。默認(rèn)登錄賬號(hào) “admin/123456”, 登錄后運(yùn)行界面如下圖所示。

2.3.配置部署“執(zhí)行器項(xiàng)目

“執(zhí)行器”項(xiàng)目：xxl-job-executor-sample-springboot (提供多種版本執(zhí)行器供選擇，現(xiàn)以 springboot 版本為例，可直接使用，也可以參考其并將現(xiàn)有項(xiàng)目改造成執(zhí)行器)

作用：負(fù)責(zé)接收“調(diào)度中心”的調(diào)度并執(zhí)行；可直接部署執(zhí)行器，也可以將執(zhí)行器集成到現(xiàn)有業(yè)務(wù)項(xiàng)目中。

修改配置：/xxl-job/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/application.properties

xxl.job.admin.addresses : 調(diào)度中心的地址，如果調(diào)度中心修改過端口，這里也要對(duì)應(yīng)修改

##?調(diào)度中心部署跟地址?[選填]：如調(diào)度中心集群部署存在多個(gè)地址則用逗號(hào)分隔。執(zhí)行器將會(huì)使用該地址進(jìn)行"執(zhí)行器心跳注冊(cè)"和"任務(wù)結(jié)果回調(diào)"；為空則關(guān)閉自動(dòng)注冊(cè)；
xxl.job.admin.addresses=http://127.0.0.1:18080/xxl-job-admin
##?執(zhí)行器通訊TOKEN?[選填]：非空時(shí)啟用；
xxl.job.accessToken=
##?執(zhí)行器AppName?[選填]：執(zhí)行器心跳注冊(cè)分組依據(jù)；為空則關(guān)閉自動(dòng)注冊(cè)
xxl.job.executor.appname=xxl-job-executor-sample
##?執(zhí)行器注冊(cè)?[選填]：優(yōu)先使用該配置作為注冊(cè)地址，為空時(shí)使用內(nèi)嵌服務(wù)?”IP:PORT“?作為注冊(cè)地址。從而更靈活的支持容器類型執(zhí)行器動(dòng)態(tài)IP和動(dòng)態(tài)映射端口問題。
xxl.job.executor.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ù)"；
xxl.job.executor.ip=
##?執(zhí)行器端口號(hào)?[選填]：小于等于0則自動(dòng)獲取；默認(rèn)端口為9999，單機(jī)部署多個(gè)執(zhí)行器時(shí)，注意要配置不同執(zhí)行器端口；
xxl.job.executor.port=9999
##?執(zhí)行器運(yùn)行日志文件存儲(chǔ)磁盤路徑?[選填]?：需要對(duì)該路徑擁有讀寫權(quán)限；為空則使用默認(rèn)路徑；
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
##?執(zhí)行器日志文件保存天數(shù)?[選填]?：?過期日志自動(dòng)清理,?限制值大于等于3時(shí)生效;?否則,?如-1,?關(guān)閉自動(dòng)清理功能；
xxl.job.executor.logretentiondays=30

上面配置是為了在Spring容器中創(chuàng)建一個(gè) XxlJobSpringExecutor 執(zhí)行器Bean，見：com.xxl.job.executor.core.config.XxlJobConfig#xxlJobExecutor

@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;
}

?

?

在com.xxl.job.executor.service.jobhandler.SampleXxlJob中提供了簡單的定時(shí)任務(wù)實(shí)例

為方便用戶參考與快速實(shí)用，示例執(zhí)行器內(nèi)原生提供多個(gè)Bean模式任務(wù)Handler，可以直接配置實(shí)用，如下：

demoJobHandler ：簡單示例任務(wù)，任務(wù)內(nèi)部模擬耗時(shí)任務(wù)邏輯，用戶可在線體驗(yàn)Rolling Log等功能；

shardingJobHandler ：分片示例任務(wù)，任務(wù)內(nèi)部模擬處理分片參數(shù)，可參考熟悉分片任務(wù)；

httpJobHandler ：通用HTTP任務(wù)Handler；業(yè)務(wù)方只需要提供HTTP鏈接等信息即可，不限制語言、平臺(tái)。示例任務(wù)入?yún)⑷缦拢?/p>

/**
?*?XxlJob開發(fā)示例（Bean模式）
?*
?*?開發(fā)步驟：
?*?1、在Spring?Bean實(shí)例中，開發(fā)Job方法，方式格式要求為?"public?ReturnT?execute(String?param)"
?*?2、為Job方法添加注解?"@XxlJob(value="自定義jobhandler名稱",?init?=?"JobHandler初始化方法",?destroy?=?"JobHandler銷毀方法")"，注解value值對(duì)應(yīng)的是調(diào)度中心新建任務(wù)的JobHandler屬性的值。
?*?3、執(zhí)行日志：需要通過?"XxlJobLogger.log"?打印執(zhí)行日志；
?*
?*?@author?xuxueli?2019-12-11?2151
?*/
@Component
public?class?SampleXxlJob?{
????private?static?Logger?logger?=?LoggerFactory.getLogger(SampleXxlJob.class);
?/**
?????*?1、簡單任務(wù)示例（Bean模式）
?????*/
????@XxlJob("demoJobHandler")
????public?ReturnT?demoJobHandler(String?param)?throws?Exception?{
????????logger.info("XXL-JOB,?Hello?World.?param={}",param);
????????return?ReturnT.SUCCESS;
????}
????//...省略...
}

【重要】 如果我們要寫自己的定時(shí)任務(wù)，參照上面方法，在方法上注解一個(gè)@XxlJob("任務(wù)名字") ,方法可以接受一個(gè)字符串參數(shù)，方法需要返回ReturnT格式。

最后啟動(dòng)執(zhí)行器項(xiàng)目.

3.配置定時(shí)任務(wù)

3.1.執(zhí)行器創(chuàng)建

打開調(diào)度中心可視化界面，在執(zhí)行器管理界面，添加新增執(zhí)行器

appName : 執(zhí)行器的名字，可以任意填寫

名稱：任意填寫

注冊(cè)方式：調(diào)度中心是通過RPC的方式對(duì)執(zhí)行器發(fā)起調(diào)度，所以這里需要的是執(zhí)行器項(xiàng)目的ip:port ，注意，該端口不是執(zhí)行器項(xiàng)目的server.port ，而是：xxl.job.executor.port 端口。你可以選擇自動(dòng)注冊(cè)，也可以手動(dòng)錄入。

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

在 任務(wù)管理 界面，新增任務(wù)

路由策略 ：有輪詢，隨機(jī)，故障轉(zhuǎn)移等等策略，是用在集群模式下的調(diào)度方式。

cron : 定時(shí)任務(wù)的執(zhí)行時(shí)間規(guī)則，時(shí)間表達(dá)式

JobHandler : 這個(gè)是要對(duì)應(yīng) “執(zhí)行器項(xiàng)目”中 @XxlJob("demoJobHandler") 注解中的名字

運(yùn)行模式 ：Bean ，使用內(nèi)置代碼方式，也可以執(zhí)行在線執(zhí)行代碼方式

報(bào)警郵件 ：如果定時(shí)任務(wù)失敗，會(huì)發(fā)送報(bào)警郵件到郵箱

任務(wù)參數(shù) ：這個(gè)參數(shù)可以傳遞給 @XxlJob("demoJobHandler")所在方法的參數(shù)。

創(chuàng)建好任務(wù)之后就可以執(zhí)行了

調(diào)度日志

IDEA工具控制臺(tái)效果

15:47:33.017?logback?[Thread-16]?INFO??c.x.j.e.s.jobhandler.SampleXxlJob?-?XXL-JOB,?Hello?World.?param=
15:47:34.007?logback?[Thread-16]?INFO??c.x.j.e.s.jobhandler.SampleXxlJob?-?XXL-JOB,?Hello?World.?param=
15:47:35.008?logback?[Thread-16]?INFO??c.x.j.e.s.jobhandler.SampleXxlJob?-?XXL-JOB,?Hello?World.?param=
...省略...

4.GLUE模式(Java)

4.1.添加任務(wù)

該模式支持在線編輯定時(shí)任務(wù)的內(nèi)容，立刻執(zhí)行，無需再開發(fā)工具中編輯代碼，也無需重啟項(xiàng)目。

請(qǐng)點(diǎn)擊任務(wù)右側(cè) “GLUE” 按鈕，進(jìn)入 “GLUE編輯器開發(fā)界面” ，見下圖。“GLUE模式(Java)” 運(yùn)行模式的任務(wù)默認(rèn)已經(jīng)初始化了示例任務(wù)代碼，即打印Hello World。

任務(wù)以源碼方式維護(hù)在調(diào)度中心，支持通過Web IDE在線更新，實(shí)時(shí)編譯和生效，因此不需要指定JobHandler

4.2.編寫代碼

保存之后可以在操作按鈕里面去編寫任務(wù)

(“GLUE模式(Java)” 運(yùn)行模式的任務(wù)實(shí)際上是一段繼承自IJobHandler的Java類代碼，它在執(zhí)行器項(xiàng)目中運(yùn)行，可使用@Resource/@Autowire注入執(zhí)行器里中的其他服務(wù)），比如我的定時(shí)任務(wù)如下，編輯好之后點(diǎn)擊保存

保存好之后，啟動(dòng)定時(shí)任務(wù)，效果如下

三.XXL-JOB集群部署

1.調(diào)度中心集群

1.1.問題概述

調(diào)度中心支持集群部署，提升調(diào)度系統(tǒng)容災(zāi)和可用性。調(diào)度中心集群部署時(shí)，幾點(diǎn)要求和建議：

DB配置保持一致；

集群機(jī)器時(shí)鐘保持一致（單機(jī)集群忽視）；

當(dāng)啟動(dòng)多個(gè)調(diào)度器時(shí)，執(zhí)行器配置調(diào)度中心部署跟地址可以用逗號(hào)分隔。執(zhí)行器將會(huì)使用該地址進(jìn)行"執(zhí)行器心跳注冊(cè)"和"任務(wù)結(jié)果回調(diào)"；為空則關(guān)閉自動(dòng)注冊(cè)；

但是建議：推薦通過nginx為調(diào)度中心集群做負(fù)載均衡，分配域名。調(diào)度中心訪問、執(zhí)行器回調(diào)配置、調(diào)用API服務(wù)等操作均通過該域名進(jìn)行。

1.2.啟動(dòng)多個(gè)調(diào)度中心

修改調(diào)度中心端口，啟動(dòng)多個(gè)調(diào)度中心，我這里啟動(dòng)兩個(gè)如

http://localhost:18080/xxl-job-admin/

http://localhost:18081/xxl-job-admin/

1.3.配置Nginx負(fù)載均衡

當(dāng)啟動(dòng)多個(gè)調(diào)度器時(shí)，執(zhí)行器配置調(diào)度中心部署跟地址可以用逗號(hào)分隔。執(zhí)行器將會(huì)使用該地址進(jìn)行“執(zhí)行器心跳注冊(cè)”和“任務(wù)結(jié)果回調(diào)”；為空則關(guān)閉自動(dòng)注冊(cè)；

但是建議：推薦通過nginx為調(diào)度中心集群做負(fù)載均衡，分配域名。調(diào)度中心訪問、執(zhí)行器回調(diào)配置、調(diào)用API服務(wù)等操作均通過該域名進(jìn)行。

我們啟動(dòng)了2個(gè)調(diào)度中心，那么我的執(zhí)行器項(xiàng)目該注冊(cè)到哪個(gè)調(diào)度中心呢？我們通過Nginx來解決這個(gè)問題，原理如下圖：

我們?cè)賖osts配置 www.jobs.com作為nginx的主機(jī)域名，然后反向代理到多個(gè)調(diào)度中心，這樣一來執(zhí)行器就只需要注冊(cè)到www.jobs.com Nginx即可。

修改 C:WindowsSystem32driversetchosts增加配置如下

127.0.0.1?www.jobs.com

Nginx配置如下

#調(diào)度中心
upstream?jobs{
?server?localhost:18080;
?server?localhost:18081;
}

server?{
??????listen???????80;
??????#使用域名
??????server_name??www.jobs.com;

??????#charset?koi8-r;

??????#access_log??logs/host.access.log??main;

??????location?/?{
???????#調(diào)度中心反向代理配置
??????????proxy_pass???http://jobs/;
??????}

??????#error_page??404??????????????/404.html;

??????#?redirect?server?error?pages?to?the?static?page?/50x.html
??????#
??????error_page???500?502?503?504??/50x.html;
??????location?=?/50x.html?{
??????????root???html;
??????}

??????
??}

啟動(dòng)Nginx,通過瀏覽器訪問 http://www.jobs.com/xxl-job-admin/ ，可以訪問到調(diào)度中心的管理界面

2.執(zhí)行器項(xiàng)目集群

執(zhí)行器支持集群部署，提升調(diào)度系統(tǒng)可用性，同時(shí)提升任務(wù)處理能力。

執(zhí)行器集群部署時(shí)，幾點(diǎn)要求和建議：

執(zhí)行器回調(diào)地址（xxl.job.admin.addresses）需要保持一致；執(zhí)行器根據(jù)該配置進(jìn)行執(zhí)行器自動(dòng)注冊(cè)等操作。

同一個(gè)執(zhí)行器集群內(nèi)AppName（xxl.job.executor.appname）需要保持一致；調(diào)度中心根據(jù)該配置動(dòng)態(tài)發(fā)現(xiàn)不同集群的在線執(zhí)行器列表。

2.1.啟動(dòng)多個(gè)執(zhí)行器項(xiàng)目

現(xiàn)在對(duì)執(zhí)行器項(xiàng)目做集群，修改xxl-job-executor-sample-springboot配置文件application.properties

server.port : 既然是做集群，項(xiàng)目端口需要修改

xxl.job.admin.addresses : 調(diào)度中心地址需要修改成www.jobs.com ，多個(gè)執(zhí)行器配置同一個(gè)地址。

xxl.job.executor.port : RPC通信端口也要修改，多個(gè)執(zhí)行器該端口需要不一樣

第一個(gè)實(shí)例配置

server.port=19090
xxl.job.admin.addresses=http://www.jobs.com/xxl-job-admin?#對(duì)應(yīng)Nginx地址
xxl.job.executor.port=9999

第二個(gè)實(shí)例配置

server.port=19091
xxl.job.admin.addresses=http://www.jobs.com/xxl-job-admin
xxl.job.executor.port=9998

在 Configurations中配置，允許啟動(dòng)多個(gè)實(shí)例

啟動(dòng)實(shí)例如下

2.2.配置定時(shí)任務(wù)

通過http://www.jobs.com/xxl-job-admin 訪問調(diào)度中心管理界面，在執(zhí)行器管理中可以看到多臺(tái)執(zhí)行器實(shí)例

在任務(wù)管理中，可以編輯任務(wù)，然后選擇路由策略，比如：選擇輪詢，然后啟動(dòng)任務(wù)，就會(huì)看到兩個(gè)執(zhí)行器項(xiàng)目輪著執(zhí)行定時(shí)任務(wù)。

說在最后

xxl-job確實(shí)很強(qiáng)大，功能也很全,經(jīng)過該文章學(xué)習(xí)相信你可以把xxl-job給用起來了，但是如果你的項(xiàng)目是一個(gè)小體量的單體，我不太建議使用它，Quzrtz或者SpringBoot Task就足夠 ，對(duì)于xxl-job個(gè)人還是有些笨重。

編輯：黃飛

?