最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

SpringCloud如何引用xxjob定時(shí)任務(wù)

 更新時(shí)間:2024年04月12日 12:16:42   作者:杰拉德·皮克·謝  
Spring?Cloud?本身不直接支持?XXL-JOB?這樣的定時(shí)任務(wù)框架,如果你想在?Spring?Cloud?應(yīng)用中集成?XXL-JOB,你需要手動(dòng)進(jìn)行配置,本文給大家介紹SpringCloud如何引用xxjob定時(shí)任務(wù),感興趣的朋友一起看看吧

SpringClout 引用 xxjob定時(shí)任務(wù)

下載源碼

分布式任務(wù)調(diào)度平臺(tái)XXL-JOB-官網(wǎng)地址
源碼地址

組成部分

調(diào)度中心
作用:統(tǒng)一管理任務(wù)調(diào)度平臺(tái)上調(diào)度任務(wù),負(fù)責(zé)觸發(fā)調(diào)度執(zhí)行,并且提供任務(wù)管理平臺(tái)。
公共依賴(lài)
xxl-job-core
執(zhí)行器
作用:負(fù)責(zé)接收“調(diào)度中心”的調(diào)度并執(zhí)行;可直接部署執(zhí)行器,也可以將執(zhí)行器集成到現(xiàn)有業(yè)務(wù)項(xiàng)目中。

調(diào)度中心使用步驟

修改調(diào)度中心配置

位置:/xxl-job/xxl-job-admin/src/main/resources/application.properties

配置解釋

### 調(diào)度中心JDBC鏈接:鏈接地址請(qǐng)保持和 2.1章節(jié) 所創(chuàng)建的調(diào)度數(shù)據(jù)庫(kù)的地址一致
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/xxl_job?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=root_pwd
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
### 報(bào)警郵箱
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
### 調(diào)度中心通訊TOKEN [選填]:非空時(shí)啟用;
xxl.job.accessToken=
### 調(diào)度中心國(guó)際化配置 [必填]: 默認(rèn)為 "zh_CN"/中文簡(jiǎn)體, 可選范圍為 "zh_CN"/中文簡(jiǎn)體, "zh_TC"/中文繁體 and "en"/英文;
xxl.job.i18n=zh_CN
## 調(diào)度線(xiàn)程池最大線(xiàn)程配置【必填】
xxl.job.triggerpool.fast.max=200
xxl.job.triggerpool.slow.max=100
### 調(diào)度中心日志表數(shù)據(jù)保存天數(shù) [必填]:過(guò)期日志自動(dòng)清理;限制大于等于7時(shí)生效,否則, 如-1,關(guān)閉自動(dòng)清理功能;
xxl.job.logretentiondays=30

啟動(dòng)驗(yàn)證

1.啟動(dòng)類(lèi)啟動(dòng)
2.登錄網(wǎng)址:http://localhost:8080/xxl-job-admin/jobinfo

3.admin 123456 (登錄密碼也可在數(shù)據(jù)庫(kù)中自定義)

執(zhí)行器使用步驟

修改執(zhí)行器配置

1.引入依賴(lài)

<!-- xxl-job-core -->
<dependency>
    <groupId>com.lazzen.cloud</groupId>
    <artifactId>cloud-xxl-job-core</artifactId>
</dependency>

2.修改配置

