[發(fā)明專利]分布式協(xié)議的異常構(gòu)造方法、系統(tǒng)和裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201910171946.7
• 申請(qǐng)日: 2019-03-07
• 公開（公告）號(hào): CN110213074B
• 公開（公告）日: 2022-03-11
• 發(fā)明（設(shè)計(jì)）人: 鐘星漢;張鵬飛;徐金光;吳學(xué)武
• 申請(qǐng)（專利權(quán)）人: 騰訊科技（深圳）有限公司
• 主分類號(hào): H04L41/14
• 分類號(hào): H04L41/14;H04L43/08
• 代理公司: 華進(jìn)聯(lián)合專利商標(biāo)代理有限公司 44224
• 代理人: 李文淵;何平

1.一種分布式協(xié)議的異常構(gòu)造方法，應(yīng)用于分布式集群中的分布式節(jié)點(diǎn)，所述方法包括：

對(duì)基于分布式協(xié)議的分布式應(yīng)用進(jìn)程進(jìn)行交互的網(wǎng)絡(luò)報(bào)文進(jìn)行監(jiān)測(cè)；

當(dāng)監(jiān)測(cè)到特征報(bào)文時(shí)，確定所述特征報(bào)文對(duì)應(yīng)的鏈路；

當(dāng)預(yù)設(shè)的異常觸發(fā)時(shí)機(jī)為傳輸報(bào)文前觸發(fā)時(shí)，若所述特征報(bào)文為通過分布式應(yīng)用進(jìn)程生成的待發(fā)送的網(wǎng)絡(luò)報(bào)文時(shí)，則持續(xù)緩存包括所述特征報(bào)文在內(nèi)的、通過所述鏈路傳輸?shù)木W(wǎng)絡(luò)報(bào)文，以在將生成的所述特征報(bào)文發(fā)送至所述分布式集群中需交互的分布式節(jié)點(diǎn)之前構(gòu)造異常；若所述特征報(bào)文為接收的來自于所述分布式集群中分布式節(jié)點(diǎn)發(fā)送的網(wǎng)絡(luò)報(bào)文時(shí)，則持續(xù)緩存包括所述特征報(bào)文在內(nèi)的、通過所述鏈路傳輸?shù)木W(wǎng)絡(luò)報(bào)文，以在將接收的所述特征報(bào)文傳遞至本地運(yùn)行的分布式應(yīng)用進(jìn)程之前構(gòu)造異常；

當(dāng)預(yù)設(shè)的異常觸發(fā)時(shí)機(jī)為傳輸報(bào)文后觸發(fā)時(shí)，若所述特征報(bào)文為通過分布式應(yīng)用進(jìn)程生成的待發(fā)送的網(wǎng)絡(luò)報(bào)文時(shí)，則持續(xù)緩存不包括所述特征報(bào)文在內(nèi)的、通過鏈路傳輸?shù)木W(wǎng)絡(luò)報(bào)文，以在將生成的所述特征報(bào)文發(fā)送至所述分布式集群中需交互的分布式節(jié)點(diǎn)之后構(gòu)造異常；若所述特征報(bào)文為接收的來自于所述分布式集群中分布式節(jié)點(diǎn)發(fā)送的網(wǎng)絡(luò)報(bào)文時(shí)，則持續(xù)緩存不包括所述特征報(bào)文在內(nèi)的、通過鏈路傳輸?shù)木W(wǎng)絡(luò)報(bào)文，以在將接收的所述特征報(bào)文傳遞至本地運(yùn)行的分布式應(yīng)用進(jìn)程之后構(gòu)造異常；

按照預(yù)設(shè)的演練場(chǎng)景，構(gòu)造符合所述異常觸發(fā)時(shí)機(jī)的異常；

當(dāng)所述異常生效后，解除對(duì)通過所述鏈路傳輸?shù)木W(wǎng)絡(luò)報(bào)文的緩存，并傳輸緩存的所述網(wǎng)絡(luò)報(bào)文，以確定構(gòu)造的所述異常生效后，所述分布式集群中各所述分布式節(jié)點(diǎn)上的所述分布式應(yīng)用進(jìn)程能否繼續(xù)按照預(yù)期正常交互；

獲取針對(duì)構(gòu)造的所述異常的撤銷指令，根據(jù)所述撤銷指令撤銷構(gòu)造的所述異常，以確定構(gòu)造的所述異常撤銷后，所述分布式集群中各所述分布式節(jié)點(diǎn)上的所述分布式應(yīng)用進(jìn)程能否繼續(xù)按照預(yù)期正常交互。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述當(dāng)監(jiān)測(cè)到特征報(bào)文時(shí)，確定所述特征報(bào)文對(duì)應(yīng)的鏈路包括：

從網(wǎng)絡(luò)報(bào)文中確定與預(yù)設(shè)的網(wǎng)絡(luò)報(bào)文特征匹配的特征報(bào)文；

根據(jù)所述特征報(bào)文中的源地址和目的地址確定對(duì)應(yīng)的鏈路。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述按照預(yù)設(shè)的演練場(chǎng)景，構(gòu)造符合所述異常觸發(fā)時(shí)機(jī)的異常包括：

獲取預(yù)先設(shè)置的與所述特征報(bào)文對(duì)應(yīng)的演練場(chǎng)景；

確定在所述演練場(chǎng)景下所需構(gòu)造的異常；

向需交互的分布式節(jié)點(diǎn)發(fā)送確定的所述異常對(duì)應(yīng)的構(gòu)造指令；

所述構(gòu)造指令用于指示所述分布式節(jié)點(diǎn)在本地構(gòu)造確定的且符合所述異常觸發(fā)時(shí)機(jī)的所述異常。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述按照預(yù)設(shè)的演練場(chǎng)景，構(gòu)造符合所述異常觸發(fā)時(shí)機(jī)的異常包括：

獲取預(yù)先設(shè)置的與所述特征報(bào)文對(duì)應(yīng)的演練場(chǎng)景；

確定在所述演練場(chǎng)景下所需構(gòu)造的異常；

在本地構(gòu)造確定的且符合所述異常觸發(fā)時(shí)機(jī)的所述異常。

5.根據(jù)權(quán)利要求1至4任一項(xiàng)所述的方法，其特征在于，所述當(dāng)所述異常生效后，解除對(duì)通過所述鏈路傳輸?shù)木W(wǎng)絡(luò)報(bào)文的緩存，并傳輸緩存的所述網(wǎng)絡(luò)報(bào)文包括：

當(dāng)所述異常生效后，解除對(duì)通過所述鏈路傳輸?shù)乃鼍W(wǎng)絡(luò)報(bào)文的緩存；

通過所述分布式應(yīng)用進(jìn)程獲取本地緩存的待接收的所述網(wǎng)絡(luò)報(bào)文；或者，向需交互的分布式節(jié)點(diǎn)發(fā)送本地緩存的待發(fā)送的所述網(wǎng)絡(luò)報(bào)文；

所述方法還包括：

通過演練終端獲取各分布式節(jié)點(diǎn)針對(duì)所述網(wǎng)絡(luò)報(bào)文生成的響應(yīng)結(jié)果；根據(jù)所述響應(yīng)結(jié)果判定各所述分布式節(jié)點(diǎn)上基于所述分布式協(xié)議的分布式應(yīng)用進(jìn)程在所述演練場(chǎng)景下能否正常運(yùn)行。