[發(fā)明專利]一種調(diào)度方法及系統(tǒng)、工作節(jié)點(diǎn)及監(jiān)控節(jié)點(diǎn)

有效

• 申請(qǐng)?zhí)枺?/td>: 201711190923.8
• 申請(qǐng)日: 2017-11-24
• 公開(kāi)（公告）號(hào): CN109842500B
• 公開(kāi)（公告）日: 2022-05-10
• 發(fā)明（設(shè)計(jì)）人: 譚佳
• 申請(qǐng)（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號(hào): H04L41/0663
• 分類號(hào): H04L41/0663;H04L43/00;H04L43/50
• 代理公司: 北京潤(rùn)澤恒知識(shí)產(chǎn)權(quán)代理有限公司 11319
• 代理人: 譚鎮(zhèn)

本申請(qǐng)?zhí)峁┝艘环N調(diào)度方法及系統(tǒng)，涉及計(jì)算機(jī)技術(shù)領(lǐng)域。所述方法包括：監(jiān)控節(jié)點(diǎn)將用戶請(qǐng)求發(fā)送給一處于可用狀態(tài)的工作節(jié)點(diǎn)；所述處于可用狀態(tài)的工作節(jié)點(diǎn)創(chuàng)建對(duì)應(yīng)所述用戶請(qǐng)求的工作流實(shí)例，將所述工作流實(shí)例的執(zhí)行過(guò)程數(shù)據(jù)進(jìn)行記錄；所述監(jiān)控節(jié)點(diǎn)監(jiān)控多個(gè)工作節(jié)點(diǎn)的運(yùn)行狀態(tài)數(shù)據(jù)，在確定一工作節(jié)點(diǎn)處于不可用狀態(tài)，則根據(jù)所述不可用狀態(tài)的工作節(jié)點(diǎn)的記錄，將所述不可用狀態(tài)的工作節(jié)點(diǎn)的未完成的工作流實(shí)例調(diào)度到另一處于可用狀態(tài)的工作節(jié)點(diǎn)；所述另一處于可用狀態(tài)的工作節(jié)點(diǎn)，根據(jù)所述不可用狀態(tài)的工作節(jié)點(diǎn)的記錄，繼續(xù)執(zhí)行所述未完成的工作流實(shí)例，并將所述工作流實(shí)例的執(zhí)行過(guò)程數(shù)據(jù)進(jìn)行記錄。本申請(qǐng)能夠提高效率的同時(shí)能達(dá)到高可靠的目的。

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

本申請(qǐng)涉及計(jì)算機(jī)技術(shù)領(lǐng)域，特別是涉及一種調(diào)度方法及系統(tǒng)、一種工作節(jié)點(diǎn)、一種監(jiān)控節(jié)點(diǎn)。

背景技術(shù)

在云產(chǎn)品管控平臺(tái)接收到用戶請(qǐng)求后，可能存在一系列的工作流以完成該用戶請(qǐng)求，比如以創(chuàng)建虛機(jī)為例，該請(qǐng)求需要調(diào)用存儲(chǔ)、網(wǎng)絡(luò)、虛擬化等各個(gè)模塊完成用戶請(qǐng)求，整個(gè)服務(wù)調(diào)用會(huì)跨越多個(gè)外部業(yè)務(wù)系統(tǒng)。那么對(duì)于一個(gè)工作流而言，如果其未完成，那么對(duì)于用戶而言，由于相應(yīng)請(qǐng)求無(wú)法被完成導(dǎo)致需要重新提交請(qǐng)求或者通過(guò)工單要求恢復(fù)。對(duì)于系統(tǒng)而言，工作流運(yùn)行到一半可能導(dǎo)致有某些中間的資源無(wú)法被釋放，出現(xiàn)孤立的資源導(dǎo)致系統(tǒng)不一致。上述問(wèn)題如果不解決，會(huì)導(dǎo)致開(kāi)發(fā)團(tuán)隊(duì)花費(fèi)大量的精力來(lái)解決各種客戶問(wèn)題、系統(tǒng)問(wèn)題，效率很低。

