[發(fā)明專利]緩存數(shù)據(jù)讀寫方法、系統(tǒng)、電子設(shè)備及計(jì)算機(jī)可讀介質(zhì)

有效

• 申請(qǐng)?zhí)枺?/td>: 201610515151.X
• 申請(qǐng)日: 2016-07-01
• 公開（公告）號(hào): CN107566434B
• 公開（公告）日: 2022-01-07
• 發(fā)明（設(shè)計(jì)）人: 陳福洪
• 申請(qǐng)（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): H04L67/1097
• 分類號(hào): H04L67/1097;G06F3/06
• 代理公司: 中科專利商標(biāo)代理有限責(zé)任公司 11021
• 代理人: 任巖

本發(fā)明提供一種分布式系統(tǒng)中緩存數(shù)據(jù)讀寫方法及系統(tǒng)，方法對(duì)于分布式系統(tǒng)中的任意一個(gè)節(jié)點(diǎn)，設(shè)定該節(jié)點(diǎn)的數(shù)據(jù)清空時(shí)刻，當(dāng)該節(jié)點(diǎn)收到一請(qǐng)求時(shí)，判斷是否到達(dá)該數(shù)據(jù)清空時(shí)刻，如果是，則對(duì)該節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行清空，然后再次設(shè)定該節(jié)點(diǎn)的數(shù)據(jù)清空時(shí)刻，否則，根據(jù)請(qǐng)求對(duì)節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行讀寫。本發(fā)明保證各節(jié)點(diǎn)中的數(shù)據(jù)能定時(shí)地保持一致性，從而令分布式系統(tǒng)能夠輕松使用緩存數(shù)據(jù)來提高源利用率與系統(tǒng)響應(yīng)性能。

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

本發(fā)明屬于計(jì)算機(jī)技術(shù)領(lǐng)域，尤其涉及一種分布式系統(tǒng)中緩存數(shù)據(jù)讀寫方法及系統(tǒng)。

背景技術(shù)

當(dāng)分布式的業(yè)務(wù)系統(tǒng)在面臨大規(guī)模流量沖擊時(shí)，分布式系統(tǒng)一般會(huì)對(duì)熱點(diǎn)數(shù)據(jù)進(jìn)行緩存，提高響應(yīng)效率。但是在分布式系統(tǒng)下本地緩存會(huì)存在由于數(shù)據(jù)更新而無法及時(shí)同步，導(dǎo)致數(shù)據(jù)差異影響業(yè)務(wù)性能。另外，大部分分布式系統(tǒng)還會(huì)選擇犧牲部分性能采用集中式的緩存插件(如：redis)來解決運(yùn)行效率與數(shù)據(jù)一致性問題，這在高并發(fā)請(qǐng)求下對(duì)集中緩存壓力較大，并且存在網(wǎng)絡(luò)消耗、性能受影響。

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

(一)要解決的技術(shù)問題

本發(fā)明的目的在于，提供一種分布式系統(tǒng)中緩存數(shù)據(jù)讀寫方法及系統(tǒng)，使得分布式系統(tǒng)中的各節(jié)點(diǎn)在讀寫緩存數(shù)據(jù)時(shí)能保持?jǐn)?shù)據(jù)一致性，從而令分布式系統(tǒng)能夠輕松使用緩存數(shù)據(jù)來提高源利用率與系統(tǒng)響應(yīng)性能。

(二)技術(shù)方案

本發(fā)明一方面提供一種分布式系統(tǒng)中緩存數(shù)據(jù)讀寫方法，用于對(duì)分布式系統(tǒng)中各個(gè)節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行讀寫，對(duì)于分布式系統(tǒng)中的任意一個(gè)節(jié)點(diǎn)，方法包括：

S1，設(shè)定節(jié)點(diǎn)的數(shù)據(jù)清空時(shí)刻；

S2，當(dāng)節(jié)點(diǎn)收到一請(qǐng)求時(shí)，判斷是否到達(dá)數(shù)據(jù)清空時(shí)刻，如果是，則對(duì)該節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行清空，然后重新設(shè)定該節(jié)點(diǎn)的數(shù)據(jù)清空時(shí)刻，否則，根據(jù)請(qǐng)求對(duì)節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行讀寫。

