接上一篇：
搭建xxl-job任務(wù)調(diào)度中心
https://gblfy.blog.csdn.net/article/details/113809843

文章目錄

• • • • • 一、SpringBoot 配置
        • • 1. maven依賴
          • 2. 執(zhí)行器配置 application.yml
          • 3. 執(zhí)行器組件配置
          • 4. 部署執(zhí)行器項目
        • 二、xxl-job任務(wù)調(diào)度中心
        • • 2.1. 執(zhí)行器管理
          • 2.2. 任務(wù)管理
        • 三、Springboot創(chuàng)建任務(wù)
        • • 3.1. 創(chuàng)建任務(wù)
        • 四、xxl-job任務(wù)調(diào)度中心
        • • 4.1. 查看執(zhí)行器是否注冊成功
          • 4.2. 執(zhí)行任務(wù)
          • 4.3. 執(zhí)行任務(wù)失敗
          • 4.4. 修改執(zhí)行器ip
          • 4.5. 再次執(zhí)行任務(wù)
          • 4.6. 頻次執(zhí)行

一、SpringBoot 配置

Github地址
https://www.xuxueli.com/xxl-job/

1. maven依賴

<!-- http://repo1.maven.org/maven2/com/xuxueli/xxl-job-core/ --><dependency><groupId>com.xuxueli</groupId><artifactId>xxl-job-core</artifactId><version>2.3.0</version></dependency>

2. 執(zhí)行器配置 application.yml

server:port: 80xxl:job:admin:addresses: http://192.168.43.119:8080/xxl-job-admin/executor:appname: xxl-job-executor-samplelogpath: H:/data/applogs/xxl-job/jobhandlerlogretentiondays: 30# 具體解釋見Github文檔

3. 執(zhí)行器組件配置

package com.gblfy.distributedjob.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;@Configuration public class XxlJobConfig {private final static Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);@Value("${xxl.job.admin.addresses}")private String adminAddresses;@Value("${xxl.job.executor.appname}")private String appname;@Value("${xxl.job.executor.logpath}")private String logPath;@Value("${xxl.job.executor.logretentiondays}")private int logRetentionDays;@Beanpublic XxlJobSpringExecutor xxlJobExecutor() {logger.info(">>>>>>>>>>> xxl-job config init.");XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();xxlJobSpringExecutor.setAdminAddresses(adminAddresses);xxlJobSpringExecutor.setAppname(appname);// xxlJobSpringExecutor.setIp(ip);// xxlJobSpringExecutor.setPort(port);// xxlJobSpringExecutor.setAccessToken(accessToken);xxlJobSpringExecutor.setLogPath(logPath);xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);return xxlJobSpringExecutor;} }

4. 部署執(zhí)行器項目

至此“執(zhí)行器”項目已經(jīng)部署結(jié)束。

二、xxl-job任務(wù)調(diào)度中心

搭建xxl-job任務(wù)調(diào)度中心
https://gblfy.blog.csdn.net/article/details/113809843

2.1. 執(zhí)行器管理

Springboot項目（執(zhí)行器）啟動后，連接xxl-job任務(wù)調(diào)度中心會有延遲，需要等一會

【執(zhí)行器管理】-【查看】可以清楚地看到自己的外網(wǎng)ip地址
注：默認(rèn)顯示無

2.2. 任務(wù)管理

【任務(wù)管理】-【新增】
JobHandler用來連接任務(wù)類的標(biāo)識，自定義即可

三、Springboot創(chuàng)建任務(wù)

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

package com.gblfy.distributedjob.task;import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.annotation.XxlJob; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component;@Component public class TaskExecute {private final static Logger logger = LoggerFactory.getLogger(TaskExecute.class);@XxlJob("myJobHandler")public void execute() {// 獲取參數(shù)String param = XxlJobHelper.getJobParam();//控制臺輸出日志logger.info("myXxlJobHandler execute...");//寫日志到調(diào)度中心日志中XxlJobHelper.log("myXxlJobHandler execute...");// 設(shè)置任務(wù)結(jié)果XxlJobHelper.handleSuccess();} }

四、xxl-job任務(wù)調(diào)度中心

4.1. 查看執(zhí)行器是否注冊成功

4.2. 執(zhí)行任務(wù)

4.3. 執(zhí)行任務(wù)失敗

控制臺沒有輸出

查看任務(wù)執(zhí)行日志



發(fā)現(xiàn)了，ip(169.254.118.15)居然是公網(wǎng)的,我的ip應(yīng)該是192.168.43.147

4.4. 修改執(zhí)行器ip

4.5. 再次執(zhí)行任務(wù)

控制臺輸出

執(zhí)行日志

4.6. 頻次執(zhí)行

總結(jié)

以上是生活随笔為你收集整理的SpringBoot2 集成 xxl-job任务调度中心的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。