為您找到相關(guān)結(jié)果23個(gè)
SpringBoot整合PowerJob實(shí)現(xiàn)定時(shí)任務(wù)調(diào)度_java_腳本之家
PowerJob是基于java開(kāi)發(fā)的企業(yè)級(jí)的分布式任務(wù)調(diào)度平臺(tái),與xxl-job一樣,基于web頁(yè)面實(shí)現(xiàn)任務(wù)調(diào)度配置與記錄,使用簡(jiǎn)單,上手快速,其主要功能特性如下: 使用簡(jiǎn)單:提供前端Web界面,允許開(kāi)發(fā)者可視化地完成調(diào)度任務(wù)的管理(增、刪、改、查)、任務(wù)運(yùn)行狀態(tài)監(jiān)控和運(yùn)行日志查看等功能。 定時(shí)策略完善:支持 CRON 表達(dá)式、固定頻率、固定延遲和
www.dbjr.com.cn/program/318176q...htm 2025-6-5
PowerJob的OmsLogHandler工作流程源碼解析_java_腳本之家
PowerJob的OmsLogHandler提供了submitLog方法,它先判斷l(xiāng)ogQueue大小是否超過(guò)REPORT_SIZE(1024),超過(guò)則通過(guò)異步線程執(zhí)行l(wèi)ogSubmitter;接著將內(nèi)容包裝為InstanceLogContent,然后放入到logQueue;logSubmitter主要是執(zhí)行reportLogs,它先通過(guò)easyBuildUrl構(gòu)建URL,再通過(guò)transporter.tell(url, req)發(fā)送請(qǐng)求,rootPath為server,handlerPat...
www.dbjr.com.cn/program/3088878...htm 2025-6-8
PowerJob Alarmable工作流程源碼剖析_java_腳本之家
PowerJob的Alarmable接口定義了onFailed方法,其入?yún)閍larm及targetUserList;它有三個(gè)實(shí)現(xiàn)類,分別是DingTalkAlarmService(用的是DingTalkClient)、MailAlarmService(用的是spring的JavaMailSender)、WebHookAlarmService(用的是okhttp3的OkHttpClient)。 以上就是PowerJob Alarmable工作流程源碼剖析的詳細(xì)內(nèi)容,更多關(guān)于PowerJob...
www.dbjr.com.cn/program/312888e...htm 2025-5-13
PowerJob的CleanService清理服務(wù)流程_java_腳本之家
PowerJob的CleanService提供了timingClean、cleanLocal方法,其中timingClean先執(zhí)行WorkerClusterManagerService.cleanUp()釋放本地緩存,之后通過(guò)cleanLocal釋放本地磁盤空間,最后執(zhí)行cleanByOneServer刪除歷史數(shù)據(jù);cleanLocal會(huì)刪除指定目錄中l(wèi)astModified距離當(dāng)前時(shí)間大于等于1天的文件。 以上就是PowerJob的CleanService清理服務(wù)流程的詳...
www.dbjr.com.cn/program/315656g...htm 2025-5-28
PowerJob的DesignateServer工作流程源碼解讀_java_腳本之家
PowerJob的DesignateServer注解定義了appIdParameterName屬性,默認(rèn)是appId;DesignateServerAspect攔截了@DesignateServer注解,它判斷currentServer就是本機(jī)則執(zhí)行point.proceed(),否則構(gòu)建RemoteProcessReq,通過(guò)transportService.ask轉(zhuǎn)發(fā)請(qǐng)求到指定server執(zhí)行。 以上就是PowerJob的DesignateServer工作流程源碼解讀的詳細(xì)內(nèi)容,更多關(guān)于PowerJ...
www.dbjr.com.cn/program/3133613...htm 2025-6-5
PowerJob的DatabaseMonitorAspect源碼流程_java_腳本之家
tech/powerjob/server/monitor/MonitorService.java 1 2 3 public interface MonitorService { void monitor(Event event); } MonitorService定義了monitor方法 PowerJobMonitorService tech/powerjob/server/monitor/PowerJobMonitorService.java 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 @Slf4j @Compon...
www.dbjr.com.cn/program/3112675...htm 2025-5-29
PowerJob的Evaluator方法工作流程源碼解讀_java_腳本之家
PowerJob的Evaluator接口定義了evaluate方法,它有expression和input兩個(gè)參數(shù),返回計(jì)算結(jié)果;GroovyEvaluator實(shí)現(xiàn)了Evaluator,它內(nèi)置了一個(gè)groovy的ScriptEngine,其evaluate方法先創(chuàng)建bindings,然后傳入?yún)?shù),最后通過(guò)ENGINE.eval(expression, bindings)計(jì)算結(jié)果。 以上就是PowerJob的Evaluator方法工作流程源碼解讀的詳細(xì)內(nèi)容,更多關(guān)于PowerJo...
www.dbjr.com.cn/program/312697m...htm 2025-6-1
PowerJob的WorkerHealthReporter工作流程源碼解讀_java_腳本之家
tech/powerjob/server/remote/worker/WorkerClusterManagerService.java 1 2 3 4 5 6 public static void updateStatus(WorkerHeartbeat heartbeat) { Long appId = heartbeat.getAppId(); String appName = heartbeat.getAppName(); ClusterStatusHolder clusterStatusHolder = APP_ID_2_CLUSTER_STATUS.computeIf...
www.dbjr.com.cn/program/309887d...htm 2025-5-17
PowerJob的HashedWheelTimer工作流程源碼解讀_java_腳本之家
PowerJob定義了Timer接口,并提供了HashedWheelTimer的實(shí)現(xiàn),它定義了waitingTasks、canceledTasks兩個(gè)LinkedBlockingQueue(無(wú)界隊(duì)列),同時(shí)還支持定義任務(wù)處理線程池的core線程數(shù);它通過(guò)Indicator線程來(lái)處理時(shí)間輪的轉(zhuǎn)動(dòng)及任務(wù)處理,Indicator循環(huán)將waitingTasks的任務(wù)放入到對(duì)應(yīng)的bucket,然后模擬時(shí)間輪等待,然后通過(guò)bucket.expireTimerTa...
www.dbjr.com.cn/program/313797b...htm 2025-5-28
PowerJob的AliOssService工作流程源碼解讀_java_腳本之家
* 清理 powerjob 認(rèn)為“過(guò)期”的文件 * 部分存儲(chǔ)系統(tǒng)自帶生命周期管理(如阿里云OSS,則不需要單獨(dú)實(shí)現(xiàn)該方法) * @param bucket bucket * @param days 天數(shù),需要清理超過(guò) X 天的文件 */ default void cleanExpiredFiles(String bucket, int days) { } } DFsService接口定義了store、download、fetchFileMeta、clean...
www.dbjr.com.cn/program/3135985...htm 2025-5-21