[發(fā)明專利]容器內(nèi)基于內(nèi)存數(shù)據(jù)庫(kù)的定時(shí)任務(wù)調(diào)度的優(yōu)化方法及系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 202010048736.1
• 申請(qǐng)日: 2020-01-16
• 公開（公告）號(hào): CN111274013B
• 公開（公告）日: 2022-05-03
• 發(fā)明（設(shè)計(jì)）人: 田躍東
• 申請(qǐng)（專利權(quán)）人: 北京思特奇信息技術(shù)股份有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48
• 代理公司: 北京輕創(chuàng)知識(shí)產(chǎn)權(quán)代理有限公司 11212
• 代理人: 徐琪琦

1.一種容器內(nèi)基于內(nèi)存數(shù)據(jù)庫(kù)的定時(shí)任務(wù)調(diào)度的優(yōu)化方法，其特征在于，包括如下步驟：

S1、通過調(diào)度決策容器重復(fù)從內(nèi)存數(shù)據(jù)庫(kù)中獲取至少一個(gè)待處理定時(shí)任務(wù)，并將其分發(fā)至定時(shí)任務(wù)處理隊(duì)列；

S2、通過任務(wù)處理容器重復(fù)從所述定時(shí)任務(wù)處理隊(duì)列中獲取并執(zhí)行各所述待處理定時(shí)任務(wù)；

S1中通過所述調(diào)度決策容器具體執(zhí)行如下步驟：

S10、任一時(shí)刻從所述內(nèi)存數(shù)據(jù)庫(kù)內(nèi)獲取至少一個(gè)定時(shí)任務(wù)，并采用哈希鏈表算法對(duì)各所述定時(shí)任務(wù)進(jìn)行處理后存儲(chǔ)至鏈表，所述鏈表以所述時(shí)刻作為關(guān)鍵字、以存放各所述定時(shí)任務(wù)的任務(wù)結(jié)構(gòu)作為相應(yīng)的鏈表節(jié)點(diǎn)；

S11、采用無權(quán)最短路徑算法對(duì)所述鏈表中的各所述定時(shí)任務(wù)的任務(wù)屬性進(jìn)行分析，并結(jié)合當(dāng)前時(shí)間篩選出至少一個(gè)所述待處理定時(shí)任務(wù)；

S12、通過反向服務(wù)代理器Nginx的負(fù)載均衡默認(rèn)算法和加權(quán)輪詢算法將各所述待處理定時(shí)任務(wù)分發(fā)至所述定時(shí)任務(wù)處理隊(duì)列。

2.根據(jù)權(quán)利要求1所述的一種容器內(nèi)基于內(nèi)存數(shù)據(jù)庫(kù)的定時(shí)任務(wù)調(diào)度的優(yōu)化方法，其特征在于，還包括如下步驟：

S100、通過設(shè)置運(yùn)維界面對(duì)所述內(nèi)存數(shù)據(jù)庫(kù)中的定時(shí)任務(wù)進(jìn)行配置。

3.根據(jù)權(quán)利要求1或2所述的一種容器內(nèi)基于內(nèi)存數(shù)據(jù)庫(kù)的定時(shí)任務(wù)調(diào)度的優(yōu)化方法，其特征在于，S12之后還包括如下步驟：

S13、結(jié)合各所述待處理定時(shí)任務(wù)的任務(wù)屬性相應(yīng)生成各所述待處理定時(shí)任務(wù)的任務(wù)執(zhí)行狀態(tài)，并將各所述任務(wù)執(zhí)行狀態(tài)發(fā)送至狀態(tài)數(shù)據(jù)庫(kù)，并對(duì)所述狀態(tài)數(shù)據(jù)庫(kù)進(jìn)行監(jiān)測(cè)。

4.根據(jù)權(quán)利要求3所述的一種容器內(nèi)基于內(nèi)存數(shù)據(jù)庫(kù)的定時(shí)任務(wù)調(diào)度的優(yōu)化方法，其特征在于，S2中通過所述任務(wù)處理容器執(zhí)行各所述待處理定時(shí)任務(wù)具體包括如下步驟：

S20、從所述狀態(tài)數(shù)據(jù)庫(kù)中獲取各所述待處理定時(shí)任務(wù)所相應(yīng)的各任務(wù)執(zhí)行狀態(tài)；

S21、結(jié)合各所述任務(wù)執(zhí)行狀態(tài)對(duì)各相應(yīng)的待處理定時(shí)任務(wù)的任務(wù)屬性進(jìn)行分析，當(dāng)滿足執(zhí)行條件時(shí)，執(zhí)行各所述待處理定時(shí)任務(wù)，并更新所述狀態(tài)數(shù)據(jù)庫(kù)中相應(yīng)的各任務(wù)執(zhí)行狀態(tài)。

