簡介

PowerJob是基于java開發(fā)的企業(yè)級的分布式任務(wù)調(diào)度平臺，與xxl-job一樣，基于web頁面實現(xiàn)任務(wù)調(diào)度配置與記錄，使用簡單，上手快速，其主要功能特性如下：

• 使用簡單：提供前端Web界面，允許開發(fā)者可視化地完成調(diào)度任務(wù)的管理（增、刪、改、查）、任務(wù)運行狀態(tài)監(jiān)控和運行日志查看等功能。
• 定時策略完善：支持 CRON 表達(dá)式、固定頻率、固定延遲和API四種定時調(diào)度策略。
• 執(zhí)行模式豐富：支持單機、廣播、Map、MapReduce 四種執(zhí)行模式，其中 Map/MapReduce 處理器能使開發(fā)者寥寥數(shù)行代碼便獲得集群分布式計算的能力。
• 工作流支持：支持在線配置任務(wù)依賴關(guān)系（DAG），以可視化的方式對任務(wù)進(jìn)行編排，同時還支持上下游任務(wù)間的數(shù)據(jù)傳遞，以及多種節(jié)點類型（判斷節(jié)點 & 嵌套工作流節(jié)點）。
• 執(zhí)行器支持廣泛：支持 Spring Bean、內(nèi)置/外置 Java 類，另外可以通過引入官方提供的依賴包，一鍵集成 Shell、Python、HTTP、SQL 等處理器，應(yīng)用范圍廣。
• 運維便捷：支持在線日志功能，執(zhí)行器產(chǎn)生的日志可以在前端控制臺頁面實時顯示，降低 debug 成本，極大地提高開發(fā)效率。
• 依賴精簡：最小僅依賴關(guān)系型數(shù)據(jù)庫（MySQL/PostgreSQL/Oracle/MS SQLServer…）
• 高可用 & 高性能：調(diào)度服務(wù)器經(jīng)過精心設(shè)計，一改其他調(diào)度框架基于數(shù)據(jù)庫鎖的策略，實現(xiàn)了無鎖化調(diào)度。部署多個調(diào)度服務(wù)器可以同時實現(xiàn)高可用和性能的提升（支持無限的水平擴展）。
• 故障轉(zhuǎn)移與恢復(fù)：任務(wù)執(zhí)行失敗后，可根據(jù)配置的重試策略完成重試，只要執(zhí)行器集群有足夠的計算節(jié)點，任務(wù)就能順利完成。

定時任務(wù)類型

• 與傳統(tǒng)的定時任務(wù)框架對比，powerJob支持更多的定時任務(wù)類型：
  API: 通過客戶端提供的api接口觸發(fā)，服務(wù)端不會主動調(diào)度，適用于與業(yè)務(wù)服務(wù)上下連接或只調(diào)度一次的業(yè)務(wù)場景
• CRON: 通過cron表達(dá)式調(diào)度，這是多數(shù)定時任務(wù)框架都支持的
• 固定頻率：每隔多少毫秒執(zhí)行一次。
• 固定延遲：延遲多少毫秒執(zhí)行一次
• 工作流：配合工作流進(jìn)行調(diào)度，服務(wù)端不會主動調(diào)度，當(dāng)工作流節(jié)點執(zhí)行到該任務(wù)時運行。

運行

1.然后將powerjob-server/powerjob-server-starter下的application-daily.properties配置文件中的數(shù)據(jù)庫配置改成你服務(wù)器的

其中daily,pre,product 表示日常、預(yù)生產(chǎn)、生產(chǎn)環(huán)境下的配置，與我們常見的dev, test, prod類似，可以根據(jù)需要進(jìn)行調(diào)整

2. 我們先來本地運行啟動類PowerJobServerApplication一下試試，啟動成功后，訪問http://localhost:7700，出現(xiàn)登陸頁則說明運行成功

3、先注冊一個執(zhí)行器，注意這里的應(yīng)用名稱不能順便取，下文在客戶端的配置的app-name要與該名稱保持一致

4、然后用該執(zhí)行器名和密碼登錄

5、如下，我們就登錄成功了

部署 以 jar 包的形式

運行 maven 打jar 包

注意，如果這里報錯