進(jìn)一步，步驟S2中，對(duì)該節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行清空之后，若該請(qǐng)求為讀請(qǐng)求，則向請(qǐng)求發(fā)送方返回空值，若該請(qǐng)求為寫請(qǐng)求，則向該節(jié)點(diǎn)中寫入相應(yīng)的數(shù)據(jù)，然后重新設(shè)定該節(jié)點(diǎn)的數(shù)據(jù)清空時(shí)刻。

進(jìn)一步，步驟S2中，對(duì)該節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行清空之后，若該請(qǐng)求為讀請(qǐng)求，則向請(qǐng)求發(fā)送方返回空值，并從外部獲取該讀請(qǐng)求所對(duì)應(yīng)的數(shù)據(jù)，并作為緩存數(shù)據(jù)存儲(chǔ)。

進(jìn)一步，步驟S2中，從外部獲取該讀請(qǐng)求所對(duì)應(yīng)的數(shù)據(jù)，包括：從遠(yuǎn)程數(shù)據(jù)庫、緩存插件、本地磁盤中的一者中獲取該讀請(qǐng)求所對(duì)應(yīng)的數(shù)據(jù)。

進(jìn)一步，步驟S2中，判斷是否到達(dá)數(shù)據(jù)清空時(shí)刻，包括：獲取該節(jié)點(diǎn)的系統(tǒng)當(dāng)前時(shí)刻，若系統(tǒng)當(dāng)前時(shí)刻大于等于數(shù)據(jù)清空時(shí)刻，則判定到達(dá)數(shù)據(jù)清空時(shí)刻，否則判定未到達(dá)數(shù)據(jù)清空時(shí)刻。

進(jìn)一步，在步驟S1之前，還包括，同步所有節(jié)點(diǎn)的系統(tǒng)當(dāng)前時(shí)刻。

本發(fā)明一方面提供一種分布式系統(tǒng)中緩存數(shù)據(jù)讀寫系統(tǒng)，用于對(duì)分布式系統(tǒng)中各個(gè)節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行讀寫，對(duì)于分布式系統(tǒng)中的任意一個(gè)節(jié)點(diǎn)，系統(tǒng)包括設(shè)定模塊和執(zhí)行模塊，其中：設(shè)定模塊用于設(shè)定該節(jié)點(diǎn)的數(shù)據(jù)清空時(shí)刻，當(dāng)該節(jié)點(diǎn)收到一請(qǐng)求時(shí)，執(zhí)行模塊判斷是否到達(dá)該數(shù)據(jù)清空時(shí)刻，如果是，則對(duì)節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行清空，然后設(shè)定模塊重新設(shè)定節(jié)點(diǎn)的數(shù)據(jù)清空時(shí)刻，否則，根據(jù)請(qǐng)求對(duì)節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行讀寫。

進(jìn)一步，執(zhí)行模塊對(duì)該節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行清空之后，若請(qǐng)求為讀請(qǐng)求，則向請(qǐng)求發(fā)送方返回空值，若請(qǐng)求為寫請(qǐng)求，則向該節(jié)點(diǎn)中寫入相應(yīng)的數(shù)據(jù)，然后設(shè)定模塊重新設(shè)定該節(jié)點(diǎn)的數(shù)據(jù)清空時(shí)刻。

進(jìn)一步，執(zhí)行模塊對(duì)該節(jié)點(diǎn)中的緩存數(shù)據(jù)進(jìn)行清空之后，若請(qǐng)求為讀請(qǐng)求，則向請(qǐng)求發(fā)送方返回空值，并從外部獲取該讀請(qǐng)求所對(duì)應(yīng)的數(shù)據(jù)，并作為緩存數(shù)據(jù)存儲(chǔ)。

進(jìn)一步，執(zhí)行模塊從外部獲取該讀請(qǐng)求所對(duì)應(yīng)的數(shù)據(jù)，包括：從遠(yuǎn)程數(shù)據(jù)庫、緩存插件、本地磁盤中的一者中獲取該讀請(qǐng)求所對(duì)應(yīng)的數(shù)據(jù)。