[發(fā)明專利]一種數(shù)據(jù)讀寫處理方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202210174003.1
• 申請(qǐng)日: 2022-02-24
• 公開（公告）號(hào): CN114594907A
• 公開（公告）日: 2022-06-07
• 發(fā)明（設(shè)計(jì)）人: 胡嘯飛;陳培虎
• 申請(qǐng)（專利權(quán)）人: 百果園技術(shù)（新加坡）有限公司
• 主分類號(hào): G06F3/06
• 分類號(hào): G06F3/06
• 代理公司: 北京澤方譽(yù)航專利代理事務(wù)所(普通合伙) 11884
• 代理人: 唐明磊

本申請(qǐng)?zhí)峁┝艘环N數(shù)據(jù)讀寫處理方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)。本申請(qǐng)?zhí)峁┑募夹g(shù)方案，包括：在數(shù)據(jù)寫入階段，通過主設(shè)備在將數(shù)據(jù)寫入主數(shù)據(jù)庫時(shí)為數(shù)據(jù)分配對(duì)應(yīng)的序列號(hào)，并將該數(shù)據(jù)和對(duì)應(yīng)的序列號(hào)同步至從設(shè)備。從設(shè)備將新增數(shù)據(jù)和對(duì)應(yīng)的序列號(hào)寫入從數(shù)據(jù)庫中，并將新增數(shù)據(jù)對(duì)應(yīng)的序列號(hào)設(shè)置為從數(shù)據(jù)庫保存的序列號(hào)信息。在數(shù)據(jù)讀取階段，通過從設(shè)備根據(jù)數(shù)據(jù)的序列號(hào)和從數(shù)據(jù)庫的序列號(hào)信息，確定從數(shù)據(jù)庫中是否存儲(chǔ)有該數(shù)據(jù)。如果從數(shù)據(jù)庫中存儲(chǔ)有該數(shù)據(jù)，則從設(shè)備從從數(shù)據(jù)庫中讀取該數(shù)據(jù)；如果從數(shù)據(jù)庫中未存儲(chǔ)有該數(shù)據(jù)，則從主數(shù)據(jù)庫中讀取該數(shù)據(jù)。通過上述技術(shù)方案，以解決相關(guān)技術(shù)中數(shù)據(jù)讀寫不一致導(dǎo)致數(shù)據(jù)讀取異常的問題，提高數(shù)據(jù)讀取效率。

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

本申請(qǐng)涉及計(jì)算機(jī)技術(shù)領(lǐng)域，尤其涉及一種數(shù)據(jù)讀寫處理方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)。

背景技術(shù)

隨著數(shù)據(jù)量的急劇增多，數(shù)據(jù)庫的讀寫壓力隨之增大。為分?jǐn)倲?shù)據(jù)庫的讀寫壓力，使用主從數(shù)據(jù)存儲(chǔ)模式實(shí)現(xiàn)數(shù)據(jù)的讀寫分離。主從數(shù)據(jù)存儲(chǔ)模式設(shè)置有一個(gè)主數(shù)據(jù)庫和多個(gè)從數(shù)據(jù)庫，數(shù)據(jù)優(yōu)先寫入主數(shù)據(jù)庫中，然后將主數(shù)據(jù)庫存儲(chǔ)的數(shù)據(jù)同步至從數(shù)據(jù)庫，以便從從數(shù)據(jù)庫中讀取數(shù)據(jù)。由于從數(shù)據(jù)庫設(shè)置有多個(gè)，可以并發(fā)多個(gè)從數(shù)據(jù)庫，提高數(shù)據(jù)讀取效率且降低數(shù)據(jù)庫負(fù)載。

現(xiàn)有從數(shù)據(jù)庫和主數(shù)據(jù)庫可以跨機(jī)房設(shè)置，即主數(shù)據(jù)庫和從數(shù)據(jù)庫設(shè)置在不同機(jī)房的服務(wù)器下。在跨機(jī)房場(chǎng)景下，不同機(jī)房設(shè)置對(duì)應(yīng)的從數(shù)據(jù)庫，通過從數(shù)據(jù)庫保證每一機(jī)房數(shù)據(jù)讀取的低延遲。但基于不同機(jī)房之間的網(wǎng)絡(luò)延遲等因素，主數(shù)據(jù)庫新寫入的數(shù)據(jù)難以實(shí)時(shí)同步至從數(shù)據(jù)庫，無法保證數(shù)據(jù)讀寫的一致性，使得從從數(shù)據(jù)庫中不能讀取到該數(shù)據(jù)，造成數(shù)據(jù)讀取異常，降低數(shù)據(jù)讀取效率。

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

