[發(fā)明專利]一種基于客戶端、服務(wù)器系統(tǒng)的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201410689980.0
• 申請(qǐng)日: 2014-11-26
• 公開（公告）號(hào): CN104536809B
• 公開（公告）日: 2018-01-19
• 發(fā)明（設(shè)計(jì)）人: 徐東;曹奎
• 申請(qǐng)（專利權(quán)）人: 上海瀚之友信息技術(shù)服務(wù)有限公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46
• 代理公司: 上海正旦專利代理有限公司31200
• 代理人: 陸飛,盛志范

1.一種基于客戶端、服務(wù)器系統(tǒng)的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于包括：應(yīng)用服務(wù)器、核心調(diào)度服務(wù)器、WEB監(jiān)控服務(wù)器、消息服務(wù)器和數(shù)據(jù)庫；其中：

所述應(yīng)用服務(wù)器有若干個(gè)，采用分布式的集群服務(wù)器，所述應(yīng)用服務(wù)器提供的服務(wù)有定時(shí)任務(wù)的功能需求；該應(yīng)用服務(wù)器給出多個(gè)任務(wù)執(zhí)行地址到核心調(diào)度服務(wù)器，每個(gè)地址就是一個(gè)任務(wù)執(zhí)行入口；

所述核心調(diào)度服務(wù)器有若干個(gè)，是一種統(tǒng)籌服務(wù)器，用于控制應(yīng)用服務(wù)器在什么時(shí)間執(zhí)行任務(wù)，并且收集應(yīng)用服務(wù)器執(zhí)行任務(wù)的結(jié)果；由于任務(wù)有很多個(gè)，每個(gè)核心調(diào)度服務(wù)器中都維護(hù)了一個(gè)任務(wù)池，任務(wù)池是一個(gè)存放所有任務(wù)的地方；

所述WEB監(jiān)控服務(wù)器，用于對(duì)任務(wù)的執(zhí)行時(shí)間和執(zhí)行邏輯進(jìn)行配置，并且至少提供任務(wù)的暫停、刪除、新增、修改、查看、手動(dòng)觸發(fā)功能中的任意一種，任務(wù)的查看包括提供對(duì)歷史任務(wù)的執(zhí)行記錄查看；

所述消息服務(wù)器，作為一個(gè)代理，在WEB監(jiān)控服務(wù)器配置完相關(guān)信息后，WEB監(jiān)控服務(wù)器發(fā)送同步信息給消息服務(wù)器，由消息服務(wù)器把同步信息轉(zhuǎn)發(fā)到核心調(diào)度服務(wù)器；同步信息是指服務(wù)器之間通信的內(nèi)容；

所述數(shù)據(jù)庫，用于存儲(chǔ)任務(wù)配置的信息、任務(wù)執(zhí)行結(jié)束后的信息；

所述系統(tǒng)的執(zhí)行流程如下：

（1）WEB監(jiān)控服務(wù)器負(fù)責(zé)進(jìn)行任務(wù)信息的配置，配置完成后把信息數(shù)據(jù)保存進(jìn)數(shù)據(jù)庫中，同時(shí)至少提供任務(wù)信息的查看、新增、修改、暫停、刪除、手動(dòng)觸發(fā)操作中的任意一種，操作后把對(duì)應(yīng)的任務(wù)信息保存入數(shù)據(jù)庫；數(shù)據(jù)庫中保存的任務(wù)信息同時(shí)提供給WEB監(jiān)控服務(wù)器進(jìn)行查看；

（2）當(dāng)WEB監(jiān)控服務(wù)器中的任務(wù)信息至少有新增、修改、暫停、刪除操作中的任意一種的時(shí)候，發(fā)送一個(gè)同步信息給消息服務(wù)器；

（3）消息服務(wù)器找到所有核心調(diào)度服務(wù)器，對(duì)每個(gè)核心調(diào)度服務(wù)器發(fā)送同步信息；由于核心調(diào)度服務(wù)器在啟動(dòng)的時(shí)候會(huì)自動(dòng)的到消息服務(wù)器上面進(jìn)行注冊(cè)，所以消息服務(wù)器能找到在自己這里注冊(cè)的所有核心調(diào)度服務(wù)器；

