[發(fā)明專利]數(shù)據(jù)同步方法、裝置、設(shè)備及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011164017.2
• 申請日: 2020-10-27
• 公開（公告）號: CN112307119A
• 公開（公告）日: 2021-02-02
• 發(fā)明（設(shè)計）人: 曹狄
• 申請（專利權(quán)）人: 廣州市網(wǎng)星信息技術(shù)有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/23;G06F16/17
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種數(shù)據(jù)同步方法，其特征在于，應(yīng)用于跨機房系統(tǒng)中第一機房內(nèi)的第一主機，所述方法包括：

接收客戶端發(fā)送的針對第一數(shù)據(jù)條目的第一更新請求；

將所述第一更新請求分配至第一緩存隊列中，其中，所述第一緩存隊列中的項目供對應(yīng)的第一線程進(jìn)行消費，在當(dāng)前項目為更新請求時，由所述第一線程將當(dāng)前項目對應(yīng)的待更新數(shù)據(jù)更新至所述第一主機的第一緩存和第一數(shù)據(jù)庫，在當(dāng)前項目為同步請求時，由所述第一線程將當(dāng)前項目對應(yīng)的待同步數(shù)據(jù)更新至所述第一緩存；

對所述第一數(shù)據(jù)庫中的日志文件進(jìn)行解析，在得到所述第一數(shù)據(jù)條目的第一同步請求時，將所述第一同步請求分配至所述第一緩存隊列中，其中，所述第一同步請求由所述跨機房系統(tǒng)中的第二機房內(nèi)的第二數(shù)據(jù)庫發(fā)送，所述第一數(shù)據(jù)庫在接收到所述第一同步請求后，根據(jù)所述第一同步請求對本地的第一數(shù)據(jù)條目進(jìn)行更新，并將所述第一同步請求寫入所述日志文件。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述將所述第一更新請求分配至第一緩存隊列中之后，還包括：

在所述第一線程將所述第一更新請求對應(yīng)的數(shù)據(jù)更新至所述第一數(shù)據(jù)庫后，通過所述第一數(shù)據(jù)庫向所述跨機房系統(tǒng)中的第三機房內(nèi)的第三數(shù)據(jù)庫發(fā)送與本次更新操作對應(yīng)的第二同步請求。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述在將所述第一更新請求分配至第一緩存隊列中之前，還包括：

根據(jù)所述第一數(shù)據(jù)條目對應(yīng)的第一身份標(biāo)識確定對應(yīng)的第一緩存隊列。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述根據(jù)所述第一數(shù)據(jù)條目對應(yīng)的第一身份標(biāo)識確定對應(yīng)的第一緩存隊列，包括：

基于預(yù)設(shè)哈希算法確定所述第一數(shù)據(jù)條目對應(yīng)的第一身份標(biāo)識的第一哈希值；

根據(jù)所述第一哈希值確定對應(yīng)的第一緩存隊列。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述第一機房內(nèi)還存在所述第一主機對應(yīng)的第一從機，所述第一主機和所述第一從機之間進(jìn)行主從備份；

在通過進(jìn)程對緩存隊列中的第三同步請求消費成功后，向所述第一機房反饋所述第三同步請求在所述日志文件中的偏移量，供所述第一從機根據(jù)所述偏移量繼續(xù)解析所述日志文件。

6.根據(jù)權(quán)利要求1-5任一所述的方法，其特征在于，還包括：

接收客戶端發(fā)送的針對第二數(shù)據(jù)條目的第一讀取請求；

若所述第一緩存中不包含所述第二數(shù)據(jù)條目，則將所述第一讀取請求分配至第二緩存隊列中，其中，所述第二緩存隊列中的項目供對應(yīng)的第二線程進(jìn)行消費，在當(dāng)前項目為讀取請求時，由所述第二線程從所述第一數(shù)據(jù)庫中讀取所述第二數(shù)據(jù)條目對應(yīng)的數(shù)據(jù)并將所讀取到的數(shù)據(jù)寫入所述第一緩存中；

在檢測到針對所述第二數(shù)據(jù)條目的第一寫請求時，將所述第一寫請求分配至所述第二緩存隊列中的所述第一讀取請求的后面，其中，所述第一寫請求包括更新請求和/或同步請求，所述第二線程在從所述第一數(shù)據(jù)庫中讀取所述第二數(shù)據(jù)條目對應(yīng)的數(shù)據(jù)并將所讀取到的數(shù)據(jù)寫入所述第一緩存中之后，對所述第一寫請求進(jìn)行消費。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，在所述接收客戶端發(fā)送的針對第二數(shù)據(jù)條目的第一讀取請求之后，還包括：

若所述第一緩存中包含所述第二數(shù)據(jù)條目，則將所述第一緩存中存儲的所述第二數(shù)據(jù)條目對應(yīng)的數(shù)據(jù)返回至所述客戶端。

8.一種數(shù)據(jù)同步方法，其特征在于，包括：

接收第一客戶端發(fā)送的針對第一數(shù)據(jù)條目的讀取請求；

若緩存中不包含所述第一數(shù)據(jù)條目，則將所述讀取請求分配至第一緩存隊列中，其中，所述第一緩存隊列中的項目供對應(yīng)的第一線程進(jìn)行消費，在當(dāng)前項目為讀取請求時，由所述第一線程從對應(yīng)的數(shù)據(jù)庫中讀取所述第一數(shù)據(jù)條目對應(yīng)的數(shù)據(jù)并將所讀取到的數(shù)據(jù)寫入所述緩存中；

在接收到第二客戶端發(fā)送的針對所述第一數(shù)據(jù)條目的更新請求時，將所述更新請求分配至所述第一緩存隊列中的所述讀取請求的后面，其中，所述第一線程在從對應(yīng)的數(shù)據(jù)庫中讀取所述第一數(shù)據(jù)條目對應(yīng)的數(shù)據(jù)并將所讀取到的數(shù)據(jù)寫入所述緩存中之后，對所述更新請求進(jìn)行消費。