[發(fā)明專利]分布式任務(wù)處理系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 202010322658.X
• 申請(qǐng)日: 2020-04-22
• 公開(kāi)（公告）號(hào): CN111538604B
• 公開(kāi)（公告）日: 2023-03-28
• 發(fā)明（設(shè)計(jì)）人: 黃威
• 申請(qǐng)（專利權(quán)）人: 北京字節(jié)跳動(dòng)網(wǎng)絡(luò)技術(shù)有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54
• 代理公司: 北京遠(yuǎn)智匯知識(shí)產(chǎn)權(quán)代理有限公司 11659
• 代理人: 范坤坤

1.一種分布式任務(wù)處理系統(tǒng)，其特征在于，包括：任務(wù)配置子系統(tǒng)、任務(wù)解析子系統(tǒng)和下游服務(wù)子系統(tǒng)，其中，

所述任務(wù)配置子系統(tǒng)包含至少兩個(gè)任務(wù)配置設(shè)備，每個(gè)所述任務(wù)配置設(shè)備用于接收任務(wù)配置信息，并將所述任務(wù)配置信息發(fā)送至任務(wù)解析子系統(tǒng)；

所述任務(wù)解析子系統(tǒng)用于解析各相同任務(wù)配置信息中的其中一個(gè)任務(wù)配置信息，確定任務(wù)周期和任務(wù)執(zhí)行指令，并依據(jù)所述任務(wù)周期設(shè)置定時(shí)器，以及在所述定時(shí)器被觸發(fā)時(shí)，將所述任務(wù)執(zhí)行指令寫(xiě)入所述任務(wù)配置信息對(duì)應(yīng)的消息隊(duì)列；

所述下游服務(wù)子系統(tǒng)包含至少兩個(gè)下游服務(wù)處理設(shè)備，所述下游服務(wù)處理設(shè)備用于依據(jù)所述消息隊(duì)列中的所述任務(wù)執(zhí)行指令處理所述任務(wù)配置信息對(duì)應(yīng)的定時(shí)任務(wù)。

2.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述系統(tǒng)還包括：

任務(wù)配置信息輸入設(shè)備，用于接收用戶輸入的所述任務(wù)配置信息，并基于分布式系統(tǒng)的推送機(jī)制和探活機(jī)制，將所述任務(wù)配置信息發(fā)送至所述任務(wù)配置子系統(tǒng)。

3.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述任務(wù)配置子系統(tǒng)還包含至少兩個(gè)配置備用設(shè)備，所述配置備用設(shè)備用于在所述任務(wù)配置設(shè)備故障時(shí)，接收任務(wù)配置信息，并將所述任務(wù)配置信息發(fā)送至所述任務(wù)解析子系統(tǒng)。

4.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述任務(wù)解析子系統(tǒng)包含至少兩個(gè)任務(wù)解析設(shè)備，每個(gè)所述任務(wù)解析設(shè)備用于解析各所述任務(wù)配置信息中的同一個(gè)任務(wù)配置信息，確定任務(wù)周期和任務(wù)執(zhí)行指令，并依據(jù)所述任務(wù)周期設(shè)置定時(shí)器，以及在所述定時(shí)器被觸發(fā)時(shí)，將所述任務(wù)執(zhí)行指令寫(xiě)入所述任務(wù)配置信息對(duì)應(yīng)的消息隊(duì)列。

5.根據(jù)權(quán)利要求1或4所述的系統(tǒng)，其特征在于，所述任務(wù)解析子系統(tǒng)還用于：

當(dāng)所述任務(wù)執(zhí)行指令寫(xiě)入所述消息隊(duì)列失敗時(shí)，將所述任務(wù)執(zhí)行指令存入內(nèi)存，并在滿足預(yù)設(shè)內(nèi)存讀取條件時(shí)，讀取所述內(nèi)存中的所述任務(wù)執(zhí)行指令，以將所述任務(wù)執(zhí)行指令重試寫(xiě)入所述消息隊(duì)列。

6.根據(jù)權(quán)利要求4所述的系統(tǒng)，其特征在于，所述任務(wù)解析子系統(tǒng)還用于：

記錄各所述任務(wù)配置信息中被解析的任務(wù)配置信息，作為所述同一個(gè)任務(wù)配置信息，并記錄所述同一個(gè)任務(wù)配置信息中每個(gè)任務(wù)信息的解析狀態(tài)及相應(yīng)的任務(wù)解析設(shè)備，以使一個(gè)所述任務(wù)信息被一個(gè)所述任務(wù)解析設(shè)備解析。

7.根據(jù)權(quán)利要求1所述的系統(tǒng)，其特征在于，所述系統(tǒng)還包括：

消息分發(fā)子系統(tǒng)，用于在監(jiān)測(cè)到所述消息隊(duì)列中有消息時(shí)，將所述消息隊(duì)列中的所述任務(wù)執(zhí)行指令分發(fā)至所述下游服務(wù)子系統(tǒng)。

8.根據(jù)權(quán)利要求7所述的系統(tǒng)，其特征在于，所述消息分發(fā)子系統(tǒng)包含至少兩個(gè)消息分發(fā)設(shè)備，每個(gè)所述消息分發(fā)設(shè)備用于監(jiān)測(cè)所述消息隊(duì)列中是否有消息，且最早監(jiān)測(cè)到所述消息隊(duì)列中有消息的所述消息分發(fā)設(shè)備將所述消息隊(duì)列中的所述任務(wù)執(zhí)行指令分發(fā)至所述下游服務(wù)子系統(tǒng)。

9.根據(jù)權(quán)利要求7或8所述的系統(tǒng)，其特征在于，所述消息分發(fā)子系統(tǒng)具體用于：

在監(jiān)測(cè)到所述消息隊(duì)列中有消息，且所述消息的數(shù)量大于1時(shí)，判斷各所述消息是否為重復(fù)消息；

若是，則保留所述消息隊(duì)列中的任一所述任務(wù)執(zhí)行指令，并將所述任務(wù)執(zhí)行指令分發(fā)至所述下游服務(wù)子系統(tǒng)。

10.根據(jù)權(quán)利要求7所述的系統(tǒng)，其特征在于，所述消息分發(fā)子系統(tǒng)還用于：

將各所述任務(wù)執(zhí)行指令分發(fā)至所述下游服務(wù)子系統(tǒng)中的同一個(gè)下游服務(wù)設(shè)備。