[發(fā)明專利]一種分布式系統(tǒng)中的調(diào)用請求處理方法及裝置

在審

• 申請?zhí)枺?/td>: 201410462687.0
• 申請日: 2014-09-12
• 公開（公告）號: CN104219316A
• 公開（公告）日: 2014-12-17
• 發(fā)明（設(shè)計）人: 魏佳
• 申請（專利權(quán)）人: 微夢創(chuàng)科網(wǎng)絡(luò)科技（中國）有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京同達(dá)信恒知識產(chǎn)權(quán)代理有限公司 11291
• 代理人: 黃志華

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

本發(fā)明涉及分布式系統(tǒng)、數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種分布式系統(tǒng)中的調(diào)用請求處理方法及裝置。

背景技術(shù)

分布式系統(tǒng)是近年來解決海量計算、數(shù)據(jù)處理的通用系統(tǒng)架構(gòu)范式，解決了以往集中式系統(tǒng)的缺點(diǎn)，同時也由于其“去中心化”的特點(diǎn)具有很好的擴(kuò)展性、容錯性和健壯性。

分布式系統(tǒng)中，每一業(yè)務(wù)處理請求可以被劃分為若干個子任務(wù)進(jìn)行處理，各子任務(wù)在分布式系統(tǒng)中被處理的過程可以稱為分布式調(diào)用，一個請求的調(diào)用鏈路就是由處理各子任務(wù)的調(diào)用組成。

典型的分布式系統(tǒng)通常由不同功能的組件、子系統(tǒng)或者模塊構(gòu)成，各個組件、子系統(tǒng)或者模塊的職責(zé)不同，數(shù)據(jù)處理能力也不同。隨著分布式系統(tǒng)的結(jié)構(gòu)愈發(fā)復(fù)雜、拓?fù)溆l(fā)分散，為了對分布式系統(tǒng)進(jìn)行有效監(jiān)控或管理，避免由于流量超標(biāo)無法承載服務(wù)而造成的“系統(tǒng)雪崩效應(yīng)”等，需要對調(diào)用鏈路進(jìn)行追蹤并分析，同時可以根據(jù)分析結(jié)果對調(diào)用鏈路或者調(diào)用進(jìn)行優(yōu)化。

現(xiàn)有技術(shù)中，為了實(shí)現(xiàn)對分布式調(diào)用鏈路的追蹤，通常是在實(shí)現(xiàn)各個組件、子系統(tǒng)或者模塊的源代碼中加入實(shí)現(xiàn)調(diào)用鏈路追蹤功能的代碼，即對各個組件、子系統(tǒng)或者模塊進(jìn)行源代碼級改造(亦可稱為對原分布式系統(tǒng)的侵入)，即在業(yè)務(wù)處理邏輯中耦合進(jìn)調(diào)用鏈路追蹤的處理邏輯，其一方面增加了源代碼進(jìn)行改造升級代價以及后續(xù)的系統(tǒng)維護(hù)代價，另一方面，由于現(xiàn)有的調(diào)用鏈路追蹤方案需要侵入原分布式系統(tǒng)中，影響了原分布式系統(tǒng)業(yè)務(wù)處理的健壯性和可靠性。

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

本發(fā)明實(shí)施例提供一種分布式系統(tǒng)中的調(diào)用請求處理方法及裝置，用以追蹤分布式系統(tǒng)中所執(zhí)行調(diào)用的調(diào)用鏈路，減少分布式系統(tǒng)維護(hù)代價，并提高分布式系統(tǒng)的健壯性和可靠性。

本發(fā)明實(shí)施例提供一種分布式系統(tǒng)中的調(diào)用請求處理方法，包括：

攔截請求方發(fā)起的調(diào)用請求；

獲取攔截到的調(diào)用請求中的鏈路追蹤信息，所述鏈路追蹤信息至少包括全局唯一的調(diào)用鏈路標(biāo)識和在整個調(diào)用鏈路中唯一的序列標(biāo)識，所述序列標(biāo)識用于表示一次調(diào)用在整個調(diào)用鏈路中的次序；