那么可以將maven的健康檢查關(guān)閉，點擊如圖所示按鈕，并且看到test置灰，則表示關(guān)閉

新版idea 可能這樣的

執(zhí)行mvn package打包項目

在powerjob-server-starter的target目錄下即可看到打包出來的jar，將其上傳到指定服務(wù)器，通過java -jar指令即可運行

創(chuàng)建新項目

1、創(chuàng)建一個springboot項目，用于定時任務(wù)客戶端，引入客戶端依賴，如果是spring或其他java項目引入，可參考官網(wǎng)文檔：

<dependency>
    <groupId>tech.powerjob</groupId>
    <artifactId>powerjob-worker-spring-boot-starter</artifactId>
    <version>4.3.2</version>
</dependency>

2、修改配置文件

powerjob:
  worker:
    enabled: true
    enable-test-mode: false
    port: 27777
    app-name: admin # 應(yīng)用名稱，需與PowerJob服務(wù) 注冊的應(yīng)用保持一致
    server-address: 127.0.0.1:7700
    protocol: http
    max-result-length: 4096
    max-lightweight-task-num: 1024
    max-heavy-task-num: 64

3、啟動類上添加注解@EnableScheduling

4、通過申明BasicProcessor接口，實現(xiàn)process方法來書寫一個簡單的定時任務(wù)示例類，注意要聲明為bean

5、啟動客戶端項目，運行成功后，可以在服務(wù)端首頁看到機器實例

6、服務(wù)端任務(wù)管理點擊新建任務(wù)

其中處理器配置是通過書寫處理器的全類路徑名來聲明的，比如我這里是com.example.powerjobdemo.job.SimpleJobServer

7、創(chuàng)建成功后，可以在列表看到新建的任務(wù)

8、打開客戶端控制臺，也能看到輸出的參數(shù)和執(zhí)行打印，說明任務(wù)執(zhí)行成功

9、同時我們可以在運行記錄中看到執(zhí)行日志

至此，針對powerjob的最簡單使用就完成了

定時信息：

主要選擇定時任務(wù)類型，支持API, CRON，固定頻率、固定延遲、工作流、每日固定間隔等幾種定時任務(wù)類型。

生命周期：

這是比其他任務(wù)框架更便捷的功能，指定了任務(wù)的生效周期，如果該任務(wù)是預(yù)定某時間段內(nèi)執(zhí)行的，可以通過該參數(shù)配置

執(zhí)行配置：

執(zhí)行類型支持單機執(zhí)行、廣播執(zhí)行、Map執(zhí)行、MapReduce執(zhí)行

單機執(zhí)行表示只需要有一個節(jié)點執(zhí)行任務(wù)即可的場景

廣播執(zhí)行表示需要全部節(jié)點一同執(zhí)行的場景，比如清除機器日志、各節(jié)點數(shù)據(jù)統(tǒng)計

Map與MapReduce執(zhí)行都是表示分布式、分批執(zhí)行，用來拆分計算量、耗時較大的任務(wù)，區(qū)別在于Map執(zhí)行是一種簡單的數(shù)據(jù)處理邏輯，特點是將輸入數(shù)據(jù)拆分成多個子塊，并交給多個分布式節(jié)點同時執(zhí)行，以提高數(shù)據(jù)處理效率，適用于簡單的數(shù)據(jù)處理場景

MapReduce執(zhí)行是一種大數(shù)據(jù)處理框架，處理邏輯是將復(fù)雜的數(shù)據(jù)處理拆分成Map和Reduce階段進(jìn)行處理，通過數(shù)據(jù)分組計算后合并來提供數(shù)據(jù)處理效率，更適合復(fù)雜的大數(shù)據(jù)場景

運行時配置：

支持HEALTH_FIRST和RANDOM，即第一個健康節(jié)點和隨機，用于選擇執(zhí)行處理器節(jié)點的策略。

最大實例數(shù)用于控制處理器節(jié)點數(shù)量，線程并發(fā)度用于控制并發(fā)，運行時間限制

以上就是SpringBoot整合PowerJob實現(xiàn)定時任務(wù)調(diào)度的詳細(xì)內(nèi)容，更多關(guān)于SpringBoot PowerJob任務(wù)調(diào)度的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論