欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

springboot整合 xxl-job的項(xiàng)目實(shí)踐

 更新時(shí)間:2024年09月14日 10:28:50   作者:世界需要行動(dòng)派  
XL-JOB是一個(gè)分布式任務(wù)調(diào)度平臺(tái),用于解決分布式系統(tǒng)中的任務(wù)調(diào)度和管理問(wèn)題,它包括調(diào)度中心、執(zhí)行器和Web管理控制臺(tái),本文就來(lái)介紹一下springboot整合 xxl-job的項(xiàng)目實(shí)踐,感興趣的可以了解一下

一、xxl-job是什么

XXL-JOB 是一個(gè)分布式任務(wù)調(diào)度平臺(tái),主要用于解決在分布式系統(tǒng)中任務(wù)調(diào)度和任務(wù)管理的問(wèn)題。

  • XXL-JOB 的架構(gòu)通常包括以下幾個(gè)組件:
    調(diào)度中心(Scheduler):負(fù)責(zé)任務(wù)的調(diào)度、管理和監(jiān)控,是整個(gè)調(diào)度系統(tǒng)的核心。
  • 執(zhí)行器(Executor):負(fù)責(zé)具體任務(wù)的執(zhí)行,可以部署在不同的節(jié)點(diǎn)上。
  • Web 管理控制臺(tái):提供友好的 Web 界面,方便用戶進(jìn)行任務(wù)的管理和監(jiān)控。

二、使用步驟

1. 下載并運(yùn)行管理端代碼

項(xiàng)目地址:
1??:【gitee】https://gitee.com/xuxueli0323/xxl-job
2??:【github】https://github.com/xuxueli/xxl-job

項(xiàng)目整體結(jié)構(gòu)

管理端需要注意的地方

在這里插入圖片描述

執(zhí)行sql腳本,tables_xxl_job.sql

修改application.properties配置文件,主要修改兩處

### xxl-job, datasource
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=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
### xxl-job, access token
xxl.job.accessToken=default_token

數(shù)據(jù)庫(kù)地址對(duì)應(yīng)的是第一步執(zhí)行腳本創(chuàng)建的庫(kù)的位置

  • accessToken的值需要和執(zhí)行器中配置的值(后面會(huì)寫)一致
  • 通過(guò)Application運(yùn)行程序,也可以打包后通過(guò)jar命令啟動(dòng)

2. 訪問(wèn)管理頁(yè)面,確認(rèn)是否啟動(dòng)成功

地址:http://127.0.0.1:8080/xxl-job-admin 【和配置文件一致】
默認(rèn)賬密:admin/123456【忘記密碼可以去數(shù)據(jù)庫(kù)修改,使用md5加密后填充】

3. 配置執(zhí)行器【在自己的springboot項(xiàng)目中配置】

引入依賴

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

添加配置文件

  • accessToken與前面配置一致,address對(duì)應(yīng)管理端訪問(wèn)地址
  • executor(執(zhí)行器)的配置與后面在頁(yè)面上創(chuàng)建執(zhí)行器時(shí)保持一致
### xxl-job admin address list, such as "http://address" or "http://address01,http://address02"
xxl:
  job:
    accessToken: default_token
    admin:
      addresses: http://127.0.0.1:8080/xxl-job-admin
    executor:
      appname: xxl-job-executor-test-zhu
      address: http://localhost:9999  # 填充地址,假設(shè)執(zhí)行器運(yùn)行在本地
      ip: 127.0.0.1  # 填充本地IP,確保它與address配置一致
      port: 9999
      logpath: /data/applogs/xxl-job/jobhandler
      logretentiondays: -1

執(zhí)行器組件配置

package com.zhui.yudada.config;

import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Slf4j
@Configuration
public class XxlJobConfig {
    @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() {
        log.info(">>>>>>>>>>> start 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;
    }
}

jobhander配置

package com.zhui.yudada.job;
 
 
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

 
 
@Component
public class HelloJob {
 
    @Value("${server.port}")
    private String port;
 
    @XxlJob("demoJobHandler")
    public ReturnT helloJob() {
        System.out.println("簡(jiǎn)單任務(wù)執(zhí)行了。。。" + port);
        return  ReturnT.SUCCESS;
    }
}
 

啟動(dòng)項(xiàng)目,出現(xiàn)下面的提示說(shuō)明啟動(dòng)成功

在這里插入圖片描述

4. 在頁(yè)面上創(chuàng)建執(zhí)行器和任務(wù),與項(xiàng)目中綁定

創(chuàng)建執(zhí)行器【取值與springboot項(xiàng)目中配置文件一一對(duì)應(yīng)】

在這里插入圖片描述

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

在這里插入圖片描述

在這里插入圖片描述

啟動(dòng),驗(yàn)證是否執(zhí)行成功

在這里插入圖片描述

啟動(dòng)后查看調(diào)度日志,或者觀察程序控制臺(tái)數(shù)據(jù)

在這里插入圖片描述

在這里插入圖片描述

總結(jié)

如果啟動(dòng)失敗,檢查配置文件的值是否一致,如accessToken的值

參考

到此這篇關(guān)于springboot整合 xxl-job的項(xiàng)目實(shí)踐的文章就介紹到這了,更多相關(guān)springboot整合 xxl-job內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家! 

相關(guān)文章

