[發(fā)明專利]分布式系統(tǒng)中的數(shù)據(jù)寫方法、服務(wù)器及客戶端

有效

• 申請?zhí)枺?/td>: 201910136605.6
• 申請日: 2019-02-25
• 公開（公告）號: CN111611068B
• 公開（公告）日: 2022-07-15
• 發(fā)明（設(shè)計）人: 汪東升;王占業(yè)
• 申請（專利權(quán)）人: 清華大學
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京路浩知識產(chǎn)權(quán)代理有限公司 11002
• 代理人: 王瑩;李相雨

1.一種分布式系統(tǒng)中的數(shù)據(jù)寫方法，其特征在于，包括：

在預(yù)設(shè)等待時間周期內(nèi)，待寫數(shù)據(jù)的主副本所在計算機節(jié)點接收客戶端以預(yù)先獲取的速度發(fā)送的待寫數(shù)據(jù)的寫請求，并將各所述寫請求放入等待隊列中；其中，將所述待寫數(shù)據(jù)的任一副本作為所述待寫數(shù)據(jù)的主副本；

經(jīng)過所述預(yù)設(shè)等待時間周期后，所述主副本所在計算機節(jié)點基于兩階段提交協(xié)議將所述等待隊列中的寫請求批量完成，并根據(jù)所述主副本所在計算機節(jié)點處理各所述寫請求時的性能狀態(tài)，判斷所述主副本所在計算機節(jié)點是否已達到性能瓶頸；

將各所述寫請求對應(yīng)的判斷結(jié)果發(fā)送給所述客戶端，以供所述客戶端根據(jù)各所述寫請求對應(yīng)的判斷結(jié)果調(diào)整所述速度，以最近調(diào)整的所述速度向所述主副本所在計算機節(jié)點發(fā)送寫請求；

所述主副本所在計算機節(jié)點基于兩階段提交協(xié)議將所述等待隊列中的寫請求批量完成的步驟具體包括：

所述主副本所在計算機節(jié)點將所述等待隊列中的各寫請求發(fā)送到待寫數(shù)據(jù)的所有從副本所在計算機節(jié)點，以供所有所述從副本所在計算機節(jié)點根據(jù)各所述寫請求執(zhí)行寫操作；其中，將所述待寫數(shù)據(jù)的副本中除所述主副本以外的副本作為所述待寫數(shù)據(jù)的從副本；

所述主副本所在計算機節(jié)點根據(jù)所有所述從副本所在計算機節(jié)點返回的各所述寫請求的寫操作結(jié)果確定各所述寫請求的最終寫操作結(jié)果，并將各所述寫請求的最終寫操作結(jié)果發(fā)送給所述客戶端。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，根據(jù)所述主副本所在計算機節(jié)點處理各所述寫請求時的性能狀態(tài)，判斷所述主副本所在計算機節(jié)點是否已達到性能瓶頸的步驟具體包括：

若所述主副本所在計算機節(jié)點的CPU利用率大于第一預(yù)設(shè)閾值、所述主副本所在計算機節(jié)點的內(nèi)存利用率大于第二預(yù)設(shè)閾值，或者所述主副本所在計算機節(jié)點的磁盤I/O速度小于第三預(yù)設(shè)閾值，則獲知所述主副本所在計算機節(jié)點已達到性能瓶頸；

否則，獲知所述主副本所在計算機節(jié)點未達到性能瓶頸。

3.一種分布式系統(tǒng)中的數(shù)據(jù)寫方法，其特征在于，包括：

按照預(yù)先獲取的速度將待寫數(shù)據(jù)的寫請求發(fā)送到待寫數(shù)據(jù)的主副本所在計算機節(jié)點；其中，將所述待寫數(shù)據(jù)的任一副本作為所述待寫數(shù)據(jù)的主副本；

接收所述主副本所在計算機節(jié)點返回的各所述寫請求對應(yīng)的判斷結(jié)果，根據(jù)各所述寫請求對應(yīng)的判斷結(jié)果調(diào)整所述速度；其中，所述判斷結(jié)果為所述主副本所在計算機節(jié)點在處理各所述寫請求時已達到性能瓶頸或未達到性能瓶頸，所述判斷結(jié)果根據(jù)所述主副本所在計算機節(jié)點處理各所述寫請求時的性能狀態(tài)獲取；

按照最近調(diào)整的所述速度向所述主副本所在計算機節(jié)點發(fā)送寫請求；

根據(jù)各所述寫請求對應(yīng)的判斷結(jié)果調(diào)整所述速度的步驟具體包括：

若當前接收的判斷結(jié)果為已達到性能瓶頸，則將上次調(diào)整后的速度調(diào)低。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，通過以下公式將上次調(diào)整后的速度調(diào)低：

S'＝S*(1-e^-M)；

其中，S為上次調(diào)整后的所述速度，S'為本次調(diào)整后的所述速度，M為第一預(yù)設(shè)常數(shù)。

5.根據(jù)權(quán)利要求3所述的方法，其特征在于，根據(jù)所述判斷結(jié)果調(diào)整所述速度的步驟還包括：

若當前接收的判斷結(jié)果為未達到性能瓶頸，且緊鄰當前接收的判斷結(jié)果之前，包括當前接收的判斷結(jié)果連續(xù)Q個判斷結(jié)果均為未達到性能瓶頸，則將上次調(diào)整后的速度調(diào)高；其中，Q為預(yù)設(shè)個數(shù)的倍數(shù)。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，通過以下公式將上次調(diào)整后的所述速度調(diào)高：

S'＝S*(1+e^-N)；

其中，S為上次調(diào)整后的所述速度，S'為本次調(diào)整后的所述速度，N為第二預(yù)設(shè)常數(shù)。