[發(fā)明專利]業(yè)務(wù)進(jìn)程調(diào)度方法、裝置、電子設(shè)備以及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202110945796.8
• 申請(qǐng)日: 2021-08-17
• 公開(kāi)（公告）號(hào): CN113626169A
• 公開(kāi)（公告）日: 2021-11-09
• 發(fā)明（設(shè)計(jì)）人: 羅金
• 申請(qǐng)（專利權(quán)）人: 北京沃東天駿信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): G06F9/48
• 分類號(hào): G06F9/48;G06F9/50;G06F16/2455
• 代理公司: 中科專利商標(biāo)代理有限責(zé)任公司 11021
• 代理人: 任巖

本公開(kāi)提供了一種業(yè)務(wù)進(jìn)程調(diào)度方法，包括：獲取至少一個(gè)業(yè)務(wù)進(jìn)程；為至少一個(gè)業(yè)務(wù)進(jìn)程分別設(shè)置對(duì)應(yīng)的流程節(jié)點(diǎn)；根據(jù)至少一個(gè)業(yè)務(wù)進(jìn)程之間的執(zhí)行邏輯，分別依次通過(guò)流程節(jié)點(diǎn)調(diào)度對(duì)應(yīng)的業(yè)務(wù)進(jìn)程，使業(yè)務(wù)進(jìn)程依次被執(zhí)行；以及在確定業(yè)務(wù)進(jìn)程出現(xiàn)執(zhí)行異常的情況下，通過(guò)業(yè)務(wù)進(jìn)程對(duì)應(yīng)的流程節(jié)點(diǎn)重新調(diào)度業(yè)務(wù)進(jìn)程，使出現(xiàn)執(zhí)行異常的業(yè)務(wù)進(jìn)程被重新執(zhí)行。本公開(kāi)還提供一種業(yè)務(wù)進(jìn)程調(diào)度裝置、電子設(shè)備以及存儲(chǔ)介質(zhì)。

技術(shù)領(lǐng)域

本公開(kāi)涉及計(jì)算機(jī)技術(shù)領(lǐng)域，更具體地，涉及一種業(yè)務(wù)進(jìn)程調(diào)度方法、裝置、電子設(shè)備以及存儲(chǔ)介質(zhì)。

背景技術(shù)

在復(fù)雜的多進(jìn)程環(huán)境中，合理的業(yè)務(wù)進(jìn)程調(diào)度方法顯得尤為重要。通常，對(duì)于流程性較強(qiáng)的多個(gè)業(yè)務(wù)進(jìn)程，可以采用鏈?zhǔn)浇Y(jié)構(gòu)進(jìn)行進(jìn)程調(diào)度。即根據(jù)業(yè)務(wù)邏輯由上一業(yè)務(wù)進(jìn)程的完成事件作為觸發(fā)條件，觸發(fā)下一業(yè)務(wù)進(jìn)程被執(zhí)行。

在實(shí)現(xiàn)本公開(kāi)構(gòu)思的過(guò)程中，發(fā)明人發(fā)現(xiàn)相關(guān)技術(shù)中至少存在如下問(wèn)題：鏈?zhǔn)浇Y(jié)構(gòu)的調(diào)度方法會(huì)造成業(yè)務(wù)進(jìn)程的執(zhí)行流程與業(yè)務(wù)邏輯耦合。當(dāng)任一業(yè)務(wù)進(jìn)程的執(zhí)行過(guò)程中出現(xiàn)異常時(shí)，執(zhí)行流程與業(yè)務(wù)邏輯之間的耦合度會(huì)增加調(diào)度的困難。

發(fā)明內(nèi)容

有鑒于此，本公開(kāi)提供了一種業(yè)務(wù)進(jìn)程調(diào)度方法和裝置。

本公開(kāi)的一個(gè)方面提供了一種業(yè)務(wù)進(jìn)程調(diào)度方法，包括：獲取至少一個(gè)業(yè)務(wù)進(jìn)程；為所述至少一個(gè)業(yè)務(wù)進(jìn)程分別設(shè)置對(duì)應(yīng)的流程節(jié)點(diǎn)；根據(jù)所述至少一個(gè)業(yè)務(wù)進(jìn)程之間的執(zhí)行邏輯，分別依次通過(guò)所述流程節(jié)點(diǎn)調(diào)度對(duì)應(yīng)的業(yè)務(wù)進(jìn)程，使所述業(yè)務(wù)進(jìn)程依次被執(zhí)行；以及在確定業(yè)務(wù)進(jìn)程出現(xiàn)執(zhí)行異常的情況下，通過(guò)所述業(yè)務(wù)進(jìn)程對(duì)應(yīng)的流程節(jié)點(diǎn)重新調(diào)度所述業(yè)務(wù)進(jìn)程，使出現(xiàn)執(zhí)行異常的業(yè)務(wù)進(jìn)程被重新執(zhí)行。