（4）核心調(diào)度服務(wù)器收到通知后去數(shù)據(jù)庫中取出任務(wù)，放入任務(wù)池中進(jìn)行監(jiān)聽；

（5）當(dāng)任務(wù)時(shí)間到達(dá)的時(shí)候，核心調(diào)度服務(wù)器通知應(yīng)用服務(wù)器進(jìn)行任務(wù)的執(zhí)行，在通知應(yīng)用服務(wù)器的同時(shí)，核心調(diào)度服務(wù)器在數(shù)據(jù)庫中記錄任務(wù)開始執(zhí)行的信息；

（6）當(dāng)應(yīng)用服務(wù)器執(zhí)行結(jié)束后，返回信息給核心調(diào)度服務(wù)器，核心調(diào)度服務(wù)器又把返回信息記錄進(jìn)數(shù)據(jù)庫；此時(shí)WEB監(jiān)控服務(wù)器可以通過數(shù)據(jù)庫查看任務(wù)的執(zhí)行歷史。

2.根據(jù)權(quán)利要求1所述的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于所述應(yīng)用服務(wù)器啟動(dòng)的時(shí)候，首先任務(wù)執(zhí)行主體初始化，生成一個(gè)唯一地址；在WEB監(jiān)控服務(wù)器中配置相對(duì)應(yīng)的任務(wù)信息：包含任務(wù)主體的地址、任務(wù)執(zhí)行的時(shí)間規(guī)則以及其他一些相關(guān)附帶屬性；當(dāng)配置完信息后，通知核心調(diào)度服務(wù)器，核心調(diào)度服務(wù)器根據(jù)通知過來的信息把需要新增或修改的任務(wù)加載進(jìn)來，并加入任務(wù)池中，當(dāng)監(jiān)聽發(fā)現(xiàn)有任務(wù)觸發(fā)的時(shí)候找到對(duì)應(yīng)的任務(wù)主體地址進(jìn)行遠(yuǎn)程通知調(diào)用；當(dāng)應(yīng)用服務(wù)器執(zhí)行結(jié)束后，應(yīng)用服務(wù)器把執(zhí)行結(jié)果發(fā)送回核心調(diào)度服務(wù)器；

應(yīng)用服務(wù)器中包含有一個(gè)集成功能軟件包，該集成功能軟件包提供任務(wù)主體監(jiān)聽功能；在集成功能軟件包中定義了標(biāo)注任務(wù)主體的注解標(biāo)識(shí)，在集成功能軟件包啟動(dòng)的時(shí)候，本集成功能軟件包掃描全部使用該注解標(biāo)識(shí)的任務(wù)主體從而進(jìn)行監(jiān)控；當(dāng)這些任務(wù)主體執(zhí)行結(jié)束，或者執(zhí)行異常后收集成功或者異常信息報(bào)告給核心調(diào)度服務(wù)器；

監(jiān)聽功能采用AOP技術(shù)，在任務(wù)調(diào)度系統(tǒng)中，在應(yīng)用服務(wù)器啟動(dòng)前，開發(fā)人員在任務(wù)執(zhí)行主體上面加上集成功能軟件包定義好的注解，啟動(dòng)的時(shí)候集成功能軟件包掃描所有使用該注解的任務(wù)執(zhí)行主體確認(rèn)監(jiān)聽的范圍，從而進(jìn)行監(jiān)控；當(dāng)這些任務(wù)執(zhí)行主體執(zhí)行結(jié)束后，集成功能軟件包把任務(wù)執(zhí)行的結(jié)果信息收集起來通過dubbo協(xié)議傳送給核心調(diào)度服務(wù)器；核心調(diào)度服務(wù)器收到信息后把執(zhí)行結(jié)果信息、任務(wù)標(biāo)識(shí)數(shù)據(jù)存儲(chǔ)進(jìn)數(shù)據(jù)庫，用來作為web歷史數(shù)據(jù)查看的依據(jù)。