1.概述

1.1 什么是任務(wù)調(diào)度

我們可以先思考一下業(yè)務(wù)場(chǎng)景的解決方案：

• 某電商系統(tǒng)需要在每天上午10點(diǎn)，下午3點(diǎn)，晚上8點(diǎn)發(fā)放一批優(yōu)惠券。
• 某銀行系統(tǒng)需要在信用卡到期還款日的前三天進(jìn)行短信提醒。
• 某財(cái)務(wù)系統(tǒng)需要在每天凌晨0:10結(jié)算前一天的財(cái)務(wù)數(shù)據(jù)，統(tǒng)計(jì)匯總。
• 12306會(huì)根據(jù)車(chē)次的不同，設(shè)置某幾個(gè)時(shí)間點(diǎn)進(jìn)行分批放票。

以上業(yè)務(wù)場(chǎng)景的解決方案就是任務(wù)調(diào)度。

任務(wù)調(diào)度是指系統(tǒng)為了自動(dòng)完成特定任務(wù)，在約定的特定時(shí)刻去執(zhí)行任務(wù)的過(guò)程。有了任務(wù)調(diào)度即可解放更多的人力，而是由系統(tǒng)自動(dòng)去執(zhí)行任務(wù)。

如何實(shí)現(xiàn)任務(wù)調(diào)度？

• 多線程方式，結(jié)合sleep
• JDK提供的API，例如：Timer、ScheduledExecutor
• 框架，例如Quartz ，它是一個(gè)功能強(qiáng)大的任務(wù)調(diào)度框架，可以滿足更多更復(fù)雜的調(diào)度需求
• spring task

入門(mén)案例

spring框架中默認(rèn)就支持了一個(gè)任務(wù)調(diào)度，spring-task

（1）創(chuàng)建一個(gè)工程：spring-task-demo

pom文件

<!-- 繼承Spring boot工程 -->
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.5.RELEASE</version>
</parent>

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

（2）引導(dǎo)類(lèi)：

package com.itheima.task;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
public class TaskApplication {

    public static void main(String[] args) {
        SpringApplication.run(TaskApplication.class,args);
    }
}

(3)編寫(xiě)案例

package com.itheima.task.job;

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.Date;

@Component
public class HelloJob {

    @Scheduled(cron = "0/5 * * * * ?")
    public void eat(){
        System.out.println("5秒中吃一次飯，我想成為一個(gè)胖子"+new Date());
    }
}

測(cè)試：?jiǎn)?dòng)項(xiàng)目，每隔5秒中會(huì)執(zhí)行一次eat方法

1.2 cron表達(dá)式

cron表達(dá)式是一個(gè)字符串, 用來(lái)設(shè)置定時(shí)規(guī)則, 由七部分組成, 每部分中間用空格隔開(kāi), 每部分的含義如下表所示:

另外, cron表達(dá)式還可以包含一些特殊符號(hào)來(lái)設(shè)置更加靈活的定時(shí)規(guī)則, 如下表所示:

為了讓大家更熟悉cron表達(dá)式的用法, 接下來(lái)我們給大家列舉了一些例子, 如下表所示:

1.3 什么是分布式任務(wù)調(diào)度

當(dāng)前軟件的架構(gòu)已經(jīng)開(kāi)始向分布式架構(gòu)轉(zhuǎn)變，將單體結(jié)構(gòu)拆分為若干服務(wù)，服務(wù)之間通過(guò)網(wǎng)絡(luò)交互來(lái)完成業(yè)務(wù)處理。在分布式架構(gòu)下，一個(gè)服務(wù)往往會(huì)部署多個(gè)實(shí)例來(lái)運(yùn)行我們的業(yè)務(wù)，如果在這種分布式系統(tǒng)環(huán)境下運(yùn)行任務(wù)調(diào)度，我們稱(chēng)之為分布式任務(wù)調(diào)度。

[外鏈圖片轉(zhuǎn)存失敗,源站可能有防盜鏈機(jī)制,建議將圖片保存下來(lái)直接上傳(img-eVGMnOeX-1690642441216)(assets\分布式任務(wù)調(diào)度.png)]

