[發(fā)明專利]查詢請(qǐng)求異步處理方法、裝置、計(jì)算機(jī)設(shè)備、存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202111407680.5
• 申請(qǐng)日: 2021-11-24
• 公開（公告）號(hào): CN114218267A
• 公開（公告）日: 2022-03-22
• 發(fā)明（設(shè)計(jì)）人: 吳松圃
• 申請(qǐng)（專利權(quán)）人: 建信金融科技有限責(zé)任公司
• 主分類號(hào): G06F16/2455
• 分類號(hào): G06F16/2455
• 代理公司: 華進(jìn)聯(lián)合專利商標(biāo)代理有限公司 44224
• 代理人: 賴遠(yuǎn)龍

1.一種查詢請(qǐng)求異步處理方法，其特征在于，所述方法包括：

接收查詢端發(fā)送的查詢請(qǐng)求，基于所述查詢請(qǐng)求生成查詢?nèi)蝿?wù)并分配任務(wù)編號(hào)，將所述查詢?nèi)蝿?wù)寫入查詢隊(duì)列；

利用分布式執(zhí)行節(jié)點(diǎn)從所述查詢隊(duì)列中獲取當(dāng)前查詢?nèi)蝿?wù)，基于所述當(dāng)前查詢?nèi)蝿?wù)向緩存庫發(fā)起查詢；所述緩存庫包括若干緩存節(jié)點(diǎn)，所述緩存庫用于存儲(chǔ)包括歷史查詢?nèi)蝿?wù)的第一鍵值對(duì)，所述第一鍵值對(duì)為所述查詢?nèi)蝿?wù)的結(jié)構(gòu)化查詢語言和查詢結(jié)果集的鍵值對(duì)；

根據(jù)所述當(dāng)前查詢?nèi)蝿?wù)的結(jié)構(gòu)化查詢語言，查詢所述緩存庫中的第一鍵值對(duì)是否存在目標(biāo)鍵值對(duì)，得到查詢結(jié)果；所述目標(biāo)鍵值對(duì)為所述緩存庫中與所述當(dāng)前查詢?nèi)蝿?wù)具有相同結(jié)構(gòu)化查詢語言的第一鍵值對(duì)；

根據(jù)所述查詢結(jié)果和所述當(dāng)前查詢?nèi)蝿?wù)的任務(wù)編號(hào)，相應(yīng)的生成所述當(dāng)前查詢?nèi)蝿?wù)的第二鍵值對(duì)，將所述第二鍵值對(duì)存儲(chǔ)在所述緩存庫中，以供所述查詢端讀取；所述第二鍵值對(duì)為所述查詢?nèi)蝿?wù)的任務(wù)編號(hào)和查詢結(jié)果集的鍵值對(duì)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述利用分布式執(zhí)行節(jié)點(diǎn)從所述查詢隊(duì)列中獲取當(dāng)前查詢?nèi)蝿?wù)，基于所述當(dāng)前查詢?nèi)蝿?wù)向緩存庫發(fā)起查詢；所述緩存庫包括若干緩存節(jié)點(diǎn)，所述緩存庫用于存儲(chǔ)包括歷史查詢?nèi)蝿?wù)的第一鍵值對(duì)，所述第一鍵值對(duì)為所述查詢?nèi)蝿?wù)的結(jié)構(gòu)化查詢語言和查詢結(jié)果集的鍵值對(duì)包括：

基于所述查詢?nèi)蝿?wù)，所述分布式執(zhí)行節(jié)點(diǎn)按照預(yù)設(shè)規(guī)則獲取對(duì)應(yīng)的查詢?nèi)蝿?wù)。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)所述查詢結(jié)果和所述當(dāng)前查詢?nèi)蝿?wù)的任務(wù)編號(hào)，相應(yīng)的生成所述當(dāng)前查詢?nèi)蝿?wù)的第二鍵值對(duì)，將所述第二鍵值對(duì)存儲(chǔ)在所述緩存庫中，以供所述查詢端讀取包括：

