[發(fā)明專利]分布式網(wǎng)絡(luò)業(yè)務(wù)調(diào)度方法、裝置、計(jì)算設(shè)備和存儲(chǔ)介質(zhì)

有效

• 申請(qǐng)?zhí)枺?/td>: 201810745163.0
• 申請(qǐng)日: 2018-07-09
• 公開(kāi)（公告）號(hào): CN108900379B
• 公開(kāi)（公告）日: 2020-12-29
• 發(fā)明（設(shè)計(jì)）人: 王冰;胡根
• 申請(qǐng)（專利權(quán)）人: 阿里巴巴（中國(guó)）有限公司
• 主分類號(hào): H04L12/26
• 分類號(hào): H04L12/26;H04L29/08
• 代理公司: 北京展翼知識(shí)產(chǎn)權(quán)代理事務(wù)所(特殊普通合伙) 11452
• 代理人: 屠長(zhǎng)存

1.一種用于分布式網(wǎng)絡(luò)的業(yè)務(wù)調(diào)度方法，包括：

基于下游節(jié)點(diǎn)針對(duì)上游節(jié)點(diǎn)下發(fā)的業(yè)務(wù)處理請(qǐng)求返回的業(yè)務(wù)處理結(jié)果，判斷下游節(jié)點(diǎn)是否處理成功；

分別統(tǒng)計(jì)所述上游節(jié)點(diǎn)的各個(gè)下游節(jié)點(diǎn)的業(yè)務(wù)處理失敗率；

將失敗率不低于第一閾值的下游節(jié)點(diǎn)標(biāo)記為非正常節(jié)點(diǎn)，將失敗率低于所述第一閾值的下游節(jié)點(diǎn)標(biāo)記為正常節(jié)點(diǎn)；

響應(yīng)于所述上游節(jié)點(diǎn)存在要向所述下游節(jié)點(diǎn)下發(fā)的業(yè)務(wù)處理請(qǐng)求，構(gòu)建候選隊(duì)列，其中，將所述非正常節(jié)點(diǎn)放入所述候選隊(duì)列的概率低于將所述正常節(jié)點(diǎn)放入所述候選隊(duì)列；

從所述候選隊(duì)列中選擇下游節(jié)點(diǎn)以用于執(zhí)行所述業(yè)務(wù)處理請(qǐng)求；

向所選擇的下游節(jié)點(diǎn)發(fā)送所述業(yè)務(wù)處理請(qǐng)求；以及

從所選擇的下游節(jié)點(diǎn)接收業(yè)務(wù)處理結(jié)果。

2.根據(jù)權(quán)利要求1所述的業(yè)務(wù)調(diào)度方法，還包括：

響應(yīng)于判定下游節(jié)點(diǎn)處理失敗，判斷所述業(yè)務(wù)處理請(qǐng)求的剩余處理時(shí)間是否足夠重新請(qǐng)求其它下游節(jié)點(diǎn)處理該項(xiàng)業(yè)務(wù)處理請(qǐng)求，并在所述剩余處理時(shí)間足夠的情況下，選擇另一個(gè)下游節(jié)點(diǎn)以執(zhí)行所述業(yè)務(wù)處理請(qǐng)求。

3.根據(jù)權(quán)利要求1所述的業(yè)務(wù)調(diào)度方法，其中，所述分別統(tǒng)計(jì)所述上游節(jié)點(diǎn)的各個(gè)下游節(jié)點(diǎn)的業(yè)務(wù)處理失敗率的步驟包括：

針對(duì)各個(gè)下游節(jié)點(diǎn)分別維護(hù)第一計(jì)數(shù)器和第二計(jì)數(shù)器，所述第一計(jì)數(shù)器用于累計(jì)對(duì)應(yīng)下游節(jié)點(diǎn)處理成功的次數(shù)，所述第二計(jì)數(shù)器用于累計(jì)對(duì)應(yīng)下游節(jié)點(diǎn)處理失敗的次數(shù)；

基于各個(gè)下游節(jié)點(diǎn)分別對(duì)應(yīng)的所述第一計(jì)數(shù)器的第一計(jì)數(shù)值和所述第二計(jì)數(shù)器的第二計(jì)數(shù)值，分別統(tǒng)計(jì)該下游節(jié)點(diǎn)的失敗率。

4.根據(jù)權(quán)利要求3所述的業(yè)務(wù)調(diào)度方法，其中，所述分別統(tǒng)計(jì)所述上游節(jié)點(diǎn)的各個(gè)下游節(jié)點(diǎn)的業(yè)務(wù)處理失敗率的步驟還包括：