將任務(wù)調(diào)度程序分布式構(gòu)建，這樣就可以具有分布式系統(tǒng)的特點(diǎn)，并且提高任務(wù)的調(diào)度處理能力：

1、并行任務(wù)調(diào)度

并行任務(wù)調(diào)度實(shí)現(xiàn)靠多線程，如果有大量任務(wù)需要調(diào)度，此時(shí)光靠多線程就會(huì)有瓶頸了，因?yàn)橐慌_(tái)計(jì)算機(jī)CPU的處理能力是有限的。

如果將任務(wù)調(diào)度程序分布式部署，每個(gè)結(jié)點(diǎn)還可以部署為集群，這樣就可以讓多臺(tái)計(jì)算機(jī)共同去完成任務(wù)調(diào)度，我們可以將任務(wù)分割為若干個(gè)分片，由不同的實(shí)例并行執(zhí)行，來(lái)提高任務(wù)調(diào)度的處理效率。

2、高可用

若某一個(gè)實(shí)例宕機(jī)，不影響其他實(shí)例來(lái)執(zhí)行任務(wù)。

3、彈性擴(kuò)容

當(dāng)集群中增加實(shí)例就可以提高并執(zhí)行任務(wù)的處理效率。

4、任務(wù)管理與監(jiān)測(cè)

對(duì)系統(tǒng)中存在的所有定時(shí)任務(wù)進(jìn)行統(tǒng)一的管理及監(jiān)測(cè)。讓開(kāi)發(fā)人員及運(yùn)維人員能夠時(shí)刻了解任務(wù)執(zhí)行情況，從而做出快速的應(yīng)急處理響應(yīng)。

分布式任務(wù)調(diào)度面臨的問(wèn)題：

當(dāng)任務(wù)調(diào)度以集群方式部署，同一個(gè)任務(wù)調(diào)度可能會(huì)執(zhí)行多次，例如：電商系統(tǒng)定期發(fā)放優(yōu)惠券，就可能重復(fù)發(fā)放優(yōu)惠券，對(duì)公司造成損失，信用卡還款提醒就會(huì)重復(fù)執(zhí)行多次，給用戶造成煩惱，所以我們需要控制相同的任務(wù)在多個(gè)運(yùn)行實(shí)例上只執(zhí)行一次。常見(jiàn)解決方案：

• 分布式鎖，多個(gè)實(shí)例在任務(wù)執(zhí)行前首先需要獲取鎖，如果獲取失敗那么就證明有其他服務(wù)已經(jīng)在運(yùn)行，如果獲取成功那么證明沒(méi)有服務(wù)在運(yùn)行定時(shí)任務(wù)，那么就可以執(zhí)行。
• ZooKeeper選舉，利用ZooKeeper對(duì)Leader實(shí)例執(zhí)行定時(shí)任務(wù)，執(zhí)行定時(shí)任務(wù)的時(shí)候判斷自己是否是Leader，如果不是則不執(zhí)行，如果是則執(zhí)行業(yè)務(wù)邏輯，這樣也能達(dá)到目的。

1.4 xxl-Job簡(jiǎn)介

針對(duì)分布式任務(wù)調(diào)度的需求，市場(chǎng)上出現(xiàn)了很多的產(chǎn)品：

1） TBSchedule：淘寶推出的一款非常優(yōu)秀的高性能分布式調(diào)度框架，目前被應(yīng)用于阿里、京東、支付寶、國(guó)美等很多互聯(lián)網(wǎng)企業(yè)的流程調(diào)度系統(tǒng)中。但是已經(jīng)多年未更新，文檔缺失嚴(yán)重，缺少維護(hù)。

