[發(fā)明專(zhuān)利]分布式存儲(chǔ)方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201710751085.0
• 申請(qǐng)日: 2017-08-28
• 公開(kāi)（公告）號(hào): CN107707619B
• 公開(kāi)（公告）日: 2020-12-04
• 發(fā)明（設(shè)計(jì)）人: 張旭華
• 申請(qǐng)（專(zhuān)利權(quán)）人: 北京小米移動(dòng)軟件有限公司
• 主分類(lèi)號(hào): H04L29/08
• 分類(lèi)號(hào): H04L29/08;G06F3/06;G06F12/0866
• 代理公司: 北京尚倫律師事務(wù)所 11477
• 代理人: 代治國(guó)

本公開(kāi)是關(guān)于一種分布式存儲(chǔ)方法及裝置。該方法應(yīng)用于分發(fā)中心節(jié)點(diǎn)，所述分發(fā)中心節(jié)點(diǎn)與多個(gè)存儲(chǔ)節(jié)點(diǎn)連接，所述分發(fā)中心節(jié)點(diǎn)設(shè)置有多個(gè)分別與所述多個(gè)存儲(chǔ)節(jié)點(diǎn)對(duì)應(yīng)的緩存區(qū)；所述分布式存儲(chǔ)方法包括：獲取下發(fā)給參考存儲(chǔ)節(jié)點(diǎn)的數(shù)據(jù)，所述參考存儲(chǔ)節(jié)點(diǎn)為所述多個(gè)存儲(chǔ)節(jié)點(diǎn)中的任意一個(gè)；將所述數(shù)據(jù)緩存至所述參考存儲(chǔ)節(jié)點(diǎn)對(duì)應(yīng)的緩存區(qū)。該技術(shù)方案中，分發(fā)中心節(jié)點(diǎn)在向存儲(chǔ)節(jié)點(diǎn)下發(fā)數(shù)據(jù)的同時(shí)可以將這些數(shù)據(jù)進(jìn)行緩存，避免了由于存儲(chǔ)節(jié)點(diǎn)失效數(shù)據(jù)無(wú)法寫(xiě)入造成的數(shù)據(jù)丟失，提高了數(shù)據(jù)存儲(chǔ)的可靠性。

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

本公開(kāi)涉及信息存儲(chǔ)技術(shù)領(lǐng)域，尤其涉及一種分布式存儲(chǔ)方法及裝置。

背景技術(shù)

隨著云計(jì)算和大數(shù)據(jù)技術(shù)的發(fā)展，傳統(tǒng)的單一存儲(chǔ)介質(zhì)的數(shù)據(jù)存儲(chǔ)方式已經(jīng)不能滿(mǎn)足大數(shù)據(jù)處理的需求，在這樣的背景下，分布式存儲(chǔ)系統(tǒng)得到了廣泛的應(yīng)用。

分布式存儲(chǔ)系統(tǒng)由分發(fā)中心節(jié)點(diǎn)和若干存儲(chǔ)節(jié)點(diǎn)互相連接構(gòu)成，與傳統(tǒng)的存儲(chǔ)設(shè)備相比，分布式存儲(chǔ)系統(tǒng)能夠通過(guò)分發(fā)中心節(jié)點(diǎn)將數(shù)據(jù)池中的數(shù)據(jù)按照不同策略分布到不同的存儲(chǔ)節(jié)點(diǎn)上，并在多個(gè)存儲(chǔ)節(jié)點(diǎn)之間實(shí)現(xiàn)負(fù)載均衡。

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

為克服相關(guān)技術(shù)中存在的問(wèn)題，本公開(kāi)實(shí)施例提供一種分布式存儲(chǔ)方法及裝置。所述技術(shù)方案如下：

根據(jù)本公開(kāi)實(shí)施例的第一方面，提供一種分布式存儲(chǔ)方法，應(yīng)用于分發(fā)中心節(jié)點(diǎn)，所述分發(fā)中心節(jié)點(diǎn)與多個(gè)存儲(chǔ)節(jié)點(diǎn)連接，所述分發(fā)中心節(jié)點(diǎn)設(shè)置有多個(gè)分別與所述多個(gè)存儲(chǔ)節(jié)點(diǎn)對(duì)應(yīng)的緩存區(qū)；所述分布式存儲(chǔ)方法包括：