#調(diào)度中心部署跟地址 [選填]:如調(diào)度中心集群部署存在多個(gè)地址則用逗號(hào)分隔。執(zhí)行器將會(huì)使用該地址進(jìn)行"執(zhí)行器心跳注冊(cè)"和"任務(wù)結(jié)果回調(diào)";為空則關(guān)閉自動(dòng)注冊(cè);
xxl.job.admin.addresses=http://127.0.0.1:8080/xxl-job-admin
#執(zhí)行器通訊TOKEN [選填]:非空時(shí)啟用;
xxl.job.accessToken=
#執(zhí)行器AppName [選填]:執(zhí)行器心跳注冊(cè)分組依據(jù);為空則關(guān)閉自動(dòng)注冊(cè)
xxl.job.executor.appname=xxl-job-executor-sample
#執(zhí)行器注冊(cè) [選填]:優(yōu)先使用該配置作為注冊(cè)地址,為空時(shí)使用內(nèi)嵌服務(wù) ”IP:PORT“ 作為注冊(cè)地址。從而更靈活的支持容器類(lèi)型執(zhí)行器動(dòng)態(tài)IP和動(dòng)態(tài)映射端口問(wèn)題。
xxl.job.executor.address=
#執(zhí)行器IP [選填]:默認(rèn)為空表示自動(dòng)獲取IP,多網(wǎng)卡時(shí)可手動(dòng)設(shè)置指定IP,該IP不會(huì)綁定Host僅作為通訊實(shí)用;地址信息用于 "執(zhí)行器注冊(cè)" 和 "調(diào)度中心請(qǐng)求并觸發(fā)任務(wù)";
xxl.job.executor.ip=
#執(zhí)行器端口號(hào) [選填]:小于等于0則自動(dòng)獲??;默認(rèn)端口為9999,單機(jī)部署多個(gè)執(zhí)行器時(shí),注意要配置不同執(zhí)行器端口;
xxl.job.executor.port=9999
#執(zhí)行器運(yùn)行日志文件存儲(chǔ)磁盤(pán)路徑 [選填] :需要對(duì)該路徑擁有讀寫(xiě)權(quán)限;為空則使用默認(rèn)路徑;
xxl.job.executor.logpath=/data/applogs/xxl-job/jobhandler
#執(zhí)行器日志文件保存天數(shù) [選填] : 過(guò)期日志自動(dòng)清理, 限制值大于等于3時(shí)生效; 否則, 如-1, 關(guān)閉自動(dòng)清理功能;
xxl.job.executor.logretentiondays=30

執(zhí)行器組件配置

執(zhí)行器組件,配置文件地址:XxlJobConfig.java

    @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;
    }

啟動(dòng)

創(chuàng)建定時(shí)任務(wù)

創(chuàng)建任務(wù)代碼

此處的業(yè)務(wù)邏輯就遵循三層架構(gòu)沒(méi)有什么特別之處

@Slf4j
@Component
@AllArgsConstructor
public class xxjobTest {
    private final OamTimingAirconditionService oamTimingAirconditionService;
    /**
     * 定時(shí)分合閘處理器
     */
    @XxlJob("demoJobHandler")
    public void lightingGateway() {
        XxlJobHelper.log("定時(shí)任務(wù)開(kāi)始執(zhí)行.....");
        // 讀取參數(shù)
        String param = XxlJobHelper.getJobParam();
        if (param == null || param.trim().isEmpty()) {
            // 參數(shù)錯(cuò)誤
            XxlJobHelper.log("param[" + param + "] invalid.");
            XxlJobHelper.handleFail();
            return;
        }
        try {
            // 業(yè)務(wù)邏輯
            XxlJobHelper.handleSuccess();
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
            XxlJobHelper.log(ex);
            XxlJobHelper.handleFail();
        }finally {
            DynamicDataSourceExt.clearCustomIdThreadLocal();
        }
        XxlJobHelper.log("定時(shí)任務(wù)執(zhí)行結(jié)束!");
    }
}

附加已有項(xiàng)目調(diào)用xxjob API