在所述查詢結(jié)果為所述緩存庫中存在所述目標(biāo)鍵值對(duì)的情況下，則根據(jù)所述目標(biāo)鍵值對(duì)和所述當(dāng)前查詢?nèi)蝿?wù)的任務(wù)編號(hào)生成第二鍵值對(duì)，將所述第二鍵值對(duì)存儲(chǔ)在所述緩存庫中，以供所述查詢端讀取。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述在所述查詢結(jié)果為所述緩存庫中存在所述目標(biāo)鍵值對(duì)的情況下，則根據(jù)所述目標(biāo)鍵值對(duì)和所述當(dāng)前查詢?nèi)蝿?wù)的任務(wù)編號(hào)生成第二鍵值對(duì)，將所述第二鍵值對(duì)存儲(chǔ)在所述緩存庫中，以供所述查詢端讀取包括：

獲取所述目標(biāo)鍵值對(duì)的查詢結(jié)果集，根據(jù)所述當(dāng)前查詢?nèi)蝿?wù)的任務(wù)編號(hào)和所述目標(biāo)鍵值對(duì)的查詢結(jié)果集生成所述當(dāng)前查詢?nèi)蝿?wù)的第二鍵值對(duì)；

基于哈希算法將所述當(dāng)前查詢?nèi)蝿?wù)的第二鍵值進(jìn)行數(shù)據(jù)拆分，生成若干數(shù)據(jù)分片；

將所述數(shù)據(jù)分片分別存儲(chǔ)在所述緩存庫的若干緩存節(jié)點(diǎn)上。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)所述查詢結(jié)果和所述當(dāng)前查詢?nèi)蝿?wù)的任務(wù)編號(hào)，相應(yīng)的生成所述當(dāng)前查詢?nèi)蝿?wù)的第二鍵值對(duì)，將所述第二鍵值對(duì)存儲(chǔ)在所述緩存庫中，以供所述查詢端讀取包括：

在所述查詢結(jié)果為所述緩存庫中不存在所述目標(biāo)鍵值對(duì)的情況下，則向數(shù)據(jù)庫查詢獲取所述當(dāng)前查詢?nèi)蝿?wù)的查詢結(jié)果集，生成所述當(dāng)前查詢?nèi)蝿?wù)的第一鍵值對(duì)和第二鍵值對(duì)，并存儲(chǔ)至所述緩存庫，以供所述查詢端讀取。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述在所述查詢結(jié)果為所述緩存庫中不存在所述目標(biāo)鍵值對(duì)的情況下，則向數(shù)據(jù)庫查詢獲取所述當(dāng)前查詢?nèi)蝿?wù)的查詢結(jié)果集，生成所述當(dāng)前查詢?nèi)蝿?wù)的第一鍵值對(duì)和第二鍵值對(duì)，并存儲(chǔ)至所述緩存庫，以供所述查詢端讀取包括：

根據(jù)所述當(dāng)前查詢?nèi)蝿?wù)的結(jié)構(gòu)化查詢語言向數(shù)據(jù)庫發(fā)起查詢，接收所述數(shù)據(jù)庫返回的所述當(dāng)前查詢?nèi)蝿?wù)的查詢結(jié)果集；

根據(jù)所述當(dāng)前查詢?nèi)蝿?wù)的結(jié)構(gòu)化查詢語言和查詢結(jié)果集生成第一鍵值對(duì)；

根據(jù)所述當(dāng)前查詢?nèi)蝿?wù)的任務(wù)編號(hào)和查詢結(jié)果集生成第二鍵值對(duì)；

基于哈希算法將所述當(dāng)前查詢?nèi)蝿?wù)的第一鍵值對(duì)和第二鍵值分別進(jìn)行數(shù)據(jù)拆分，生成若干數(shù)據(jù)分片；

將所述數(shù)據(jù)分片分別存儲(chǔ)在所述緩存庫的若干緩存節(jié)點(diǎn)上。

7.根據(jù)權(quán)利要求4或6所述的方法，其特征在于，所述將所述數(shù)據(jù)分片分別存儲(chǔ)在所述緩存庫的若干緩存節(jié)點(diǎn)上包括：

所述數(shù)據(jù)分片按照預(yù)設(shè)算法進(jìn)行計(jì)算輸出節(jié)點(diǎn)編號(hào)，所述節(jié)點(diǎn)編號(hào)用于與所述緩存節(jié)點(diǎn)一一對(duì)應(yīng)；

將所述數(shù)據(jù)分片按照節(jié)點(diǎn)編號(hào)存儲(chǔ)至對(duì)應(yīng)的緩存節(jié)點(diǎn)。