[發(fā)明專利]分布式定時(shí)任務(wù)調(diào)度系統(tǒng)及計(jì)算裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 202010107648.4
• 申請(qǐng)日: 2020-02-21
• 公開（公告）號(hào): CN111338774B
• 公開（公告）日: 2023-09-19
• 發(fā)明（設(shè)計(jì)）人: 李紅
• 申請(qǐng)（專利權(quán)）人: 華云數(shù)據(jù)有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48;G06F9/451;G06F9/455;G06F9/50
• 代理公司: 蘇州友佳知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 32351
• 代理人: 儲(chǔ)振

1.一種分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于，包括：

至少在兩個(gè)節(jié)點(diǎn)中以聲明方式配置出的包含流程調(diào)度進(jìn)程的任務(wù)調(diào)度器、包含服務(wù)調(diào)度進(jìn)程的服務(wù)調(diào)度器及確定定時(shí)任務(wù)執(zhí)行周期的任務(wù)定時(shí)器，

消息隊(duì)列，

部署于消息隊(duì)列與服務(wù)調(diào)度器之間的至少兩個(gè)用于檢測(cè)節(jié)點(diǎn)響應(yīng)能力的調(diào)度中心，

定時(shí)任務(wù)下發(fā)組件，選定至少一個(gè)節(jié)點(diǎn)作為響應(yīng)定時(shí)任務(wù)的指定節(jié)點(diǎn)，以及，保存定時(shí)任務(wù)所對(duì)應(yīng)的執(zhí)行結(jié)果的第一存儲(chǔ)裝置；

所述任務(wù)調(diào)度器將定時(shí)任務(wù)下發(fā)至消息隊(duì)列中，剩余節(jié)點(diǎn)監(jiān)聽消息隊(duì)列并創(chuàng)建與下發(fā)至消息隊(duì)列中的定時(shí)任務(wù)相同的定時(shí)任務(wù)；所述消息隊(duì)列將定時(shí)任務(wù)中所包含的至少一個(gè)定時(shí)作業(yè)下發(fā)至調(diào)度中心，所述調(diào)度中心檢測(cè)節(jié)點(diǎn)的響應(yīng)能力，以根據(jù)各個(gè)節(jié)點(diǎn)的響應(yīng)能力確定執(zhí)行定時(shí)作業(yè)所對(duì)應(yīng)的服務(wù)調(diào)度器。

2.根據(jù)權(quán)利要求1所述的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于，各節(jié)點(diǎn)之間基于與所述定時(shí)任務(wù)所對(duì)應(yīng)的分布式鎖，使用任務(wù)調(diào)度器中包含的流程調(diào)度進(jìn)程根據(jù)任務(wù)定時(shí)器所設(shè)定的時(shí)限確定是否由消息隊(duì)列中的輪詢機(jī)制通知調(diào)度中心，并通過所述調(diào)度中心根據(jù)各個(gè)節(jié)點(diǎn)的響應(yīng)能力確定執(zhí)行定時(shí)作業(yè)所對(duì)應(yīng)的至少一個(gè)服務(wù)調(diào)度器。

3.根據(jù)權(quán)利要求2所述的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于，至少兩個(gè)調(diào)度中心以定時(shí)任務(wù)下發(fā)組件所選定至少一個(gè)節(jié)點(diǎn)中所部署的任務(wù)定時(shí)器所設(shè)定的時(shí)限為周期對(duì)節(jié)點(diǎn)的響應(yīng)能力進(jìn)行檢測(cè)。

4.根據(jù)權(quán)利要求2所述的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于，至少在兩個(gè)節(jié)點(diǎn)中以聲明方式配置出至少一對(duì)流程調(diào)度進(jìn)程與服務(wù)調(diào)度進(jìn)程，所述流程調(diào)度進(jìn)程與服務(wù)調(diào)度進(jìn)程使用消息隊(duì)列進(jìn)行解耦。

5.根據(jù)權(quán)利要求1所述的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于，所述第一存儲(chǔ)裝置保存響應(yīng)定時(shí)任務(wù)所對(duì)應(yīng)的執(zhí)行結(jié)果后，由消息隊(duì)列通知執(zhí)行定時(shí)任務(wù)的節(jié)點(diǎn)及所述節(jié)點(diǎn)中部署的服務(wù)調(diào)度器；

所述第一存儲(chǔ)裝置選自JVM內(nèi)存、分布式存儲(chǔ)組件或者數(shù)據(jù)庫。

6.根據(jù)權(quán)利要求1所述的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于，定時(shí)任務(wù)下發(fā)組件包括：用戶界面及負(fù)載均衡器；

所述用戶界面接收定時(shí)任務(wù)并下發(fā)至負(fù)載均衡器，各節(jié)點(diǎn)之間基于與所述定時(shí)任務(wù)所對(duì)應(yīng)的分布式鎖通過所述負(fù)載均衡器所內(nèi)置的負(fù)載均衡策略選定至少一個(gè)節(jié)點(diǎn)作為指定節(jié)點(diǎn)以響應(yīng)定時(shí)任務(wù)。

7.根據(jù)權(quán)利要求2至6中任一項(xiàng)所述的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于，所述調(diào)度中心響應(yīng)自所述消息隊(duì)列下發(fā)的定時(shí)任務(wù)，按照定時(shí)任務(wù)所包含的至少一個(gè)定時(shí)作業(yè)所依賴的配置對(duì)所述定時(shí)任務(wù)執(zhí)行拆分，并為拆分定時(shí)任務(wù)后所形成的多個(gè)子定時(shí)任務(wù)確定執(zhí)行子定時(shí)任務(wù)所對(duì)應(yīng)的至少一個(gè)服務(wù)調(diào)度器；

所述節(jié)點(diǎn)為計(jì)算節(jié)點(diǎn)、存儲(chǔ)節(jié)點(diǎn)或者網(wǎng)絡(luò)節(jié)點(diǎn)。

8.根據(jù)權(quán)利要求7所述的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于，所述分布式定時(shí)任務(wù)調(diào)度系統(tǒng)用于響應(yīng)多定時(shí)任務(wù)場(chǎng)景；

所述節(jié)點(diǎn)配置的任務(wù)調(diào)度器與服務(wù)調(diào)度器包含一對(duì)或者多對(duì)流程調(diào)度進(jìn)程與服務(wù)調(diào)度進(jìn)程，并將流程調(diào)度進(jìn)程與服務(wù)調(diào)度進(jìn)程使用消息隊(duì)列進(jìn)行解耦。

9.根據(jù)權(quán)利要求8所述的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于，所述消息隊(duì)列保存于邏輯上獨(dú)立于第一存儲(chǔ)裝置的第二存儲(chǔ)裝置，所述第二存儲(chǔ)裝置選自物理服務(wù)器或者虛擬服務(wù)器或者非易失性存儲(chǔ)裝置，所述消息隊(duì)列為RabbitMQ。

10.根據(jù)權(quán)利要求7所述的分布式定時(shí)任務(wù)調(diào)度系統(tǒng)，其特征在于，所述服務(wù)調(diào)度進(jìn)程被配置為一個(gè)或者多個(gè)用于響應(yīng)定時(shí)任務(wù)的服務(wù)單元，所述服務(wù)調(diào)度進(jìn)程與服務(wù)單元之間具映射關(guān)系，所述服務(wù)單元部署于任意一個(gè)節(jié)點(diǎn)。