網站排名易下拉排名,做外貿重新設計網站,柜子定制,鎮(zhèn)江網站建站快速開始#xff08;本地IDE版#xff09; 官方教程:https://www.yuque.com/powerjob/guidence/quick_start PowerJob 的設計目標為企業(yè)級的分布式任務調度平臺#xff0c;即成為公司內部的調度中間件。整個公司統(tǒng)一部署調度中心 powerjob-server#xff0c;旗下所有業(yè)務…快速開始本地IDE版官方教程:https://www.yuque.com/powerjob/guidence/quick_startPowerJob 的設計目標為企業(yè)級的分布式任務調度平臺即成為公司內部的調度中間件。整個公司統(tǒng)一部署調度中心 powerjob-server旗下所有業(yè)務線應用只需要依賴 powerjob-worker 即可接入獲取任務調度與分布式計算能力通過不同的 appName 相互隔離。因此PowerJob 由調度服務器powerjob-server,Power Job服務系統(tǒng)和執(zhí)行器(powerjob-worker,你的業(yè)務系統(tǒng)上的定時任務)兩部分組成powerjob-server 負責提供 Web 服務和完成任務的調度powerjob-worker 則負責執(zhí)行用戶所編寫的任務代碼同時提供分布式計算能力。以下為在本地開發(fā)環(huán)境快速搭建并試用 PowerJob 的教程。下載power job代碼——運行調度服務——開發(fā)配置業(yè)務系統(tǒng)處理器及配置項——配置定時任務。STEP1: 初始化項目下載Power Job 程序代碼,git clone https://github.com/PowerJob/PowerJob.gitgit clone https://gitcode.com/PowerStack/PowerJob.git導入 IDE源碼結構如下我們需要啟動調度服務器powerjob-server同時在 samples 工程中編寫自己的處理器代碼STEP2: 啟動調度服務器創(chuàng)建數據庫僅需要創(chuàng)建數據庫找到你的 DB運行 SQL CREATE DATABASE IF NOT EXISTSpowerjob-dailyDEFAULT CHARSET utf8mb4搞定修改配置文件配置文件的說明官方文檔寫的非常詳細此處不再贅述。需要修改的地方(路徑: PowerJob/powerjob-server/powerjob-server-starter/src/main/resources/application-daily.properties)為數據庫配置spring.datasource.core.jdbc-url、spring.datasource.core.username和spring.datasource.core.password當然有 mongoDB 的同學也可以修改spring.data.mongodb.uri以獲取完全版體驗。#參考配置文件代碼 oms.envDAILY logging.configclasspath:logback-dev.xml #修改數據庫相關配置 spring.datasource.core.driver-class-namecom.mysql.cj.jdbc.Driverspring.datasource.core.jdbc-urljdbc:mysql://127.0.0.1:3306/powerjob-daily?useUnicodetruecharacterEncodingUTF-8serverTimezoneAsia/Shanghaispring.datasource.core.usernameroot spring.datasource.core.passwordroot spring.datasource.core.maximum-pool-size20spring.datasource.core.minimum-idle5#修改數據庫相關配置 oms.storage.dfs.mysql_series.drivercom.mysql.cj.jdbc.Driveroms.storage.dfs.mysql_series.urljdbc:mysql://127.0.0.1:3306/powerjob-daily?useUnicodetruecharacterEncodingUTF-8serverTimezoneAsia/Shanghaioms.storage.dfs.mysql_series.usernameroot oms.storage.dfs.mysql_series.passwordroot oms.storage.dfs.mysql_series.auto_create_tabletrue####### 郵件配置不需要郵件報警可以刪除以下配置來避免報錯 ####### #spring.mail.hostsmtp.163.com #spring.mail.usernamezqq163.com#spring.mail.passwordGOFZPNARMVKCGONV #spring.mail.properties.mail.smtp.authtrue#spring.mail.properties.mail.smtp.starttls.enabletrue#spring.mail.properties.mail.smtp.starttls.requiredtrue####### 釘釘配置(不需要的話刪除以下配置來避免報錯 ####### #oms.alarm.ding.app-keydingauqwkvxxnqskknfv #oms.alarm.ding.app-secretXWrEPdAZMPgJeFtHuL0LH73LRj-74umF2_0BFcoXMfvnX0pCQvt0rpb1JOJU_HLl #oms.alarm.ding.agent-id847044348#######Resourcecleaning properties ####### oms.instanceinfo.retention1oms.container.retention.local1oms.container.retention.remote-1#######Cacheproperties ####### oms.instance.metadata.cache.size1024#######Thresholdin precise fetchingserver(0~100).100means full detection of server,in which ####### ####### split-brain could be avoidedwhileperformance overhead would increase.####### oms.accurate.select.server.percentage50完成配置文件的修改后可以直接通過啟動類 tech.powerjob.server.PowerJobServerApplication 啟動調度服務器注意需要使用 daily 配置文件啟動可自行百度搜索“SpringBoot 指定配置文件啟動”觀察啟動日志查看是否啟動成功啟動成功后訪問 http://127.0.0.1:7700/ 如果能順利出現 Web 界面則說明調度服務器啟動成功注冊應用○ v4.x及前序版本點擊主頁應用注冊按鈕填入 powerjob-worker-samples 和控制臺密碼用于進入控制臺注冊示例應用當然你也可以注冊其他的 appName只是別忘記在示例程序中同步修改○ v5.x 版本■ 選擇 PowerJob Account進行登錄簡單起見可直接使用超級管理員登錄賬號 ADMIN密碼 powerjob_admin登錄后進入應用管理TAB點擊右上角新增進行應用注冊即可。STEP3: 編寫示例代碼進入示例工程powerjob-worker-samples修改配置文件連接powerjob-server并編寫自己的處理器代碼。1.修改 powerjob-worker-samples 的 application.properties將 powerjob.worker.app-name 改為剛剛在控制臺注冊的名稱。server.port8081spring.jpa.open-in-viewfalse########### powerjob-worker 配置 ########### # akka 工作端口可選默認27777powerjob.worker.akka-port27777# 接入應用名稱用于分組隔離推薦填寫 本 Java 項目名稱 powerjob.worker.app-namepowerjob-worker-samples # 調度服務器地址IP:Port 或 域名多值逗號分隔 powerjob.worker.server-address127.0.0.1:7700,127.0.0.1:7701# 持久化方式可選默認 disk powerjob.worker.store-strategydisk # 任務返回結果信息的最大長度超過這個長度的信息會被截斷默認8192powerjob.worker.max-result-length4096# 單個任務追加的工作流上下文最大長度超過這個長度的會被直接丟棄默認8192powerjob.worker.max-appended-wf-context-length40962.編寫自己的處理器隨便找個地方新建類繼承你想要使用的處理器各個處理器的介紹可見官方文檔文檔非常詳細這里為了簡單演示選擇使用單機處理器 BasicProcessor以下是代碼示例。Slf4jComponent//單擊執(zhí)行示例publicclassStandaloneProcessorDemoimplementsBasicProcessor{OverridepublicProcessResultprocess(TaskContextcontext)throwsException{// PowerJob 在線日志功能使用該 Logger 打印的日志可以直接在 PowerJob 控制臺查看OmsLoggeromsLoggercontext.getOmsLogger();omsLogger.info(StandaloneProcessorDemo start process,context is {}.,context);returnnewProcessResult(true,process successfully~);}}啟動示例程序即直接運行主類 tech.powerjob.samples.SampleApplication觀察控制臺輸出信息判斷是否啟動成功。STEP4: 任務的配置與運行調度服務器與示例工程都啟動完畢后再次前往Web頁面 http://127.0.0.1:7700/ 進行任務的配置與運行。進入執(zhí)行器應用的主界面v4.x 及前序版本在首頁輸入框輸入配置的應用名稱成功操作后會正式進入前端管理界面v5.x在應用管理頁面選擇對應的應用點擊右側“進入”按鈕即可。進入注冊應用首頁后出現如下圖頁面新建任務點擊“任務管理” - “新建任務”右上角開始創(chuàng)建任務?？砂聪聢D說明填寫參數任務運行運維完成任務創(chuàng)建后即可在控制臺看到剛才創(chuàng)建的任務如果覺得等待調度太過于漫長可以直接點擊運行按鈕立即運行本任務。前往任務實例邊欄查看任務的運行狀態(tài)和在線日志基礎的教程到這里也就結束了PowerJob Worker 與 Server 的通信機制通信模式說明1.雙向通信架構Worker 主動連接 ServerWorker 啟動時主動連接 ServerServer 控制 Worker通過心跳機制實現任務調度和管理長連接維持建立持久的通信通道2.配置驗證根據 [application.properties](file:///E:/java/PowerJob/powerjob-worker-samples/src/main/resources/application.properties) 中的配置powerjob.worker.server-addressWorker 需要知道 Server 地址powerjob.worker.protocol使用 HTTP 協(xié)議通信powerjob.worker.allow-lazy-connect-server當前設置為false強制驗證連接3.通信流程初始化連接Worker 啟動時連接到 Server心跳機制維持連接狀態(tài)和任務狀態(tài)同步任務執(zhí)行Server 通過連接下發(fā)任務指令結果回傳Worker 執(zhí)行完成后將結果發(fā)送回 Server4.工作模式Server 作為控制中心負責任務分發(fā)和調度Worker 作為執(zhí)行節(jié)點負責實際任務執(zhí)行雙向數據流任務下發(fā)和結果回傳同時存在所以是Worker 既接受 Server 調度也主動與 Server 通信形成完整的分布式任務調度體系。PowerJob 執(zhí)行方式區(qū)別執(zhí)行類型分類1.單機執(zhí)行Standalone特點任務在一個 Worker 節(jié)點上執(zhí)行適用場景簡單任務、不需要分布式處理的任務優(yōu)勢執(zhí)行簡單資源消耗少2.廣播執(zhí)行Broadcast特點任務被發(fā)送到所有可用的 Worker 節(jié)點同時執(zhí)行適用場景需要在所有節(jié)點執(zhí)行相同操作的場景應用場景系統(tǒng)通知、配置更新、緩存清理等3.MapReduce 執(zhí)行特點Map 階段將任務分解到多個 Worker 并行處理Reduce 階段匯總各節(jié)點處理結果適用場景大數據處理、復雜計算任務優(yōu)勢充分利用分布式計算能力提高處理效率通信機制所有執(zhí)行類型都通過powerjob.worker.server-address配置的 Server 地址進行任務調度Worker 通過powerjob.worker.protocol指定的協(xié)議與 Server 通信任務執(zhí)行狀態(tài)和結果通過心跳機制反饋給 Server