2） XXL-Job：大眾點(diǎn)評(píng)的分布式任務(wù)調(diào)度平臺(tái)，是一個(gè)輕量級(jí)分布式任務(wù)調(diào)度平臺(tái), 其核心設(shè)計(jì)目標(biāo)是開(kāi)發(fā)迅速、學(xué)習(xí)簡(jiǎn)單、輕量級(jí)、易擴(kuò)展?，F(xiàn)已開(kāi)放源代碼并接入多家公司線上產(chǎn)品線，開(kāi)箱即用。

3）Elastic-job：當(dāng)當(dāng)網(wǎng)借鑒TBSchedule并基于quartz 二次開(kāi)發(fā)的彈性分布式任務(wù)調(diào)度系統(tǒng)，功能豐富強(qiáng)大，采用zookeeper實(shí)現(xiàn)分布式協(xié)調(diào)，具有任務(wù)高可用以及分片功能。

4）Saturn： 唯品會(huì)開(kāi)源的一個(gè)分布式任務(wù)調(diào)度平臺(tái)，基于Elastic-job，可以全域統(tǒng)一配置，統(tǒng)一監(jiān)
控，具有任務(wù)高可用以及分片功能。

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

源碼地址：https://gitee.com/xuxueli0323/xxl-job

文檔地址：https://www.xuxueli.com/xxl-job/

特性

• 簡(jiǎn)單靈活
  提供Web頁(yè)面對(duì)任務(wù)進(jìn)行管理，管理系統(tǒng)支持用戶管理、權(quán)限控制；
  支持容器部署；
  支持通過(guò)通用HTTP提供跨平臺(tái)任務(wù)調(diào)度；
• 豐富的任務(wù)管理功能
  支持頁(yè)面對(duì)任務(wù)CRUD操作；
  支持在頁(yè)面編寫(xiě)腳本任務(wù)、命令行任務(wù)、Java代碼任務(wù)并執(zhí)行；
  支持任務(wù)級(jí)聯(lián)編排，父任務(wù)執(zhí)行結(jié)束后觸發(fā)子任務(wù)執(zhí)行；
  支持設(shè)置指定任務(wù)執(zhí)行節(jié)點(diǎn)路由策略，包括輪詢(xún)、隨機(jī)、廣播、故障轉(zhuǎn)移、忙碌轉(zhuǎn)移等；
  支持Cron方式、任務(wù)依賴(lài)、調(diào)度中心API接口方式觸發(fā)任務(wù)執(zhí)行
• 高性能
  任務(wù)調(diào)度流程全異步化設(shè)計(jì)實(shí)現(xiàn)，如異步調(diào)度、異步運(yùn)行、異步回調(diào)等，有效對(duì)密集調(diào)度進(jìn)行流量削峰；
• 高可用
  任務(wù)調(diào)度中心、任務(wù)執(zhí)行節(jié)點(diǎn)均 集群部署，支持動(dòng)態(tài)擴(kuò)展、故障轉(zhuǎn)移
  支持任務(wù)配置路由故障轉(zhuǎn)移策略，執(zhí)行器節(jié)點(diǎn)不可用是自動(dòng)轉(zhuǎn)移到其他節(jié)點(diǎn)執(zhí)行
  支持任務(wù)超時(shí)控制、失敗重試配置
  支持任務(wù)處理阻塞策略：調(diào)度當(dāng)任務(wù)執(zhí)行節(jié)點(diǎn)忙碌時(shí)來(lái)不及執(zhí)行任務(wù)的處理策略，包括：串行、拋棄、覆蓋策略
• 易于監(jiān)控運(yùn)維
  支持設(shè)置任務(wù)失敗郵件告警，預(yù)留接口支持短信、釘釘告警；
  支持實(shí)時(shí)查看任務(wù)執(zhí)行運(yùn)行數(shù)據(jù)統(tǒng)計(jì)圖表、任務(wù)進(jìn)度監(jiān)控?cái)?shù)據(jù)、任務(wù)完整執(zhí)行日志；

2.XXL-Job快速入門(mén)

在分布式架構(gòu)下，通過(guò)XXL-Job實(shí)現(xiàn)定時(shí)任務(wù)