到此這篇關(guān)于SpringCloudt 引用 xxjob定時(shí)任務(wù)的文章就介紹到這了,更多相關(guān)SpringCloud  xxjob定時(shí)任務(wù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Jenkins Pipeline為Kubernetes應(yīng)用部署增加狀態(tài)檢測(cè)腳本優(yōu)化

    Jenkins Pipeline為Kubernetes應(yīng)用部署增加狀態(tài)檢測(cè)腳本優(yōu)化

    這篇文章主要為大家介紹了Jenkins Pipeline為Kubernetes應(yīng)用部署增加狀態(tài)檢測(cè)腳本優(yōu)化示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-12-12
  • Java實(shí)現(xiàn)電影院訂票系統(tǒng)代碼

    Java實(shí)現(xiàn)電影院訂票系統(tǒng)代碼

    這篇文章主要介紹了Java實(shí)現(xiàn)電影院訂票系統(tǒng)代碼,代碼實(shí)現(xiàn)了界面類(lèi)登錄注冊(cè)類(lèi),用戶(hù)類(lèi)等,具有一定參考價(jià)值,需要的朋友可以參考下。
    2017-11-11
  • Java同步代碼塊解決銀行取錢(qián)的安全問(wèn)題實(shí)例分析

    Java同步代碼塊解決銀行取錢(qián)的安全問(wèn)題實(shí)例分析

    這篇文章主要介紹了Java同步代碼塊解決銀行取錢(qián)的安全問(wèn)題,結(jié)合實(shí)例形式分析了java基于線(xiàn)程的同步問(wèn)題實(shí)現(xiàn)與使用相關(guān)操作技巧,需要的朋友可以參考下
    2019-08-08
  • JAVA抽象類(lèi)及接口使用方法解析

    JAVA抽象類(lèi)及接口使用方法解析

    這篇文章主要介紹了JAVA抽象類(lèi)及接口使用方法解析,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-08-08
  • SpringBoot快速實(shí)現(xiàn)接口消息加密的過(guò)程詳解

    SpringBoot快速實(shí)現(xiàn)接口消息加密的過(guò)程詳解

    在項(xiàng)目中,為了保證數(shù)據(jù)的安全,我們常常會(huì)對(duì)傳遞的數(shù)據(jù)進(jìn)行加密,常用的加密算法包括對(duì)稱(chēng)加密(AES)和非對(duì)稱(chēng)加密(RSA),博主選取碼云上最簡(jiǎn)單的API加密項(xiàng)目進(jìn)行下面的講解,需要的朋友可以參考下
    2023-11-11
  • Java中byte、byte數(shù)組與int、long的轉(zhuǎn)換詳解

    Java中byte、byte數(shù)組與int、long的轉(zhuǎn)換詳解

    這篇文章分別給大家介紹了Java中byte和int之間的轉(zhuǎn)換、Java中 byte數(shù)組和int之間的轉(zhuǎn)換、Java中byte數(shù)組和long之間的轉(zhuǎn)換以及整理了整體工具類(lèi)的源碼,需要的朋友可以參考借鑒,下面來(lái)一起看看吧。
    2017-02-02
  • Spring?Boot常用的參數(shù)驗(yàn)證技巧和使用方法

    Spring?Boot常用的參數(shù)驗(yàn)證技巧和使用方法

    Spring Boot是一個(gè)使用Java編寫(xiě)的開(kāi)源框架,用于快速構(gòu)建基于Spring的應(yīng)用程序,這篇文章主要介紹了Spring?Boot常用的參數(shù)驗(yàn)證技巧和使用方法,需要的朋友可以參考下
    2023-09-09
  • Spring SmartLifecycle:如何精準(zhǔn)控制Bean的生命周期

    Spring SmartLifecycle:如何精準(zhǔn)控制Bean的生命周期

    這篇文章主要介紹了Spring SmartLifecycle:如何精準(zhǔn)控制Bean的生命周期問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2025-03-03
  • Java設(shè)計(jì)模式之裝飾模式(Decorator模式)介紹

    Java設(shè)計(jì)模式之裝飾模式(Decorator模式)介紹

    這篇文章主要介紹了Java設(shè)計(jì)模式之裝飾模式(Decorator模式)介紹,本文講解了為什么使用Decorator、如何使用裝飾模式、Jive中的Decorator實(shí)現(xiàn)等內(nèi)容,需要的朋友可以參考下
    2015-03-03
  • JDBC PreparedStatement Like參數(shù)報(bào)錯(cuò)解決方案

    JDBC PreparedStatement Like參數(shù)報(bào)錯(cuò)解決方案

    這篇文章主要介紹了JDBC PreparedStatement Like參數(shù)報(bào)錯(cuò)解決方案,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-10-10

最新評(píng)論

白沙| 昌吉市| 收藏| 鹿泉市| 锡林郭勒盟| 阿拉善左旗| 山东省| 九江县| 文成县| 墨脱县| 饶平县| 襄汾县| 思茅市| 余姚市| 凤山市| 同心县| 太仆寺旗| 乐清市| 洛隆县| 德阳市| 油尖旺区| 怀柔区| 宁海县| 宁阳县| 中西区| 蓝田县| 民权县| 随州市| 红桥区| 齐齐哈尔市| 丰城市| 唐海县| 东至县| 炎陵县| 咸宁市| 炉霍县| 台湾省| 嘉禾县| 临湘市| 平乐县| 巴里|