響應(yīng)于預(yù)定時(shí)間期間期滿，對(duì)于各個(gè)下游節(jié)點(diǎn)分別判斷其所對(duì)應(yīng)的所述第一計(jì)數(shù)值和所述第二計(jì)數(shù)值之和是否低于第二閾值；

響應(yīng)于所述和低于所述第二閾值，由該下游節(jié)點(diǎn)對(duì)應(yīng)的所述第一計(jì)數(shù)器和所述第二計(jì)數(shù)器繼續(xù)進(jìn)行計(jì)數(shù)，直到下一個(gè)預(yù)定時(shí)間期間期滿；以及

響應(yīng)于所述和不低于所述第二閾值，基于所述第一計(jì)數(shù)值和所述第二計(jì)數(shù)值統(tǒng)計(jì)該下游節(jié)點(diǎn)的失敗率，清空所述第一計(jì)數(shù)器和所述第二計(jì)數(shù)器，以便重新開(kāi)始進(jìn)行下一個(gè)預(yù)定時(shí)間期間的計(jì)數(shù)。

5.根據(jù)權(quán)利要求3所述的業(yè)務(wù)調(diào)度方法，其中，該業(yè)務(wù)調(diào)度方法由所述上游節(jié)點(diǎn)執(zhí)行，所述上游節(jié)點(diǎn)維護(hù)節(jié)點(diǎn)狀態(tài)監(jiān)控服務(wù)，

在所述節(jié)點(diǎn)狀態(tài)監(jiān)控服務(wù)的啟動(dòng)初始階段為各個(gè)下游節(jié)點(diǎn)分別創(chuàng)建所述第一計(jì)數(shù)器和所述第二計(jì)數(shù)器。

6.根據(jù)權(quán)利要求1所述的業(yè)務(wù)調(diào)度方法，其中，所述構(gòu)建候選隊(duì)列的步驟還包括：

基于預(yù)定策略，選擇要放入所述候選隊(duì)列的正常節(jié)點(diǎn)。

7.一種用于分布式網(wǎng)絡(luò)的業(yè)務(wù)調(diào)度裝置，包括：

結(jié)果判斷裝置，用于基于下游節(jié)點(diǎn)針對(duì)上游節(jié)點(diǎn)下發(fā)的業(yè)務(wù)處理請(qǐng)求返回的業(yè)務(wù)處理結(jié)果，判斷下游節(jié)點(diǎn)是否處理成功；

失敗率統(tǒng)計(jì)裝置，用于分別統(tǒng)計(jì)所述上游節(jié)點(diǎn)的各個(gè)下游節(jié)點(diǎn)的業(yè)務(wù)處理失敗率；

狀態(tài)標(biāo)記裝置，用于將失敗率不低于第一閾值的下游節(jié)點(diǎn)標(biāo)記為非正常節(jié)點(diǎn)，將失敗率低于所述第一閾值的下游節(jié)點(diǎn)標(biāo)記為正常節(jié)點(diǎn)；

隊(duì)列構(gòu)建裝置，用于響應(yīng)于所述上游節(jié)點(diǎn)存在要向所述下游節(jié)點(diǎn)下發(fā)的業(yè)務(wù)處理請(qǐng)求，構(gòu)建候選隊(duì)列，其中，將所述非正常節(jié)點(diǎn)放入所述候選隊(duì)列的概率低于將所述正常節(jié)點(diǎn)放入所述候選隊(duì)列；

節(jié)點(diǎn)選擇裝置，用于從所述候選隊(duì)列中選擇下游節(jié)點(diǎn)以用于執(zhí)行所述業(yè)務(wù)處理請(qǐng)求；

請(qǐng)求下發(fā)裝置，用于向所選擇的下游節(jié)點(diǎn)發(fā)送所述業(yè)務(wù)處理請(qǐng)求；以及

結(jié)果接收裝置，用于從所選擇的下游節(jié)點(diǎn)接收業(yè)務(wù)處理結(jié)果。

8.根據(jù)權(quán)利要求7所述的業(yè)務(wù)調(diào)度裝置，還包括：

節(jié)點(diǎn)重選裝置，用于響應(yīng)于判定下游節(jié)點(diǎn)處理失敗，判斷所述業(yè)務(wù)處理請(qǐng)求的剩余處理時(shí)間是否足以完成該項(xiàng)業(yè)務(wù)處理請(qǐng)求，并在所述剩余處理時(shí)間足夠的情況下，選擇另一個(gè)下游節(jié)點(diǎn)以執(zhí)行所述業(yè)務(wù)處理請(qǐng)求。