5.一種容器內(nèi)基于內(nèi)存數(shù)據(jù)庫(kù)的定時(shí)任務(wù)調(diào)度的優(yōu)化系統(tǒng)，其特征在于，包括調(diào)度決策模塊和任務(wù)處理模塊；

所述調(diào)度決策模塊通過調(diào)度決策容器重復(fù)從內(nèi)存數(shù)據(jù)庫(kù)中獲取至少一個(gè)待處理定時(shí)任務(wù)，并將其分發(fā)至定時(shí)任務(wù)處理隊(duì)列；

所述任務(wù)處理模塊通過任務(wù)處理容器重復(fù)所述定時(shí)任務(wù)處理隊(duì)列中獲取并執(zhí)行各所述待處理定時(shí)任務(wù)；

所述調(diào)度決策模塊包括鏈表模塊、篩選模塊和分發(fā)模塊；

所述鏈表模塊用于在任一時(shí)刻從所述內(nèi)存數(shù)據(jù)庫(kù)內(nèi)獲取至少一個(gè)定時(shí)任務(wù)，并采用哈希鏈表算法對(duì)各所述定時(shí)任務(wù)進(jìn)行處理后存儲(chǔ)至鏈表，所述鏈表以所述時(shí)刻作為關(guān)鍵字、以存放各所述定時(shí)任務(wù)的任務(wù)結(jié)構(gòu)作為相應(yīng)的鏈表節(jié)點(diǎn)；

所述篩選模塊采用無權(quán)最短路徑算法對(duì)所述鏈表中的各所述定時(shí)任務(wù)的任務(wù)屬性進(jìn)行分析，并結(jié)合當(dāng)前時(shí)間篩選出至少一個(gè)所述待處理定時(shí)任務(wù)；

所述分發(fā)模塊通過反向服務(wù)代理器Nginx的負(fù)載均衡默認(rèn)算法和加權(quán)輪詢算法將各所述待處理定時(shí)任務(wù)分發(fā)至所述定時(shí)任務(wù)處理隊(duì)列。

6.根據(jù)權(quán)利要求5所述的一種容器內(nèi)基于內(nèi)存數(shù)據(jù)庫(kù)的定時(shí)任務(wù)調(diào)度的優(yōu)化系統(tǒng)，其特征在于，還包括運(yùn)維模塊，所述運(yùn)維模塊通過設(shè)置運(yùn)維界面對(duì)所述內(nèi)存數(shù)據(jù)庫(kù)中的定時(shí)任務(wù)進(jìn)行配置。

7.根據(jù)權(quán)利要求5或6所述的一種容器內(nèi)基于內(nèi)存數(shù)據(jù)庫(kù)的定時(shí)任務(wù)調(diào)度的優(yōu)化系統(tǒng)，其特征在于，還包括生成模塊和監(jiān)測(cè)模塊，所述生成模塊結(jié)合各所述待處理定時(shí)任務(wù)的任務(wù)屬性相應(yīng)生成各所述待處理定時(shí)任務(wù)的任務(wù)執(zhí)行狀態(tài)，所述分發(fā)模塊將各所述任務(wù)執(zhí)行狀態(tài)發(fā)送至狀態(tài)數(shù)據(jù)庫(kù)，并通過所述監(jiān)測(cè)模塊對(duì)所述狀態(tài)數(shù)據(jù)庫(kù)進(jìn)行監(jiān)測(cè)。

8.根據(jù)權(quán)利要求7所述的一種容器內(nèi)基于內(nèi)存數(shù)據(jù)庫(kù)的定時(shí)任務(wù)調(diào)度的優(yōu)化系統(tǒng)，其特征在于，所述任務(wù)處理模塊包括獲取模塊、分析模塊和執(zhí)行模塊，所述獲取模塊從所述狀態(tài)數(shù)據(jù)庫(kù)中獲取各所述待處理定時(shí)任務(wù)所相應(yīng)的各任務(wù)執(zhí)行狀態(tài)，所述分析模塊結(jié)合各所述任務(wù)執(zhí)行狀態(tài)對(duì)各相應(yīng)的待處理定時(shí)任務(wù)的任務(wù)屬性進(jìn)行分析，當(dāng)滿足執(zhí)行條件時(shí)，所述執(zhí)行模塊執(zhí)行各所述待處理定時(shí)任務(wù)，并更新所述狀態(tài)數(shù)據(jù)庫(kù)中相應(yīng)的各任務(wù)執(zhí)行狀態(tài)。