文章目錄

• • • • • 一、xxl-job任務調度中心
        • • 1. 調度中心創建任務
          • 2. 調度中心創建執行器
        • 二、執行器任務編碼
        • • 2.1. 單參數
          • 2.2. 多參數
        • 三、調度中心參數傳遞測試
        • • 3.1. 單個參數傳遞
          • 3.2. 多個參數傳遞

前提：執行器和xxl-job任務調度中心啟動完畢

一、xxl-job任務調度中心

1. 調度中心創建任務

2. 調度中心創建執行器

注：一定要和執行器ip對上，外網ip不可以

二、執行器任務編碼

2.1. 單參數

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);/*** 任務調度入口** <p>* 參數1: 執行日期 executeDate 2021-02-15* 參數2: 執行標識 executeFlag I-增量 F-全量* 參數3: 表名稱 tableName sys_user* 參數4: 管理機構 manageCom 86* 參數5: 執行場景 executeScene UPDATE* </p>*/@XxlJob("myJobHandler")public void execute() {// 獲取參數String param = XxlJobHelper.getJobParam();logger.info("接收調度中心參數...[{}]",param);//控制臺輸出日志logger.info("myXxlJobHandler execute...");try {//書寫業務邏輯//TODO//寫日志到調度中心日志中XxlJobHelper.log("myXxlJobHandler execute Success...");// 設置任務結果XxlJobHelper.handleSuccess();} catch (Exception e) {logger.error("myXxlJobHandler execute Fail ...", e);//寫日志到調度中心日志中XxlJobHelper.log("myXxlJobHandler execute Fail...");// 設置任務結果XxlJobHelper.handleFail();}} }

2.2. 多參數

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);/*** 任務調度入口** <p>* 參數1: 執行日期 executeDate 2021-02-15* 參數2: 執行標識 executeFlag I-增量 F-全量* 參數3: 表名稱 tableName sys_user* 參數4: 管理機構 manageCom 86* 參數5: 執行場景 executeScene UPDATE* </p>*/@XxlJob("myJobHandler")public void execute() {// 獲取參數String param = XxlJobHelper.getJobParam();String[] methodParams = param.split(",");logger.info("執行日期...[{}]", methodParams[0]);logger.info("執行標識...[{}]", methodParams[1]);logger.info("表名稱 ...[{}]", methodParams[2]);logger.info("管理機構...[{}]", methodParams[3]);logger.info("執行場景...[{}]", methodParams[4]);//控制臺輸出日志logger.info("myXxlJobHandler execute...");try {//書寫業務邏輯//TODO//寫日志到調度中心日志中XxlJobHelper.log("myXxlJobHandler execute Success...");// 設置任務結果XxlJobHelper.handleSuccess();} catch (Exception e) {logger.error("myXxlJobHandler execute Fail ...", e);//寫日志到調度中心日志中XxlJobHelper.log("myXxlJobHandler execute Fail...");// 設置任務結果XxlJobHelper.handleFail();}} }

三、調度中心參數傳遞測試

3.1. 單個參數傳遞

3.2. 多個參數傳遞

用，分割

2021-02-15,I,sys_user,86,UPDATE

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。