根據(jù)本公開(kāi)的實(shí)施例，所述至少一個(gè)業(yè)務(wù)進(jìn)程包括N個(gè)業(yè)務(wù)進(jìn)程，N為大于等于2的整數(shù)；所述根據(jù)所述至少一個(gè)業(yè)務(wù)進(jìn)程之間的執(zhí)行邏輯，分別依次通過(guò)所述流程節(jié)點(diǎn)調(diào)度對(duì)應(yīng)的業(yè)務(wù)進(jìn)程，使所述業(yè)務(wù)進(jìn)程依次被執(zhí)行，包括：根據(jù)所述N個(gè)業(yè)務(wù)進(jìn)程之間的執(zhí)行邏輯，通過(guò)所述N個(gè)業(yè)務(wù)進(jìn)程中的第i業(yè)務(wù)進(jìn)程對(duì)應(yīng)的第i流程節(jié)點(diǎn)向所述第i業(yè)務(wù)進(jìn)程發(fā)送調(diào)度消息，i∈[1，N)；根據(jù)所述調(diào)度消息，執(zhí)行所述第i業(yè)務(wù)進(jìn)程，得到第i執(zhí)行結(jié)果；將所述第i執(zhí)行結(jié)果發(fā)送到所述第i流程節(jié)點(diǎn)；以及在確定所述第i執(zhí)行結(jié)果為執(zhí)行成功的情況下，根據(jù)所述N個(gè)業(yè)務(wù)進(jìn)程之間的執(zhí)行邏輯，通過(guò)所述第i+1業(yè)務(wù)進(jìn)程對(duì)應(yīng)的第i+1流程節(jié)點(diǎn)向所述第i+1業(yè)務(wù)進(jìn)程發(fā)送調(diào)度消息。

根據(jù)本公開(kāi)的實(shí)施例，所述業(yè)務(wù)進(jìn)程包括任務(wù)創(chuàng)建進(jìn)程；所述通過(guò)所述流程節(jié)點(diǎn)調(diào)度對(duì)應(yīng)的業(yè)務(wù)進(jìn)程，包括：通過(guò)所述任務(wù)創(chuàng)建進(jìn)程對(duì)應(yīng)的流程節(jié)點(diǎn)向所述任務(wù)創(chuàng)建進(jìn)程發(fā)送創(chuàng)建指令；所述流程節(jié)點(diǎn)獲取由所述任務(wù)創(chuàng)建進(jìn)程基于所述創(chuàng)建指令創(chuàng)建的至少一個(gè)任務(wù)和創(chuàng)建結(jié)果；以及在緩存中存儲(chǔ)所述至少一個(gè)任務(wù)，以及在數(shù)據(jù)庫(kù)中存儲(chǔ)所述創(chuàng)建結(jié)果。

根據(jù)本公開(kāi)的實(shí)施例，所述業(yè)務(wù)進(jìn)程還包括任務(wù)執(zhí)行進(jìn)程；所述通過(guò)所述流程節(jié)點(diǎn)調(diào)度對(duì)應(yīng)的業(yè)務(wù)進(jìn)程還包括：在所述緩存中存儲(chǔ)所述至少一個(gè)任務(wù)后，在所述緩存中為所述至少一個(gè)任務(wù)創(chuàng)建對(duì)應(yīng)的結(jié)果對(duì)象，所述結(jié)果對(duì)象用于記錄所述至少一個(gè)任務(wù)對(duì)應(yīng)數(shù)量的執(zhí)行結(jié)果；以及通過(guò)所述任務(wù)執(zhí)行進(jìn)程對(duì)應(yīng)的流程節(jié)點(diǎn)監(jiān)控所述結(jié)果對(duì)象，以獲得執(zhí)行結(jié)果。

根據(jù)本公開(kāi)的實(shí)施例，所述方法還包括：獲取所述業(yè)務(wù)進(jìn)程的執(zhí)行結(jié)果；以及向所述業(yè)務(wù)進(jìn)程對(duì)應(yīng)的流程節(jié)點(diǎn)發(fā)送所述執(zhí)行結(jié)果，以提示用戶通過(guò)所述流程節(jié)點(diǎn)查看所述執(zhí)行結(jié)果。

根據(jù)本公開(kāi)的實(shí)施例，所述的方法，還包括，在所述根據(jù)所述至少一個(gè)業(yè)務(wù)進(jìn)程之間的執(zhí)行邏輯，分別依次通過(guò)所述流程節(jié)點(diǎn)調(diào)度對(duì)應(yīng)的業(yè)務(wù)進(jìn)程，使所述業(yè)務(wù)進(jìn)程依次被執(zhí)行之前：分別獲取每個(gè)流程節(jié)點(diǎn)的流程ID；以及通過(guò)所述流程ID對(duì)所述流程節(jié)點(diǎn)執(zhí)行去重操作。

根據(jù)本公開(kāi)的實(shí)施例，所述分別依次通過(guò)所述流程節(jié)點(diǎn)調(diào)度對(duì)應(yīng)的業(yè)務(wù)進(jìn)程，包括：所述流程節(jié)點(diǎn)通過(guò)遠(yuǎn)程過(guò)程調(diào)用接口調(diào)度對(duì)應(yīng)的業(yè)務(wù)進(jìn)程。