[發(fā)明專利]一種處理共享緩存同步消息的方法、系統(tǒng)、設(shè)備及介質(zhì)

在審

• 申請?zhí)枺?/td>: 202010007564.3
• 申請日: 2020-01-04
• 公開（公告）號: CN111221826A
• 公開（公告）日: 2020-06-02
• 發(fā)明（設(shè)計(jì)）人: 耿芳忠;王少磊
• 申請（專利權(quán)）人: 蘇州浪潮智能科技有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/2455;G06F16/27
• 代理公司: 北京連和連知識產(chǎn)權(quán)代理有限公司 11278
• 代理人: 張濤

本發(fā)明公開了一種處理共享緩存同步消息的方法、系統(tǒng)、設(shè)備和存儲(chǔ)介質(zhì)，方法包括以下步驟：創(chuàng)建基礎(chǔ)本地緩存和基礎(chǔ)外部緩存索引；響應(yīng)于接收到共享緩存同步消息，判斷共享緩存同步消息的讀寫標(biāo)識是否為寫；響應(yīng)于共享緩存同步消息的讀寫標(biāo)識為寫，判斷基礎(chǔ)本地緩存中是否存在共享緩存同步消息對應(yīng)的對象的緩存；以及響應(yīng)于基礎(chǔ)本地緩存中存在共享緩存同步消息對應(yīng)的對象的緩存，刪除基礎(chǔ)本地緩存中對應(yīng)的緩存，并將對象的外部緩存索引加入基礎(chǔ)外部緩存索引。本發(fā)明提出的處理共享緩存同步消息的方法、系統(tǒng)、設(shè)備及介質(zhì)通過利用客戶端內(nèi)存實(shí)現(xiàn)共享數(shù)據(jù)緩存，充分利用存儲(chǔ)業(yè)務(wù)網(wǎng)絡(luò)和高性能客戶端的內(nèi)存資源，降低集群共享訪問數(shù)據(jù)時(shí)的延遲。

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

本發(fā)明涉及并行存儲(chǔ)領(lǐng)域，更具體地，特別是指一種處理共享緩存同步消息的方法、系統(tǒng)、計(jì)算機(jī)設(shè)備及可讀介質(zhì)。

背景技術(shù)

并行存儲(chǔ)系統(tǒng)，是指能夠提供多個(gè)客戶端并發(fā)訪問存儲(chǔ)對象的能力的存儲(chǔ)系統(tǒng)。并發(fā)訪問需求在HPC(High Performance Computing，高性能計(jì)算)、MPI(Message PassingInterface，消息傳遞接口)等場景有著廣泛的應(yīng)用。高性能計(jì)算要求多個(gè)計(jì)算節(jié)點(diǎn)能夠同時(shí)處理一批數(shù)據(jù)，就需要對同一個(gè)對象進(jìn)行讀寫操作。消息傳遞通過共享介質(zhì)傳遞數(shù)據(jù)，消息生產(chǎn)者與消費(fèi)者也需要對同一個(gè)對象實(shí)體進(jìn)行并發(fā)的訪問。這就需要并行存儲(chǔ)系統(tǒng)中的對象同步，而現(xiàn)有技術(shù)中處理共享緩存同步消息不僅要解決數(shù)據(jù)一致性問題，又要最大限度的提高并發(fā)數(shù)，而且對鎖機(jī)制、緩存機(jī)制有極高的設(shè)計(jì)要求，因此往往比較復(fù)雜。

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

有鑒于此，本發(fā)明實(shí)施例的目的在于提出一種處理共享緩存同步消息的方法、系統(tǒng)、計(jì)算機(jī)設(shè)備及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，通過利用客戶端內(nèi)存實(shí)現(xiàn)共享數(shù)據(jù)緩存，充分利用存儲(chǔ)業(yè)務(wù)網(wǎng)絡(luò)和高性能客戶端的內(nèi)存資源，降低集群共享訪問數(shù)據(jù)時(shí)的延遲。

基于上述目的，本發(fā)明實(shí)施例的一方面提供了一種處理共享緩存同步消息的方法，包括如下步驟：創(chuàng)建基礎(chǔ)本地緩存和基礎(chǔ)外部緩存索引；響應(yīng)于接收到共享緩存同步消息，判斷所述共享緩存同步消息的讀寫標(biāo)識是否為寫；響應(yīng)于所述共享緩存同步消息的讀寫標(biāo)識為寫，判斷所述基礎(chǔ)本地緩存中是否存在所述共享緩存同步消息對應(yīng)的對象的緩存；以及響應(yīng)于所述基礎(chǔ)本地緩存中存在所述共享緩存同步消息對應(yīng)的對象的緩存，刪除所述基礎(chǔ)本地緩存中對應(yīng)的緩存，并將所述對象的外部緩存索引加入所述基礎(chǔ)外部緩存索引。

在一些實(shí)施方式中，還包括：響應(yīng)于所述共享緩存同步消息的讀寫標(biāo)識不為寫，將所述共享緩存同步消息對應(yīng)的對象的外部緩存索引加入所述基礎(chǔ)外部緩存索引。

在一些實(shí)施方式中，還包括：基于讀操作或?qū)懖僮靼l(fā)送共享緩存同步消息。

在一些實(shí)施方式中，所述基于讀操作發(fā)送共享緩存同步消息包括：響應(yīng)于應(yīng)用進(jìn)程訪問對象，判斷所述本地緩存和/或所述外部緩存索引中是否存在所述對象；以及響應(yīng)于所述本地緩存和/或所述外部緩存索引中不存在所述對象，向并行存儲(chǔ)集群發(fā)起讀請求并將返回?cái)?shù)據(jù)寫入所述本地緩存，并向其他客戶端節(jié)點(diǎn)發(fā)送共享緩存同步消息。

在一些實(shí)施方式中，所述基于寫操作發(fā)送共享緩存同步消息包括：響應(yīng)于應(yīng)用進(jìn)程訪問對象，向存儲(chǔ)集群獲取所述對象的寫鎖，并判斷所述本地緩存中是否存在所述對象；響應(yīng)于所述本地緩存中不存在所述對象，創(chuàng)建所述對象的本地緩存，并向其他客戶端節(jié)點(diǎn)發(fā)送共享緩存同步消息；以及釋放所述寫鎖，向所述應(yīng)用進(jìn)程返回操作成功。

本發(fā)明實(shí)施例的另一方面，還提供了一種處理共享緩存同步消息的系統(tǒng)，包括：創(chuàng)建模塊，配置用于創(chuàng)建基礎(chǔ)本地緩存和基礎(chǔ)外部緩存索引；第一判斷模塊，配置用于響應(yīng)于接收到共享緩存同步消息，判斷所述共享緩存同步消息的讀寫標(biāo)識是否為寫；第二判斷模塊，配置用于響應(yīng)于所述共享緩存同步消息的讀寫標(biāo)識為寫，判斷所述基礎(chǔ)本地緩存中是否存在所述共享緩存同步消息對應(yīng)的對象的緩存；以及處理模塊，配置用于響應(yīng)于所述基礎(chǔ)本地緩存中存在所述共享緩存同步消息對應(yīng)的對象的緩存，刪除所述基礎(chǔ)本地緩存中對應(yīng)的緩存，并將所述對象的外部緩存索引加入所述基礎(chǔ)外部緩存索引。