調(diào)度中心：負(fù)責(zé)管理調(diào)度信息，按照調(diào)度配置發(fā)出調(diào)度請(qǐng)求，自身不承擔(dān)業(yè)務(wù)代碼。

任務(wù)執(zhí)行器：負(fù)責(zé)接收調(diào)度請(qǐng)求并執(zhí)行任務(wù)邏輯。

任務(wù)：專(zhuān)注于任務(wù)的處理。

調(diào)度中心會(huì)發(fā)出調(diào)度請(qǐng)求，任務(wù)執(zhí)行器接收到請(qǐng)求之后會(huì)去執(zhí)行任務(wù)，任務(wù)則專(zhuān)注于任務(wù)業(yè)務(wù)的處理。

2.1 環(huán)境搭建

2.1.1 調(diào)度中心環(huán)境要求

• Maven3+
• Jdk1.8+
• Mysql5.7+

2.1.2 源碼倉(cāng)庫(kù)地址

也可以使用資料文件夾中的源碼

2.1.3 初始化“調(diào)度數(shù)據(jù)庫(kù)”

請(qǐng)下載項(xiàng)目源碼并解壓，獲取 “調(diào)度數(shù)據(jù)庫(kù)初始化SQL腳本” 并執(zhí)行即可。

位置：/xxl-job/doc/db/tables_xxl_job.sql 共8張表

- 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_logglue：任務(wù)GLUE日志：用于保存GLUE更新歷史，用于支持GLUE的版本回溯功能；
- xxl_job_registry：執(zhí)行器注冊(cè)表，維護(hù)在線的執(zhí)行器和調(diào)度中心機(jī)器地址信息；
- xxl_job_user：系統(tǒng)用戶表；

調(diào)度中心支持集群部署，集群情況下各節(jié)點(diǎn)務(wù)必連接同一個(gè)mysql實(shí)例;

如果mysql做主從,調(diào)度中心集群節(jié)點(diǎn)務(wù)必強(qiáng)制走主庫(kù);

2.1.4 編譯源碼

解壓源碼,按照maven格式將源碼導(dǎo)入IDE, 使用maven進(jìn)行編譯即可，源碼結(jié)構(gòu)如下：

2.1.5 配置部署“調(diào)度中心”

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

作用：統(tǒng)一管理任務(wù)調(diào)度平臺(tái)上調(diào)度任務(wù)，負(fù)責(zé)觸發(fā)調(diào)度執(zhí)行，并且提供任務(wù)管理平臺(tái)。

步驟一：調(diào)度中心配置

調(diào)度中心配置文件地址：/xxl-job/xxl-job-admin/src/main/resources/application.properties

數(shù)據(jù)庫(kù)的連接信息修改為自己的數(shù)據(jù)庫(kù)

### web
server.port=8888
server.servlet.context-path=/xxl-job-admin

### actuator
management.server.servlet.context-path=/actuator
management.health.mail.enabled=false

