Springboot集成分布式任務調(diào)度系統(tǒng)XXl-Job(調(diào)度器和執(zhí)行器)

作者：言沫東 2023-11-07 07:56:40

我們部署的是調(diào)度器管理平臺，執(zhí)行器就是我們實際開發(fā)的應用系統(tǒng)：比如：會員系統(tǒng)、訂單系統(tǒng)、結(jié)算系統(tǒng)等等；執(zhí)行器管理可以對每一個注冊上來的執(zhí)行器進行管理（編輯、刪除執(zhí)行器等）。

一、部署xxl-job服務端

下載xxl-job源碼

下載地址：https://gitee.com/xuxueli0323/xxl-job

二、導入項目、創(chuàng)建xxl_job數(shù)據(jù)庫、修改配置文件為自己的數(shù)據(jù)庫

三、啟動項目、訪問首頁

訪問地址：http://localhost:8080/xxl-job-admin/ 賬號：admin 密碼：123456.

執(zhí)行器管理

任務管理

我們應用系統(tǒng)都會有自己特定的job任務：比如：會員系統(tǒng)定時拉取一些會員推送模板消息、短信消息；結(jié)算系統(tǒng)定時生成結(jié)算任務、報表等。任務管理可根據(jù)具體的執(zhí)行器、job任務名稱（JobHandler）、任務描述等進行篩選；可新增任務、啟動任務、執(zhí)行任務、查詢調(diào)度日志，功能比較豐富。

用戶管理

用戶管理可根據(jù)角色（普通用戶、管理員）進行管理：新增用戶、刪除用戶。

調(diào)度日志

在調(diào)度日志模塊可查詢我們執(zhí)行任務時的具體情況，可根據(jù)具體的執(zhí)行器、任務名稱、執(zhí)行狀態(tài)進行篩選（成功、失敗、進行中），對于進行中的任務可手動終止；調(diào)度備注列可查看調(diào)度詳情，比如：我們的任務被調(diào)度到哪一臺機器、調(diào)度的結(jié)果碼、結(jié)果信息等等。

運行報表

運行報表是對調(diào)度平臺中執(zhí)行器數(shù)、任務數(shù)、調(diào)度次數(shù)、調(diào)度明細（成功、失敗）數(shù)據(jù)的匯總統(tǒng)計。

四、新建結(jié)算系統(tǒng)執(zhí)行器【僅僅是個demo案例】

看到此處，想必大家心中對xxl-job已經(jīng)有了一些初步的了解和感受，摩拳擦掌，趁熱打鐵，下面我們新建一個結(jié)算系統(tǒng)應用，注冊到調(diào)度平臺，并新建一個月結(jié)任務，測試下吧。

引入xxl-job調(diào)度器依賴

<dependency>
         <groupId>com.xuxueli</groupId>
         <artifactId>xxl-job-core</artifactId>
         <version>2.3.1</version>
</dependency>

application.properties配置文件新增xxl-job配置

#xxljob config
#調(diào)度器地址
xxl.job.admin.addresses = http://127.0.0.1:8080/xxl-job-admin
#鑒權(quán)用暫無
xxl.job.accessToken =
#執(zhí)行器名稱（就是我們的業(yè)務系統(tǒng)） 
xxl.job.executor.appname = settle-system
#執(zhí)行器地址和ip，demo案例無需填寫
xxl.job.executor.address =
xxl.job.executor.ip =
#執(zhí)行器端口：默認值：9999
xxl.job.executor.port = 9999
#日志路徑
xxl.job.executor.logpath = D:\\tmp\\log
#日志清理時間
xxl.job.executor.logretentiondays = 30

執(zhí)行器配置類(XxlJobConfig.java)：

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.beans.factory.annotation.Value;
import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
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;
    }

編寫結(jié)算系統(tǒng)-月結(jié)job任務(MonthlySettlementJobHandler.java)

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import com.xxl.job.core.handler.annotation.XxlJob;

@Component
public class MonthlySettlementJobHandler {

    private static Logger logger = LoggerFactory.getLogger(MonthlySettlementJobHandler.class);

		// 使用@XxlJob注解，將monthlySettlementJobHandler任務注冊到調(diào)度平臺
    @XxlJob("monthlySettlementJobHandler")
    public void monthlySettlementJobHandler(String param) throws InterruptedException {
        try {
            logger.info("結(jié)算系統(tǒng)-月結(jié)任務執(zhí)行 參數(shù): {}", param);
        } catch (Exception e) {
            logger.error("結(jié)算系統(tǒng)-月結(jié)任務執(zhí)行 異常 參數(shù): {} 異常信息: ", param, e);
        }
    }
}

結(jié)算系統(tǒng)執(zhí)行器代碼編寫完畢，啟動成功后，就需要去調(diào)度器管理平臺新建我們的執(zhí)行器、以及我們的job任務了。