獲取下發(fā)給參考存儲(chǔ)節(jié)點(diǎn)的數(shù)據(jù)，所述參考存儲(chǔ)節(jié)點(diǎn)為所述多個(gè)存儲(chǔ)節(jié)點(diǎn)中的任意一個(gè)；

將所述數(shù)據(jù)緩存至所述參考存儲(chǔ)節(jié)點(diǎn)對(duì)應(yīng)的緩存區(qū)。

本公開(kāi)的實(shí)施例提供的技術(shù)方案可以包括以下有益效果：分發(fā)中心節(jié)點(diǎn)在向存儲(chǔ)節(jié)點(diǎn)下發(fā)數(shù)據(jù)的同時(shí)可以將這些數(shù)據(jù)進(jìn)行緩存，避免了由于存儲(chǔ)節(jié)點(diǎn)失效數(shù)據(jù)無(wú)法寫(xiě)入造成的數(shù)據(jù)丟失，提高了數(shù)據(jù)存儲(chǔ)的可靠性。

在一個(gè)實(shí)施例中，所述方法還包括：

接收所述參考存儲(chǔ)節(jié)點(diǎn)發(fā)送的清空緩存指令，所述清空緩存指令指示清空所述參考存儲(chǔ)節(jié)點(diǎn)對(duì)應(yīng)的緩存區(qū)中的數(shù)據(jù)；

根據(jù)所述清空緩存指令，將所述緩存區(qū)中的數(shù)據(jù)清空。

在一個(gè)實(shí)施例中，所述方法還包括：

確定從上一次清空所述緩存區(qū)開(kāi)始的第一預(yù)設(shè)時(shí)間段內(nèi)是否接收到所述清空緩存指令；

若從上一次清空所述緩存區(qū)開(kāi)始的第一預(yù)設(shè)時(shí)間段內(nèi)未接收到所述清空緩存指令，將所述緩存區(qū)在所述第一預(yù)設(shè)時(shí)間段內(nèi)緩存的數(shù)據(jù)發(fā)送給備用存儲(chǔ)節(jié)點(diǎn)。

在一個(gè)實(shí)施例中，所述清空緩存指令包括結(jié)束數(shù)據(jù)標(biāo)志位，所述結(jié)束數(shù)據(jù)標(biāo)志位指示所述參考存儲(chǔ)節(jié)點(diǎn)中已存儲(chǔ)數(shù)據(jù)的結(jié)束標(biāo)志位；

所述根據(jù)所述清空緩存指令，將所述緩存區(qū)中的數(shù)據(jù)清空包括：

根據(jù)所述結(jié)束數(shù)據(jù)標(biāo)志位，確定所述參考存儲(chǔ)節(jié)點(diǎn)中存儲(chǔ)的數(shù)據(jù)與所述緩存區(qū)中緩存的數(shù)據(jù)是否匹配；

若所述參考存儲(chǔ)節(jié)點(diǎn)中存儲(chǔ)的數(shù)據(jù)與所述緩存區(qū)中緩存的數(shù)據(jù)匹配，將所述緩存區(qū)中的數(shù)據(jù)清空；

若所述參考存儲(chǔ)節(jié)點(diǎn)中存儲(chǔ)的數(shù)據(jù)與所述緩存區(qū)中緩存的數(shù)據(jù)不匹配，將所述緩存區(qū)中的數(shù)據(jù)重新發(fā)送給所述參考存儲(chǔ)節(jié)點(diǎn)。

在一個(gè)實(shí)施例中，所述清空緩存指令還包括時(shí)間戳，所述時(shí)間戳為所述參考存儲(chǔ)節(jié)點(diǎn)發(fā)送所述清空緩存指令的時(shí)間；所述方法還包括：

根據(jù)所述清空緩存指令包括的時(shí)間戳，確定所述清空緩存指令是否為有效指令；

所述根據(jù)所述結(jié)束數(shù)據(jù)標(biāo)志位，確定所述參考存儲(chǔ)節(jié)點(diǎn)中存儲(chǔ)的數(shù)據(jù)與所述緩存區(qū)中緩存的數(shù)據(jù)是否匹配包括：