### resources
spring.mvc.servlet.load-on-startup=0
spring.mvc.static-path-pattern=/static/**
spring.resources.static-locations=classpath:/static/

### freemarker
spring.freemarker.templateLoaderPath=classpath:/templates/
spring.freemarker.suffix=.ftl
spring.freemarker.charset=UTF-8
spring.freemarker.request-context-attribute=request
spring.freemarker.settings.number_format=0.##########

### mybatis
mybatis.mapper-locations=classpath:/mybatis-mapper/*Mapper.xml
#mybatis.type-aliases-package=com.xxl.job.admin.core.model

### xxl-job, datasource
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/xxl_job?Unicode=true&serverTimezone=Asia/Shanghai&characterEncoding=UTF-8
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

### datasource-pool
spring.datasource.type=com.zaxxer.hikari.HikariDataSource
spring.datasource.hikari.minimum-idle=10
spring.datasource.hikari.maximum-pool-size=30
spring.datasource.hikari.auto-commit=true
spring.datasource.hikari.idle-timeout=30000
spring.datasource.hikari.pool-name=HikariCP
spring.datasource.hikari.max-lifetime=900000
spring.datasource.hikari.connection-timeout=10000
spring.datasource.hikari.connection-test-query=SELECT 1

### xxl-job, email
spring.mail.host=smtp.qq.com
spring.mail.port=25
spring.mail.username=xxx@qq.com
spring.mail.password=xxx
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

### xxl-job, access token
xxl.job.accessToken=

### xxl-job, i18n (default is zh_CN, and you can choose "zh_CN", "zh_TC" and "en")
xxl.job.i18n=zh_CN

## xxl-job, triggerpool max size
xxl.job.triggerpool.fast.max=200
xxl.job.triggerpool.slow.max=100

### xxl-job, log retention days
xxl.job.logretentiondays=30

步驟二：部署項(xiàng)目

如果已經(jīng)正確進(jìn)行上述配置，可將項(xiàng)目編譯打包部署。

啟動(dòng)方式一：這是一個(gè)springboot項(xiàng)目，可以在idea中直接啟動(dòng)，不推薦使用

啟動(dòng)方式二：

• 執(zhí)行maven打包命令：package
• 打完包以后，從項(xiàng)目的target目錄中找到j(luò)ar包拷貝到不帶空格和中文的目錄下
• 執(zhí)行以下命令，啟動(dòng)項(xiàng)目

java -jar xxl-job-admin-2.2.0-SNAPSHOT.jar

調(diào)度中心訪問(wèn)地址：http://localhost:8888/xxl-job-admin (該地址執(zhí)行器將會(huì)使用到，作為回調(diào)地址)

默認(rèn)登錄賬號(hào) “admin/123456”, 登錄后運(yùn)行界面如下圖所示。

至此“調(diào)度中心”項(xiàng)目已經(jīng)部署成功。

2.2 入門(mén)案例編寫(xiě)

2.2.1 配置執(zhí)行器

在任務(wù)調(diào)度中心，點(diǎn)擊進(jìn)入"執(zhí)行器管理"界面, 如下圖:

1、此處的AppName,會(huì)在創(chuàng)建任務(wù)時(shí)被選擇，每個(gè)任務(wù)必然要選擇一個(gè)執(zhí)行器。
2、“執(zhí)行器列表” 中顯示在線的執(zhí)行器列表, 支持編輯刪除。

以下是執(zhí)行器的屬性說(shuō)明：

具體操作：

（1）新增執(zhí)行器：

（2）自動(dòng)注冊(cè)和手動(dòng)注冊(cè)的區(qū)別和配置

2.2.2 在調(diào)度中心新建任務(wù)

在任務(wù)管理->新建，填寫(xiě)以下內(nèi)容

• 執(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è)置

• 任務(wù)描述：任務(wù)的描述信息，便于任務(wù)管理

  路由策略：當(dāng)執(zhí)行器集群部署時(shí)，提供豐富的路由策略，包括

  • FIRST（第一個(gè)）：固定選擇第一個(gè)機(jī)器；

  • LAST（最后一個(gè)）：固定選擇最后一個(gè)機(jī)器；

  • ROUND（輪詢(xún)）：

  • 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ù)開(kāi)發(fā)分片任務(wù)；

• Cron：觸發(fā)任務(wù)執(zhí)行的Cron表達(dá)式；

• 運(yùn)行模式：

  • BEAN模式：任務(wù)以JobHandler方式維護(hù)在執(zhí)行器端；需要結(jié)合 “JobHandler” 屬性匹配執(zhí)行器中任務(wù)；

  • GLUE模式(Java)：任務(wù)以源碼方式維護(hù)在調(diào)度中心；該模式的任務(wù)實(shí)際上是一段繼承自IJobHandler的Java類(lèi)代碼并 “groovy” 源碼方式維護(hù)，它在執(zhí)行器項(xiàng)目中運(yùn)行，可使用@Resource/@Autowire注入執(zhí)行器里中的其他服務(wù)；

  • GLUE模式(Shell)：任務(wù)以源碼方式維護(hù)在調(diào)度中心；該模式的任務(wù)實(shí)際上是一段 “shell” 腳本；

  • GLUE模式(Python)：任務(wù)以源碼方式維護(hù)在調(diào)度中心；該模式的任務(wù)實(shí)際上是一段 “python” 腳本；

  • GLUE模式(PHP)：任務(wù)以源碼方式維護(hù)在調(diào)度中心；該模式的任務(wù)實(shí)際上是一段 “php” 腳本；

  • GLUE模式(NodeJS)：任務(wù)以源碼方式維護(hù)在調(diào)度中心；該模式的任務(wù)實(shí)際上是一段 “nodejs” 腳本；

  • GLUE模式(PowerShell)：任務(wù)以源碼方式維護(hù)在調(diào)度中心；該模式的任務(wù)實(shí)際上是一段 “PowerShell” 腳本；

• JobHandler：運(yùn)行模式為 “BEAN模式” 時(shí)生效，對(duì)應(yīng)執(zhí)行器中新開(kāi)發(fā)的JobHandler類(lèi)“@JobHandler”注解自定義的value值；

• 阻塞處理策略：調(diào)度過(guò)于密集執(zhí)行器來(lái)不及處理時(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ù)；

• 子任務(wù)：每個(gè)任務(wù)都擁有一個(gè)唯一的任務(wù)ID(任務(wù)ID可以從任務(wù)列表獲取)，當(dāng)本任務(wù)執(zhí)行結(jié)束并且執(zhí)行成功時(shí)，將會(huì)觸發(fā)子任務(wù)ID所對(duì)應(yīng)的任務(wù)的一次主動(dòng)調(diào)度。

• 任務(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)行重試；

• 報(bào)警郵件：任務(wù)調(diào)度失敗時(shí)郵件通知的郵箱地址，支持配置多郵箱地址，配置多個(gè)郵箱地址時(shí)用逗號(hào)分隔；

• 負(fù)責(zé)人：任務(wù)的負(fù)責(zé)人；

• 執(zhí)行參數(shù)：任務(wù)執(zhí)行所需的參數(shù)；

2.2.3 搭建springboot項(xiàng)目

新建項(xiàng)目：xxl-job-demo

（1）pom文件

<groupId>com.itheima</groupId>
<artifactId>xxl-job-demo</artifactId>
<version>1.0-SNAPSHOT</version>
<!-- 繼承Spring boot工程 -->
<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.5.RELEASE</version>
</parent>

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!-- xxl-job -->
    <dependency>
        <groupId>com.xuxueli</groupId>
        <artifactId>xxl-job-core</artifactId>
        <version>2.2.0-SNAPSHOT</version>
    </dependency>
</dependencies>

<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

注意：如果項(xiàng)目中沒(méi)有找到xxl-job-core這個(gè)依賴(lài)，需要把這個(gè)依賴(lài)安裝到本地的maven倉(cāng)庫(kù)

(2)配置有兩個(gè)，一個(gè)是application.properties，另外一個(gè)是日志配置:logback.xml

application.properties

# web port
server.port=${port:8801}
# no web
#spring.main.web-environment=false

# log config
logging.config=classpath:logback.xml


### xxl-job admin address list, such as "http://address" or "http://address01,http://address02"
xxl.job.admin.addresses=http://localhost:8888/xxl-job-admin

### xxl-job, access token
xxl.job.accessToken=

### xxl-job executor appname
xxl.job.executor.appname=xxl-job-executor-sample
### xxl-job executor registry-address: default use address to registry , otherwise use ip:port if address is null
xxl.job.executor.address=
### xxl-job executor server-info
xxl.job.executor.ip=
xxl.job.executor.port=${executor.port:9999}
### xxl-job executor log-path
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
### xxl-job executor log-retention-days
xxl.job.executor.logretentiondays=30

logback.xml

<?xml version="1.0" encoding="UTF-8"?>
<configuration debug="false" scan="true" scanPeriod="1 seconds">

    <contextName>logback</contextName>
    <property name="log.path" value="/data/applogs/xxl-job/xxl-job-executor-sample-springboot.log"/>

    <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
        <encoder>
            <pattern>%d{HH:mm:ss.SSS} %contextName [%thread] %-5level %logger{36} - %msg%n</pattern>
        </encoder>
    </appender>

    <appender name="file" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>${log.path}</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <fileNamePattern>${log.path}.%d{yyyy-MM-dd}.zip</fileNamePattern>
        </rollingPolicy>
        <encoder>
            <pattern>%date %level [%thread] %logger{36} [%file : %line] %msg%n
            </pattern>
        </encoder>
    </appender>

    <root level="info">
        <appender-ref ref="console"/>
        <appender-ref ref="file"/>
    </root>

</configuration>

(3)引導(dǎo)類(lèi)：

package com.itheima.xxljob;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class XxlJobApplication {

    public static void main(String[] args) {
        SpringApplication.run(XxlJobApplication.class,args);
    }
}

2.2.4 添加xxl-job配置

添加配置類(lèi)：

這個(gè)類(lèi)主要是創(chuàng)建了任務(wù)執(zhí)行器，參考官方案例編寫(xiě)，無(wú)須改動(dòng)

package com.itheima.xxljob.config;

import 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;

/**
 * xxl-job config
 *
 * @author xuxueli 2017-04-28
 */