按次序修改獲取到的鏈路追蹤信息中的序列標(biāo)識，將修改后的鏈路追蹤信息作為本次調(diào)用的鏈路追蹤信息存儲回攔截到的調(diào)用請求中，并將更新后的調(diào)用請求發(fā)送給接收方，其中，修改后的鏈路追蹤信息供所述接收方在發(fā)起下次調(diào)用時使用。

本發(fā)明實(shí)施例提供一種分布式系統(tǒng)中的調(diào)用請求處理裝置，包括：

攔截單元，用于攔截請求方發(fā)起的調(diào)用請求；

獲取單元，用于獲取攔截到的調(diào)用請求中的鏈路追蹤信息，所述鏈路追蹤信息至少包括全局唯一的調(diào)用鏈路標(biāo)識和在整個調(diào)用鏈路中唯一的序列標(biāo)識，所述序列標(biāo)識用于表示一次調(diào)用在整個調(diào)用鏈路中的次序；

處理單元，用于按次序修改獲取到的鏈路追蹤信息中的序列標(biāo)識，將修改后的鏈路追蹤信息作為本次調(diào)用的鏈路追蹤信息存儲回攔截到的調(diào)用請求中，并將更新后的調(diào)用請求發(fā)送給接收方，其中，修改后的鏈路追蹤信息供所述接收方在發(fā)起下次調(diào)用時使用。

本發(fā)明實(shí)施例提供的分布式系統(tǒng)中的調(diào)用請求處理方法及裝置，在將請求方發(fā)起的調(diào)用請求發(fā)送給接收方之前攔截該調(diào)用，獲取其中的鏈路追蹤信息，并按次序修改鏈路追蹤信息的序列標(biāo)識，并將修改后的鏈路追蹤信息存儲回調(diào)用請求中發(fā)送給接收方進(jìn)行業(yè)務(wù)邏輯處理，修改后的鏈路追蹤信息供接收方在發(fā)起下次調(diào)用時使用，接收方作為下次調(diào)用的請求方，發(fā)起調(diào)用請求時，該調(diào)用請求同樣被攔截，獲取其中的鏈路追蹤信息，并按次序修改鏈路追蹤信息中的序列標(biāo)識，并將修改后的鏈路追蹤信息存儲回調(diào)用請求中發(fā)送給接收方進(jìn)行業(yè)務(wù)邏輯處理等，依次類推，直至整個調(diào)用鏈路結(jié)束，根據(jù)鏈路追蹤信息中的序列標(biāo)識，能夠追蹤到整條調(diào)用鏈路。另一方面，由于上述過程中，無需對已有的業(yè)務(wù)處理邏輯進(jìn)行修改即可追蹤到整條調(diào)用鏈路，從而能夠減少分布式系統(tǒng)維護(hù)代價，提高了分布式系統(tǒng)的健壯性和可靠性。

本發(fā)明的其它特征和優(yōu)點(diǎn)將在隨后的說明書中闡述，并且，部分地從說明書中變得顯而易見，或者通過實(shí)施本發(fā)明而了解。本發(fā)明的目的和其他優(yōu)點(diǎn)可通過在所寫的說明書、權(quán)利要求書、以及附圖中所特別指出的結(jié)構(gòu)來實(shí)現(xiàn)和獲得。

附圖說明

此處所說明的附圖用來提供對本發(fā)明的進(jìn)一步理解，構(gòu)成本發(fā)明的一部分，本發(fā)明的示意性實(shí)施例及其說明用于解釋本發(fā)明，并不構(gòu)成對本發(fā)明的不當(dāng)限定。在附圖中：

圖1為本發(fā)明實(shí)施例中，調(diào)用請求處理方法的實(shí)施流程示意圖；

圖2為本發(fā)明實(shí)施例中，進(jìn)行流量控制的實(shí)施流程示意圖；

圖3為本發(fā)明實(shí)施例中，調(diào)用請求處理裝置的結(jié)構(gòu)示意圖。

具體實(shí)施方式