[發(fā)明專利]一種分布式系統(tǒng)任務(wù)執(zhí)行的方法和裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201710270128.3
• 申請(qǐng)日: 2017-04-24
• 公開（公告）號(hào): CN108733469B
• 公開（公告）日: 2021-09-03
• 發(fā)明（設(shè)計(jì)）人: 高平;孔文杰;冷維偉;邢磊
• 申請(qǐng)（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48;G06F9/50
• 代理公司: 中原信達(dá)知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 張一軍;姜?jiǎng)?/td>

1.一種分布式系統(tǒng)任務(wù)執(zhí)行的方法，其特征在于，包括：

任務(wù)發(fā)起者創(chuàng)建任務(wù)并將所述任務(wù)發(fā)送給任務(wù)調(diào)度者；

所述任務(wù)調(diào)度者接收所述任務(wù)并將所述任務(wù)分發(fā)給任務(wù)處理者；

所述任務(wù)處理者接收并執(zhí)行所述任務(wù)，并保存所述任務(wù)的執(zhí)行結(jié)果；在保存所述任務(wù)的執(zhí)行結(jié)果之前，根據(jù)預(yù)定的結(jié)果處理規(guī)則對(duì)所述任務(wù)的執(zhí)行日志進(jìn)行處理，以得到所述任務(wù)的執(zhí)行結(jié)果；

所述任務(wù)發(fā)起者從保存的所述執(zhí)行結(jié)果中獲取所述任務(wù)的執(zhí)行結(jié)果；

根據(jù)所述執(zhí)行日志監(jiān)控所述任務(wù)的執(zhí)行狀態(tài)，并當(dāng)所述執(zhí)行日志出現(xiàn)異常時(shí)進(jìn)行異常處理以及向所述任務(wù)發(fā)起者發(fā)送預(yù)警消息，其中，異常情況包括運(yùn)行時(shí)異常和資源類異常；對(duì)于出現(xiàn)異常后的異常處理，如果是運(yùn)行時(shí)異常，則直接中斷任務(wù)；如果是資源類異常，則調(diào)用其他正常的任務(wù)處理者來重新執(zhí)行任務(wù)；

所述任務(wù)處理者通過調(diào)用結(jié)果處理引擎來保存所述任務(wù)的執(zhí)行結(jié)果，所述結(jié)果處理引擎包括規(guī)則定義模塊，用于定義任務(wù)處理者同結(jié)果處理引擎之間的交互規(guī)則、結(jié)果處理引擎同任務(wù)發(fā)起者之間的交互規(guī)則，以及結(jié)果處理規(guī)則。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述結(jié)果處理規(guī)則包括：從所述執(zhí)行日志中抽取所述任務(wù)對(duì)應(yīng)的數(shù)據(jù)字段，并將所述數(shù)據(jù)字段作為所述任務(wù)的執(zhí)行結(jié)果。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，

所述任務(wù)發(fā)起者通過輪詢的方式獲取所述任務(wù)的執(zhí)行結(jié)果。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，

所述任務(wù)發(fā)起者根據(jù)所述任務(wù)處理者發(fā)來的所述任務(wù)執(zhí)行完成的通知，從所述保存的執(zhí)行結(jié)果中獲取所述任務(wù)的執(zhí)行結(jié)果。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，

所述任務(wù)發(fā)起者通過接收所述任務(wù)處理者發(fā)來的執(zhí)行結(jié)果的方式獲取所述任務(wù)的執(zhí)行結(jié)果。

6.一種分布式系統(tǒng)任務(wù)執(zhí)行的裝置，其特征在于，包括：

任務(wù)創(chuàng)建模塊，用于任務(wù)發(fā)起者創(chuàng)建任務(wù)并將所述任務(wù)發(fā)送給任務(wù)調(diào)度者；

任務(wù)分發(fā)模塊，用于所述任務(wù)調(diào)度者接收所述任務(wù)并將所述任務(wù)分發(fā)給任務(wù)處理者；

任務(wù)處理模塊，用于所述任務(wù)處理者接收并執(zhí)行所述任務(wù)，并保存所述任務(wù)的執(zhí)行結(jié)果；根據(jù)預(yù)定的結(jié)果處理規(guī)則對(duì)所述任務(wù)的執(zhí)行日志進(jìn)行處理，以得到所述任務(wù)的執(zhí)行結(jié)果；所述任務(wù)處理者通過調(diào)用結(jié)果處理引擎來保存所述任務(wù)的執(zhí)行結(jié)果，所述結(jié)果處理引擎包括規(guī)則定義模塊，用于定義任務(wù)處理者同結(jié)果處理引擎之間的交互規(guī)則、結(jié)果處理引擎同任務(wù)發(fā)起者之間的交互規(guī)則，以及結(jié)果處理規(guī)則；

結(jié)果獲取模塊，用于所述任務(wù)發(fā)起者從保存的所述執(zhí)行結(jié)果中獲取所述任務(wù)的執(zhí)行結(jié)果；

監(jiān)控預(yù)警模塊，用于根據(jù)所述執(zhí)行日志監(jiān)控所述任務(wù)的執(zhí)行狀態(tài)，并當(dāng)所述執(zhí)行日志出現(xiàn)異常時(shí)進(jìn)行異常處理以及向所述任務(wù)發(fā)起者發(fā)送預(yù)警消息，其中，異常情況包括運(yùn)行時(shí)異常和資源類異常；對(duì)于出現(xiàn)異常后的異常處理，如果是運(yùn)行時(shí)異常，則直接中斷任務(wù)；如果是資源類異常，則調(diào)用其他正常的任務(wù)處理者來重新執(zhí)行任務(wù)。

7.根據(jù)權(quán)利要求6所述的裝置，其特征在于，所述結(jié)果處理規(guī)則包括：從所述執(zhí)行日志中抽取所述任務(wù)對(duì)應(yīng)的數(shù)據(jù)字段，并將所述數(shù)據(jù)字段作為所述任務(wù)的執(zhí)行結(jié)果。

8.根據(jù)權(quán)利要求6所述的裝置，其特征在于，

所述任務(wù)發(fā)起者通過輪詢的方式獲取所述任務(wù)的執(zhí)行結(jié)果。

9.根據(jù)權(quán)利要求6所述的裝置，其特征在于，

所述任務(wù)發(fā)起者根據(jù)所述任務(wù)處理者發(fā)來的所述任務(wù)執(zhí)行完成的通知，從所述保存的執(zhí)行結(jié)果中獲取所述任務(wù)的執(zhí)行結(jié)果。

10.根據(jù)權(quán)利要求6所述的裝置，其特征在于，

所述任務(wù)發(fā)起者通過接收所述任務(wù)處理者發(fā)來的執(zhí)行結(jié)果的方式獲取所述任務(wù)的執(zhí)行結(jié)果。