[發(fā)明專利]數(shù)據(jù)讀取方法、裝置、分布式存儲系統(tǒng)、設(shè)備和存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202310495399.4
• 申請日: 2023-05-05
• 公開（公告）號: CN116540938A
• 公開（公告）日: 2023-08-04
• 發(fā)明（設(shè)計(jì)）人: 李國強(qiáng);劉濤
• 申請（專利權(quán)）人: 百度在線網(wǎng)絡(luò)技術(shù)（北京）有限公司
• 主分類號: G06F3/06
• 分類號: G06F3/06;G06F16/2458;G06F16/27
• 代理公司: 北京鴻德海業(yè)知識產(chǎn)權(quán)代理有限公司 11412
• 代理人: 岳鳳羽

1.一種數(shù)據(jù)讀取方法，應(yīng)用于分布式存儲系統(tǒng)內(nèi)多個從節(jié)點(diǎn)中的任一從節(jié)點(diǎn)，所述方法包括：

響應(yīng)于客戶端發(fā)送的讀請求，獲取所述多個從節(jié)點(diǎn)中各個從節(jié)點(diǎn)存儲的候選數(shù)據(jù)的局部最新版本號；

基于所述局部最新版本號，確定全局最新版本號；

基于所述全局最新版本號確定目標(biāo)數(shù)據(jù)，并將所述目標(biāo)數(shù)據(jù)發(fā)送至所述客戶端。

2.根據(jù)權(quán)利要求1所述的方法，其中，所述響應(yīng)于客戶端發(fā)送的讀請求，獲取所述多個從節(jié)點(diǎn)中各個從節(jié)點(diǎn)存儲的候選數(shù)據(jù)的局部最新版本號，包括：

響應(yīng)于客戶端發(fā)送的讀請求，向自身從節(jié)點(diǎn)之外的其他從節(jié)點(diǎn)發(fā)送廣播消息，所述廣播消息用于查詢所述其他從節(jié)點(diǎn)上的所述局部最新版本號；

接收所述其他從節(jié)點(diǎn)發(fā)送的響應(yīng)消息，所述響應(yīng)消息中包含所述其他從節(jié)點(diǎn)上的所述局部最新版本號；

從所述響應(yīng)消息中獲取所述其他從節(jié)點(diǎn)上的所述局部最新版本號，以及獲取自身從節(jié)點(diǎn)上的所述局部最新版本號。

3.根據(jù)權(quán)利要求1所述的方法，其中，所述局部最新版本號是所述候選數(shù)據(jù)的版本號中的最大值，所述基于所述局部最新版本號，確定全局最新版本號，包括：

將最大的局部最新版本號，作為所述全局最新版本號。

4.根據(jù)權(quán)利要求1-3任一項(xiàng)所述的方法，其中，所述基于所述全局最新版本號確定目標(biāo)數(shù)據(jù)，并將所述目標(biāo)數(shù)據(jù)發(fā)送至所述客戶端，包括：

若自身從節(jié)點(diǎn)存儲的候選數(shù)據(jù)的局部最新版本號大于或等于所述全局最新版本號，將所述自身從節(jié)點(diǎn)上存儲的候選數(shù)據(jù)作為所述目標(biāo)數(shù)據(jù)；

將所述目標(biāo)數(shù)據(jù)發(fā)送至所述客戶端。

5.根據(jù)權(quán)利要求1-3任一項(xiàng)所述的方法，其中，所述基于所述全局最新版本號確定目標(biāo)數(shù)據(jù)，并將所述目標(biāo)數(shù)據(jù)發(fā)送至所述客戶端，包括：

若自身從節(jié)點(diǎn)存儲的候選數(shù)據(jù)的局部最新版本號大于或等于所述全局最新版本號，且預(yù)設(shè)時長內(nèi)獲取到版本號大于或等于所述全局最新版本號的更新數(shù)據(jù)，將所述更新數(shù)據(jù)作為所述目標(biāo)數(shù)據(jù)；

將所述目標(biāo)數(shù)據(jù)發(fā)送至所述客戶端。

6.根據(jù)權(quán)利要求5所述的方法，還包括：

若自身從節(jié)點(diǎn)存儲的候選數(shù)據(jù)的局部最新版本號大于或等于所述全局最新版本號，且預(yù)設(shè)時長內(nèi)未獲取到版本號大于或等于所述全局最新版本號的更新數(shù)據(jù)，向所述客戶端反饋第一讀響應(yīng)，所述第一讀響應(yīng)表明讀取失敗；或者，

若自身從節(jié)點(diǎn)存儲的候選數(shù)據(jù)的局部最新版本號大于或等于所述全局最新版本號，且預(yù)設(shè)時長內(nèi)未獲取到版本號大于或等于所述全局最新版本號的更新數(shù)據(jù)，向所述客戶端反饋第二讀響應(yīng)，所述第二讀響應(yīng)中包含目標(biāo)從節(jié)點(diǎn)的信息，所述目標(biāo)從節(jié)點(diǎn)是局部最新版本號大于或等于所述全局最新版本號的從節(jié)點(diǎn)，以使所述客戶端向所述目標(biāo)從節(jié)點(diǎn)重新發(fā)送讀請求。

7.一種數(shù)據(jù)讀取裝置，應(yīng)用于分布式存儲系統(tǒng)內(nèi)多個從節(jié)點(diǎn)中的任一從節(jié)點(diǎn)，所述裝置包括：

獲取模塊，用于響應(yīng)于客戶端發(fā)送的讀請求，獲取所述多個從節(jié)點(diǎn)中各個從節(jié)點(diǎn)存儲的候選數(shù)據(jù)的局部最新版本號；

確定模塊，用于基于所述局部最新版本號，確定全局最新版本號；

發(fā)送模塊，用于基于所述全局最新版本號確定目標(biāo)數(shù)據(jù)，并將所述目標(biāo)數(shù)據(jù)發(fā)送至所述客戶端。

8.根據(jù)權(quán)利要求7所述的裝置，其中，所述獲取模塊進(jìn)一步用于：

響應(yīng)于客戶端發(fā)送的讀請求，向自身從節(jié)點(diǎn)之外的其他從節(jié)點(diǎn)發(fā)送廣播消息，所述廣播消息用于查詢所述其他從節(jié)點(diǎn)上的所述局部最新版本號；

接收所述其他從節(jié)點(diǎn)發(fā)送的響應(yīng)消息，所述響應(yīng)消息中包含所述其他從節(jié)點(diǎn)上的所述局部最新版本號；

從所述響應(yīng)消息中獲取所述其他從節(jié)點(diǎn)上的所述局部最新版本號，以及獲取自身從節(jié)點(diǎn)上的所述局部最新版本號。

9.根據(jù)權(quán)利要求7所述的裝置，其中，所述局部最新版本號是所述候選數(shù)據(jù)的版本號中的最大值，所述確定模塊進(jìn)一步用于：

將最大的局部最新版本號，作為所述全局最新版本號。