[發(fā)明專(zhuān)利]高速分布式數(shù)據(jù)緩存方法、裝置、計(jì)算機(jī)設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202011196303.7
• 申請(qǐng)日: 2020-10-30
• 公開(kāi)（公告）號(hào): CN112328637A
• 公開(kāi)（公告）日: 2021-02-05
• 發(fā)明（設(shè)計(jì)）人: 周毅
• 申請(qǐng)（專(zhuān)利權(quán)）人: 中國(guó)平安人壽保險(xiǎn)股份有限公司
• 主分類(lèi)號(hào): G06F16/2455
• 分類(lèi)號(hào): G06F16/2455;G06F16/242;G06F16/23;G06F16/27;G06F9/46
• 代理公司: 深圳市精英專(zhuān)利事務(wù)所 44242
• 代理人: 李翔宇

1.一種高速分布式數(shù)據(jù)緩存方法，其特征在于，包括：

若檢測(cè)到已嵌入Ignite程序JAR包的應(yīng)用實(shí)例發(fā)送的準(zhǔn)備消息，獲取本地的鎖類(lèi)型；其中，所述鎖類(lèi)型包括悲觀(guān)鎖和樂(lè)觀(guān)鎖；

若所述鎖類(lèi)型為樂(lè)觀(guān)鎖，將所述準(zhǔn)備消息發(fā)送至Ignite集群中的其他Ignite節(jié)點(diǎn)；

將與所述準(zhǔn)備消息對(duì)應(yīng)的確認(rèn)信息發(fā)送至已嵌入Ignite程序JAR包的應(yīng)用實(shí)例；

若檢測(cè)到已嵌入Ignite程序JAR包的應(yīng)用實(shí)例發(fā)送的緩存數(shù)據(jù),將與所述緩存數(shù)據(jù)對(duì)應(yīng)的提交消息發(fā)送至Ignite集群中的其他Ignite節(jié)點(diǎn)；

將與所述提交消息對(duì)應(yīng)的事務(wù)確認(rèn)消息發(fā)送至已嵌入Ignite程序JAR包的應(yīng)用實(shí)例；以及

若檢測(cè)到SQL查詢(xún)語(yǔ)句，根據(jù)所述SQL查詢(xún)語(yǔ)句在本地查詢(xún)獲取對(duì)應(yīng)的目標(biāo)數(shù)據(jù)。

2.根據(jù)權(quán)利要求1所述的高速分布式數(shù)據(jù)緩存方法，其特征在于，還包括：

獲取本地已存儲(chǔ)的分布式哈希表，根據(jù)所述分布式哈希表獲取Ignite集群中各Ignite節(jié)點(diǎn)的本地存儲(chǔ)數(shù)據(jù)。

3.根據(jù)權(quán)利要求1所述的高速分布式數(shù)據(jù)緩存方法，其特征在于，所述若檢測(cè)到已嵌入Ignite程序JAR包的應(yīng)用實(shí)例發(fā)送的緩存數(shù)據(jù),將與所述緩存數(shù)據(jù)對(duì)應(yīng)的提交消息發(fā)送至Ignite集群中的其他Ignite節(jié)點(diǎn)，包括：

獲取事務(wù)協(xié)調(diào)器的內(nèi)部管理事務(wù)請(qǐng)求；

將緩存數(shù)據(jù)的鍵值寫(xiě)入本地；

通過(guò)事務(wù)協(xié)調(diào)器將所述鍵值寫(xiě)入本地事務(wù)映射；

接收已嵌入Ignite程序JAR包的應(yīng)用實(shí)例發(fā)送的提交消息；

在本地獲取樂(lè)觀(guān)鎖，并根據(jù)樂(lè)觀(guān)鎖進(jìn)行Ignite節(jié)點(diǎn)寫(xiě)上鎖；

將已上鎖確認(rèn)消息發(fā)送至已嵌入Ignite程序JAR包的應(yīng)用實(shí)例；

將所述提交消息發(fā)送至Ignite集群中的其他Ignite節(jié)點(diǎn)。

4.根據(jù)權(quán)利要求1所述的高速分布式數(shù)據(jù)緩存方法，其特征在于，還包括：

根據(jù)已接收的事務(wù)確認(rèn)消息獲取對(duì)應(yīng)Ignite節(jié)點(diǎn)的節(jié)點(diǎn)唯一編號(hào)，以組成當(dāng)前有效節(jié)點(diǎn)清單；

獲取Ignite集群總清單，以所述Ignite集群總清單為全集，獲取所述當(dāng)前有效節(jié)點(diǎn)清單的補(bǔ)集以得到當(dāng)前故障節(jié)點(diǎn)清單。

5.根據(jù)權(quán)利要求1所述的高速分布式數(shù)據(jù)緩存方法，其特征在于，還包括：

若所述鎖類(lèi)型為悲觀(guān)鎖，檢測(cè)是否已產(chǎn)生確認(rèn)準(zhǔn)備消息；

若已產(chǎn)生確認(rèn)準(zhǔn)備消息，接收已嵌入Ignite程序JAR包的應(yīng)用實(shí)例發(fā)送的緩存數(shù)據(jù)。

6.根據(jù)權(quán)利要求5所述的高速分布式數(shù)據(jù)緩存方法，其特征在于，所述若所述鎖類(lèi)型為悲觀(guān)鎖，檢測(cè)是否已產(chǎn)生確認(rèn)準(zhǔn)備消息，包括：

獲取事務(wù)協(xié)調(diào)器的內(nèi)部管理事務(wù)請(qǐng)求；

本地產(chǎn)生一個(gè)悲觀(guān)鎖請(qǐng)求，根據(jù)悲觀(guān)鎖進(jìn)行Ignite節(jié)點(diǎn)寫(xiě)上鎖；

產(chǎn)生一個(gè)確認(rèn)準(zhǔn)備消息，將所述確認(rèn)準(zhǔn)備消息發(fā)送至已嵌入Ignite程序JAR包的應(yīng)用實(shí)例。

7.根據(jù)權(quán)利要求2所述的高速分布式數(shù)據(jù)緩存方法，其特征在于，所述根據(jù)所述SQL查詢(xún)語(yǔ)句在本地查詢(xún)獲取對(duì)應(yīng)的目標(biāo)數(shù)據(jù)，包括：

判斷與所述SQL查詢(xún)語(yǔ)句對(duì)應(yīng)的查詢(xún)數(shù)據(jù)是否存在于主節(jié)點(diǎn)本地；

若與所述SQL查詢(xún)語(yǔ)句對(duì)應(yīng)的查詢(xún)數(shù)據(jù)存在于主節(jié)點(diǎn)本地，以所述查詢(xún)數(shù)據(jù)為目標(biāo)數(shù)據(jù)；

若與所述SQL查詢(xún)語(yǔ)句對(duì)應(yīng)的查詢(xún)數(shù)據(jù)不存在于主節(jié)點(diǎn)本地，根據(jù)所述分布式哈希表獲取對(duì)應(yīng)的當(dāng)前目標(biāo)Ignite節(jié)點(diǎn)，接收當(dāng)前目標(biāo)Ignite節(jié)點(diǎn)發(fā)送的與所述SQL查詢(xún)語(yǔ)句對(duì)應(yīng)的目標(biāo)數(shù)據(jù)。