  • Java中的BlockingQueue接口源碼解析

    Java中的BlockingQueue接口源碼解析

    這篇文章主要介紹了Java中的BlockingQueue接口源碼解析,BlockingQueue接口表示阻塞隊(duì)列,是Java并發(fā)包中阻塞隊(duì)列的接口定義規(guī)范,阻塞隊(duì)列意味著對(duì)于該隊(duì)列的操作是線程安全的,當(dāng)多個(gè)線程存放元素進(jìn)入隊(duì)列或者從隊(duì)列中取出元素都是線程安全的,需要的朋友可以參考下
    2023-11-11
  • spring mvc利用ajax向controller傳遞對(duì)象的方法示例

    spring mvc利用ajax向controller傳遞對(duì)象的方法示例

    這篇文章主要給大家介紹了關(guān)于spring mvc利用ajax向controller傳遞對(duì)象的相關(guān)資料,文中通過(guò)示例代碼將步驟介紹的非常詳細(xì),對(duì)大家具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來(lái)跟著小編一起學(xué)習(xí)學(xué)習(xí)吧。
    2017-07-07
  • JAVA通過(guò)Filter實(shí)現(xiàn)允許服務(wù)跨域請(qǐng)求的方法

    JAVA通過(guò)Filter實(shí)現(xiàn)允許服務(wù)跨域請(qǐng)求的方法

    這里的域指的是這樣的一個(gè)概念:我們認(rèn)為若協(xié)議 + 域名 + 端口號(hào)均相同,那么就是同域即我們常說(shuō)的瀏覽器請(qǐng)求的同源策略。這篇文章主要介紹了JAVA通過(guò)Filter實(shí)現(xiàn)允許服務(wù)跨域請(qǐng)求,需要的朋友可以參考下
    2018-11-11
  • 程序員最喜歡的ThreadLocal使用姿勢(shì)

    程序員最喜歡的ThreadLocal使用姿勢(shì)

    ThreadLocal并不是一個(gè)Thread,而是Thread的局部變量,也許把它命名為ThreadLocalVariable更容易讓人理解一些,下面這篇文章主要給大家介紹了程序員最喜歡的ThreadLocal使用姿勢(shì),需要的朋友可以參考下
    2022-02-02
  • 詳解IntelliJ IDEA 自帶的 HTTP Client 接口調(diào)用插件吊打 Postman

    詳解IntelliJ IDEA 自帶的 HTTP Client 接口調(diào)用插件吊打 Postman

    HTTP Client 是 IDEA 自帶的一款簡(jiǎn)潔輕量級(jí)的接口調(diào)用插件,通過(guò)它,我們能在 IDEA 上開發(fā),調(diào)試,測(cè)試 RESTful Web 服務(wù),接下來(lái)通過(guò)本文給大家分享IntelliJ IDEA 自帶的 HTTP Client 接口調(diào)用插件吊打 Postman的知識(shí),感興趣的朋友一起看看吧
    2021-05-05
  • 在SpringBoot中如何利用Redis實(shí)現(xiàn)互斥鎖

    在SpringBoot中如何利用Redis實(shí)現(xiàn)互斥鎖

    當(dāng)我們利用Redis存儲(chǔ)熱點(diǎn)數(shù)據(jù)時(shí),突然就過(guò)期失效或者被刪除了,導(dǎo)致大量請(qǐng)求同時(shí)訪問(wèn)數(shù)據(jù)庫(kù),增加了數(shù)據(jù)庫(kù)的負(fù)載,為減輕數(shù)據(jù)庫(kù)的負(fù)載我們利用互斥鎖,本文重點(diǎn)介紹在SpringBoot中如何利用Redis實(shí)現(xiàn)互斥鎖,感興趣的朋友一起看看吧
    2023-09-09
  • Java實(shí)現(xiàn)分布式系統(tǒng)限流

    Java實(shí)現(xiàn)分布式系統(tǒng)限流

    這篇文章主要為大家詳細(xì)介紹了Java實(shí)現(xiàn)分布式系統(tǒng)限流,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2022-08-08
  • 調(diào)用java.lang.Runtime.exec的正確姿勢(shì)分享

    調(diào)用java.lang.Runtime.exec的正確姿勢(shì)分享

    這篇文章主要介紹了調(diào)用java.lang.Runtime.exec的正確姿勢(shì),具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-11-11
  • JAVA讀取文本文件內(nèi)容實(shí)例代碼

    JAVA讀取文本文件內(nèi)容實(shí)例代碼

    這篇文章主要給大家介紹了關(guān)于JAVA讀取文本文件內(nèi)容的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用Java具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2019-09-09
  • 一文讀懂a(chǎn)va中的Volatile關(guān)鍵字使用

    一文讀懂a(chǎn)va中的Volatile關(guān)鍵字使用

    volatile關(guān)鍵字的作用保證了變量的可見(jiàn)性(visibility)。被volatile關(guān)鍵字修飾的變量,如果值發(fā)生了變更,其他線程立馬可見(jiàn),避免出現(xiàn)臟讀的現(xiàn)象。這篇文章主要介紹了ava中的Volatile關(guān)鍵字使用,需要的朋友可以參考下
    2020-03-03

最新評(píng)論