日常開發中難免會碰到需要開啟定時任務處理業務，這時我們第一時間想到的是Spring的Task，但是很不方便，這里可以列出幾點：
1.一旦需要更改定時任務時間，我們就要打開IDE修改cron運算式；
2.在特殊的情況下代碼報錯了，我們就要打開Log查看是什么導致的問題；
3.需要很多定時任務去處理業務就要新建多個，突然不想執行這個任務了，我們就要再打開IDE注釋那些代碼，
就特別不好管理，
可能又有人要說了：
1.我可以用Redis進行動態修改cron運算式；-------- 看下面代碼！！！
2.我寫個Aop，只要出現例外了我就記錄相關資訊；-------- 牛掰！Aop固然好，但是你覺得真的方便了嗎？
3.······我就是不閑麻煩，咋地，-------- 打擾了！！！
package cn.chenghao.config; import lombok.AllArgsConstructor; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.SchedulingConfigurer; import org.springframework.scheduling.config.ScheduledTaskRegistrar; import org.springframework.scheduling.support.CronTrigger; import javax.annotation.PostConstruct; /** * 自定義定時任務 * * @Author chenghao * @Date 2020/4/14 11:56 **/ @Configuration @EnableScheduling @AllArgsConstructor public class CompleteScheduleConfig implements SchedulingConfigurer { /** * StringRedis模板 */ private final StringRedisTemplate stringRedisTemplate; /** * 初始化 */ @PostConstruct private void init() { // redis中不存在則創建 stringRedisTemplate.opsForValue().setIfAbsent("cron", "0/3 * * * * ?"); } /** * 配置任務 */ @Override public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { // 給定cron運算式，觸發Runnable任務 scheduledTaskRegistrar.addTriggerTask( () -> { System.out.println("執行定時任務中......."); }, triggerContext -> { // 獲取cron運算式 String cron = stringRedisTemplate.opsForValue().get("cron"); // 回傳執行周期 return new CronTrigger(cron).nextExecutionTime(triggerContext); }); } }
!(真的是太方便了)
----------------------------------好，廢話不再多說----------------------------------
XXL-JOB地址：
Gitee：https://gitee.com/xuxueli0323/xxl-job
GitHub：https://github.com/xuxueli/xxl-job/
XXL社區：https://www.xuxueli.com/xxl-job/
概述：XXL-JOB是一個分布式任務調度平臺，其核心設計目標是開發迅速、學習簡單、輕量級、易擴展，現已開放源代碼并接入多家公司線上產品線，開箱即用，
首先將專案clone下來后，再打開社區檔案，根據檔案引導先將 doc/db/tables_xxl_job.sql 腳本在自己的資料庫中執行
確認無誤后，再繼續看檔案：
XXL-JOB分為三個大模塊：調度中心、公共依賴、執行器
首先我們根據檔案引導，配置調度中心
/xxl-job/xxl-job-admin/src/main/resources/application.properties
想想還是截個圖：
相應配置完成后，直接運行admin模塊，瀏覽器輸入：http://localhost:8080/xxl-job-admin 默認登錄賬號 admin/123456
剛進去這首頁我還是很吃驚的！！！
調度器配置、運行都成功了現在我們就要新建個任務看看效果了，在這之前我們還要配置執行器，也就是執行任務的容器
/xxl-job/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/resources/application.properties
想來想去我又截了：
配置好對應調度中心的資訊后，我們在運行執行器
運行沒問題后，我們來新建個任務試試水：
我們就先用GLUE模式試試吧
保存完后，直接點擊啟動！！！
看控制臺：
看日志：
任何操作一目了然！！！
現在我們知道了XXL-JOB的作用了，就在想怎么對接到自己的專案運行，其實想想就是將公共依賴模塊移出來
<!-- xxl-job 任務調度 --> <dependency> <groupId>com.xuxueli</groupId> <artifactId>xxl-job-core</artifactId> <version>2.2.0</version> </dependency>
隨后根據clone下來專案中的springboot版本的執行器復制 application.properties
package cn.running.taskdispatchdemo.config; import com.xxl.job.core.executor.impl.XxlJobSpringExecutor; import lombok.extern.java.Log; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; /** * 執行器配置 * * @author chenghao * @createTime 2020/5/21 */ @Log @Configuration @ComponentScan(basePackages = "cn.running.taskdispatchdemo.handler") public class XxlJobConfig { @Value("${xxl.job.admin.addresses}") private String adminAddresses; @Value("${xxl.job.executor.appname}") private String appName; @Value("${xxl.job.executor.ip}") private String ip; @Value("${xxl.job.executor.port}") private int port; @Value("${xxl.job.accessToken}") private String accessToken; @Value("${xxl.job.executor.logpath}") private String logPath; @Value("${xxl.job.executor.logretentiondays}") private int logRetentionDays; @Bean(initMethod = "start") public XxlJobSpringExecutor xxlJobSpringExecutor() { log.info("》》》》》 XXL-JOB 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; } }
基本配置完成后，現在調度中心新增執行器，再啟動我們新建的執行器保存后，稍微等待一點時間，就自動注冊上去了！！！
在調度中心頁面新增個任務:
缺少JobHandler 需要我們去新建
package cn.running.taskdispatchdemo.handler; import com.xxl.job.core.biz.model.ReturnT; import com.xxl.job.core.handler.annotation.XxlJob; import org.springframework.stereotype.Component; import java.time.LocalDateTime; /** * 任務處理 * * @author chenghao * @createTime 2020/5/21 */ @Component("myHandler") public class MyHandler { @XxlJob("demoJobHandler") public ReturnT<String> execute(String s) { System.out.println("任務執行成功,執行引數：" + s + "當前時間是：" + LocalDateTime.now()); return ReturnT.SUCCESS; } }
這樣就ok了，重啟執行器就行了，再啟動任務
看控制臺：
看日志：
至此，我們再來看看首頁的樣子
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/167434.html
標籤：Java