在先技術(shù)中，亞馬遜提供了一種云服務(wù)Amazon Simple Workflow Service (亞馬遜簡(jiǎn)單工作流服務(wù)，簡(jiǎn)稱AWS)，該云服務(wù)將應(yīng)用程序劃分為兩個(gè)部分：決策程序(Decider)和活動(dòng)程序(Activity)。決策程序決定用戶的請(qǐng)求應(yīng)該做什么，活動(dòng)程序負(fù)責(zé)執(zhí)行具體的業(yè)務(wù)邏輯。活動(dòng)程序輪詢AWS任務(wù)列表上的活動(dòng)任務(wù)，然后執(zhí)行活動(dòng)任務(wù)，報(bào)告活動(dòng)任務(wù)檢測(cè)信號(hào)。決策程序輪詢 AWS獲得決策任務(wù)，然后根據(jù)預(yù)置的協(xié)作邏輯做出決策返回AWS。在該框架下，當(dāng)活動(dòng)程序出現(xiàn)問(wèn)題時(shí)，AWS無(wú)法接收到活動(dòng)程序的反饋，所以AWS 可以通過(guò)超時(shí)機(jī)制來(lái)判斷活動(dòng)是否出現(xiàn)問(wèn)題，如果出現(xiàn)問(wèn)題，則AWS會(huì)為該超時(shí)事件創(chuàng)建一個(gè)決策任務(wù)，決策程序從AWS獲取該任務(wù)，然后決定下一步具體的執(zhí)行邏輯。當(dāng)決策程序出現(xiàn)問(wèn)題，AWS也會(huì)通過(guò)超時(shí)檢測(cè)來(lái)判斷決策程序是否正常，如果不正常則執(zhí)行相應(yīng)的failover機(jī)制。其中，AWS 的failover機(jī)制是通過(guò)超時(shí)來(lái)判斷，比如一個(gè)活動(dòng)執(zhí)行過(guò)程中，負(fù)責(zé)執(zhí)行的活動(dòng)節(jié)點(diǎn)失聯(lián)，后端服務(wù)會(huì)限定該活動(dòng)的最大執(zhí)行時(shí)間，如果超過(guò)該時(shí)間，則認(rèn)為活動(dòng)執(zhí)行超時(shí)，會(huì)重新創(chuàng)建一個(gè)新的活動(dòng)來(lái)執(zhí)行。

然而，AWS上述過(guò)程，決策程序與活動(dòng)程序需要反復(fù)與AWS交互，決策程序與活動(dòng)程序各自要通過(guò)http(HyperText Transfer Protocol，超文本傳輸協(xié)議)接口從AWS獲取任務(wù)，提交任務(wù)結(jié)果。因此，上述這些操作由于需要反復(fù)的服務(wù)交互，每一個(gè)活動(dòng)執(zhí)行需要四次HTTP交互，效率很低，對(duì)于活動(dòng)的監(jiān)控和恢復(fù)過(guò)程的處理邏輯也很復(fù)雜。

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

鑒于上述問(wèn)題，本申請(qǐng)實(shí)施例提供調(diào)度方法及裝置，以對(duì)工作流實(shí)例的執(zhí)行過(guò)程數(shù)據(jù)進(jìn)行記錄，然后以監(jiān)控節(jié)點(diǎn)監(jiān)控各工作節(jié)點(diǎn)的運(yùn)行狀態(tài)，從而在工作節(jié)點(diǎn)失聯(lián)時(shí)根據(jù)該工作節(jié)點(diǎn)的記錄，將未完成的工作流實(shí)例調(diào)度給一正常的工作節(jié)點(diǎn)中重建以繼續(xù)執(zhí)行，解決在先技術(shù)無(wú)法保證用戶請(qǐng)求執(zhí)行效率同時(shí)保證高可靠的問(wèn)題。

為了解決上述問(wèn)題，本申請(qǐng)實(shí)施例公開(kāi)了一種調(diào)度方法，其特征在于，包括：

監(jiān)控節(jié)點(diǎn)將用戶請(qǐng)求發(fā)送給一處于可用狀態(tài)的工作節(jié)點(diǎn)；

所述處于可用狀態(tài)的工作節(jié)點(diǎn)創(chuàng)建對(duì)應(yīng)所述用戶請(qǐng)求的工作流實(shí)例；

所述處于可用狀態(tài)的工作節(jié)點(diǎn)將所述工作流實(shí)例的執(zhí)行過(guò)程數(shù)據(jù)進(jìn)行記錄；

所述監(jiān)控節(jié)點(diǎn)監(jiān)控多個(gè)工作節(jié)點(diǎn)的運(yùn)行狀態(tài)數(shù)據(jù)；

監(jiān)控節(jié)點(diǎn)基于所述運(yùn)行狀態(tài)數(shù)據(jù)，確定一工作節(jié)點(diǎn)處于不可用狀態(tài)，則根據(jù)所述不可用狀態(tài)的工作節(jié)點(diǎn)的記錄，將所述不可用狀態(tài)的工作節(jié)點(diǎn)的未完成的工作流實(shí)例調(diào)度到另一處于可用狀態(tài)的工作節(jié)點(diǎn)；