@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;
    }

    /**
     * 針對(duì)多網(wǎng)卡、容器內(nèi)部署等情況，可借助 "spring-cloud-commons" 提供的 "InetUtils" 組件靈活定制注冊(cè)IP；
     *
     *      1、引入依賴(lài)：
     *          <dependency>
     *             <groupId>org.springframework.cloud</groupId>
     *             <artifactId>spring-cloud-commons</artifactId>
     *             <version>${version}</version>
     *         </dependency>
     *
     *      2、配置文件，或者容器啟動(dòng)變量
     *          spring.cloud.inetutils.preferred-networks: 'xxx.xxx.xxx.'
     *
     *      3、獲取IP
     *          String ip_ = inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();
     */


}

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

package com.itheima.xxljob.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;

import java.time.LocalDateTime;


@Component
public class HelloJob {

    @Value("${server.port}")
    private String appPort;

    @XxlJob("helloJob")
    public ReturnT<String> hello(String param) throws Exception {
        System.out.println("helloJob："+ LocalDateTime.now()+",端口號(hào)"+appPort);
        return ReturnT.SUCCESS;
    }
}

@XxlJob("helloJob")這個(gè)一定要與調(diào)度中心新建任務(wù)的JobHandler的值保持一致,如下圖：

2.2.6 測(cè)試