本申請(qǐng)?zhí)峁┮环N數(shù)據(jù)讀寫處理方法、裝置、設(shè)備及存儲(chǔ)介質(zhì)，以解決相關(guān)技術(shù)中數(shù)據(jù)讀寫不一致導(dǎo)致數(shù)據(jù)讀取異常的問題，提高數(shù)據(jù)讀取效率。

第一方面，本申請(qǐng)?zhí)峁┝艘环N數(shù)據(jù)讀寫處理方法，包括：

在主數(shù)據(jù)庫進(jìn)行新增數(shù)據(jù)的寫入時(shí)，對(duì)所述新增數(shù)據(jù)分配對(duì)應(yīng)的序列號(hào)；

將所述新增數(shù)據(jù)以及對(duì)應(yīng)的序列號(hào)寫入至所述主數(shù)據(jù)庫中；

通過寫擴(kuò)散方式將所述新增數(shù)據(jù)以及對(duì)應(yīng)的序列號(hào)同步至從設(shè)備，以使所述從設(shè)備將所述新增數(shù)據(jù)以及對(duì)應(yīng)的序列號(hào)寫入從數(shù)據(jù)庫。

第二方面，本申請(qǐng)?zhí)峁┝艘环N數(shù)據(jù)讀寫處理方法，包括：

接收主設(shè)備發(fā)送的新增數(shù)據(jù)以及對(duì)應(yīng)的序列號(hào)，所述序列號(hào)為所述主設(shè)備在進(jìn)行所述新增數(shù)據(jù)的寫入時(shí)，對(duì)所述新增數(shù)據(jù)進(jìn)行分配得到；

將所述新增數(shù)據(jù)以及對(duì)應(yīng)的序列號(hào)寫入從數(shù)據(jù)庫，基于所述序列號(hào)對(duì)保存的序列號(hào)信息進(jìn)行調(diào)整，所述序列號(hào)信息用于確定數(shù)據(jù)請(qǐng)求端請(qǐng)求讀取的數(shù)據(jù)是否存儲(chǔ)在所述從數(shù)據(jù)庫中。

第三方面，本申請(qǐng)?zhí)峁┝艘环N數(shù)據(jù)讀寫處理方法，包括：

接收數(shù)據(jù)請(qǐng)求端發(fā)送的數(shù)據(jù)讀取請(qǐng)求，所述數(shù)據(jù)讀取請(qǐng)求包括待讀取數(shù)據(jù)的序列號(hào)，所述待讀取數(shù)據(jù)的序列號(hào)由主設(shè)備在進(jìn)行所述待讀取數(shù)據(jù)對(duì)應(yīng)的新增數(shù)據(jù)的寫入時(shí)分配得到；

將所述待讀取數(shù)據(jù)的序列號(hào)與從數(shù)據(jù)庫中記錄的序列號(hào)信息進(jìn)行比較，確定所述從數(shù)據(jù)庫中是否存儲(chǔ)有所述待讀取數(shù)據(jù)，所述序列號(hào)信息基于和所述主設(shè)備進(jìn)行信息同步時(shí)得到；

響應(yīng)于所述從數(shù)據(jù)庫中存儲(chǔ)有所述待讀取數(shù)據(jù)的判斷結(jié)果，從所述從數(shù)據(jù)庫中讀取所述待讀取數(shù)據(jù)，并將所述待讀取數(shù)據(jù)發(fā)送至所述數(shù)據(jù)請(qǐng)求端。

第四方面，本申請(qǐng)?zhí)峁┝艘环N數(shù)據(jù)讀寫處理方法，包括：

接收從設(shè)備發(fā)送的數(shù)據(jù)讀取請(qǐng)求，所述數(shù)據(jù)讀取請(qǐng)求包括待讀取數(shù)據(jù)的序列號(hào)，所述待讀取數(shù)據(jù)的序列號(hào)由主設(shè)備在進(jìn)行所述待讀取數(shù)據(jù)對(duì)應(yīng)的新增數(shù)據(jù)的寫入時(shí)分配得到；

根據(jù)所述待讀取數(shù)據(jù)的序列號(hào)，從主數(shù)據(jù)庫中獲取對(duì)應(yīng)的待讀取數(shù)據(jù)；