（1）首先啟動(dòng)調(diào)度中心

（2）啟動(dòng)xxl-job-demo項(xiàng)目，為了展示更好的效果，可以同時(shí)啟動(dòng)三個(gè)項(xiàng)目，用同一個(gè)JobHandler，查看處理方式。

在啟動(dòng)多個(gè)項(xiàng)目的時(shí)候，端口需要切換，連接xxl-job的執(zhí)行器端口不同相同

服務(wù)一：默認(rèn)啟動(dòng)8801端口，執(zhí)行器端口為9999

idea中不用其他配置，直接啟動(dòng)項(xiàng)目即可

服務(wù)二：項(xiàng)目端口：8802，執(zhí)行器端口：9998

idea配置如下：

• 編輯配置，Edit Configurations…

• 選中XxlJobApplication，點(diǎn)擊復(fù)制

• 修改參數(shù)

• 啟動(dòng)：選中8802啟動(dòng)項(xiàng)目

服務(wù)三：項(xiàng)目端口：8803，執(zhí)行器端口：9997

（3）測(cè)試效果

三個(gè)項(xiàng)目啟動(dòng)后，可以查看到是輪詢(xún)的方式分別去執(zhí)行當(dāng)前調(diào)度任務(wù)。文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-616577.html

到了這里，關(guān)于xxl-Job分布式任務(wù)調(diào)度的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！