[發(fā)明專利]處理高并發(fā)查詢請(qǐng)求的方法及裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 201710763330.X
• 申請(qǐng)日: 2017-08-30
• 公開(kāi)（公告）號(hào): CN109471872A
• 公開(kāi)（公告）日: 2019-03-15
• 發(fā)明（設(shè)計(jì)）人: 趙懿
• 申請(qǐng)（專利權(quán)）人: 北京國(guó)雙科技有限公司
• 主分類號(hào): G06F16/2453
• 分類號(hào): G06F16/2453;G06F16/2458;G06F16/242
• 代理公司: 北京鼎佳達(dá)知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11348
• 代理人: 王偉鋒;劉鐵生

本發(fā)明公開(kāi)了處理高并發(fā)查詢請(qǐng)求的方法及裝置，涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，提高了查詢數(shù)據(jù)的工作效率，本發(fā)明的主要技術(shù)方案為：接收多個(gè)并發(fā)查詢請(qǐng)求，所述并發(fā)查詢請(qǐng)求中包括初始查詢請(qǐng)求以及與所述初始查詢請(qǐng)求對(duì)應(yīng)的相同查詢請(qǐng)求；提取所述初始查詢請(qǐng)求；阻塞所述相同查詢請(qǐng)求；確定所述初始查詢請(qǐng)求對(duì)應(yīng)的查詢結(jié)果；將所述查詢結(jié)果確定為所述相同查詢請(qǐng)求對(duì)應(yīng)的查詢結(jié)果返回給對(duì)應(yīng)的查詢用戶。本發(fā)明主要用于處理高并發(fā)查詢請(qǐng)求。

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

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種處理高并發(fā)查詢請(qǐng)求的方法及裝置。

背景技術(shù)

在大數(shù)據(jù)時(shí)代，聯(lián)機(jī)分析處理(Online AnalyticalProcessing，OLAP)在處理數(shù)據(jù)時(shí)，通常的做法是先對(duì)一個(gè)時(shí)間范圍的數(shù)據(jù)，按照維度的組合對(duì)指標(biāo)集進(jìn)行預(yù)先計(jì)算，該預(yù)先計(jì)算被稱之為預(yù)聚合，然后保存該預(yù)聚合結(jié)果，根據(jù)上述的預(yù)聚合結(jié)果，用戶可以應(yīng)用OLAP更加具體地多維度剖析數(shù)據(jù)。

目前，在查詢預(yù)聚合結(jié)果時(shí)，對(duì)于每一次查詢請(qǐng)求，都需要執(zhí)行一次查詢操作。然而，在對(duì)預(yù)聚合結(jié)果進(jìn)行查詢分析時(shí)，可以發(fā)現(xiàn)查詢請(qǐng)求具有冪等性的特征，即執(zhí)行多次同樣的查詢請(qǐng)求對(duì)應(yīng)的查詢結(jié)果是相同的，據(jù)此，當(dāng)在高并發(fā)查詢請(qǐng)求狀態(tài)時(shí)，查詢請(qǐng)求中可能會(huì)存在很多相同的并發(fā)請(qǐng)求，若對(duì)每個(gè)請(qǐng)求都執(zhí)行一次查詢操作，那么會(huì)浪費(fèi)大量的處理資源，同時(shí)也大大降低了用戶獲取查詢結(jié)果的效率。

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

有鑒于此，本發(fā)明提供一種處理高并發(fā)查詢請(qǐng)求的方法及裝置，主要目的在于通過(guò)一次查詢請(qǐng)求獲取在一段時(shí)間內(nèi)與該查詢請(qǐng)求相同的多個(gè)并發(fā)查詢請(qǐng)求對(duì)應(yīng)的查詢結(jié)果，減少了查詢工作量，提高了查詢數(shù)據(jù)的工作效率。

為了解決上述問(wèn)題，本發(fā)明主要提供如下技術(shù)方案：

一方面，本發(fā)明提供了一種處理高并發(fā)查詢請(qǐng)求的方法，該方法包括：

接收多個(gè)并發(fā)查詢請(qǐng)求，所述并發(fā)查詢請(qǐng)求中包括初始查詢請(qǐng)求以及與所述初始查詢請(qǐng)求對(duì)應(yīng)的相同查詢請(qǐng)求；

提取所述初始查詢請(qǐng)求；

阻塞所述相同查詢請(qǐng)求；

確定所述初始查詢請(qǐng)求對(duì)應(yīng)的查詢結(jié)果；

將所述查詢結(jié)果確定為所述相同查詢請(qǐng)求對(duì)應(yīng)的查詢結(jié)果返回給對(duì)應(yīng)的查詢用戶。

優(yōu)選的，所述確定所述初始查詢請(qǐng)求對(duì)應(yīng)的查詢結(jié)果包括：

將所述初始查詢請(qǐng)求發(fā)送至分布式集群中的異地節(jié)點(diǎn)，由所述異地節(jié)點(diǎn)執(zhí)行查詢操作，獲取所述初始查詢請(qǐng)求對(duì)應(yīng)的查詢結(jié)果，將所述查詢結(jié)果寫入所述異地節(jié)點(diǎn)的分布式緩存；

接收所述異地節(jié)點(diǎn)返回的查詢完成消息；

根據(jù)所述查詢完成消息，在本地節(jié)點(diǎn)的分布式緩存中獲取所述查詢結(jié)果，其中，所述分布式集群包含的各個(gè)節(jié)點(diǎn)都存在分布式緩存，并且當(dāng)在一個(gè)節(jié)點(diǎn)的分布式緩存中寫入數(shù)據(jù)時(shí)，所述數(shù)據(jù)可以被其他節(jié)點(diǎn)的分布式緩存讀取。

優(yōu)選的，在所述接收多個(gè)并發(fā)查詢請(qǐng)求之后，所述方法還包括：

判斷所述并發(fā)查詢請(qǐng)求是否為初始查詢請(qǐng)求；

若是，則提取所述初始查詢請(qǐng)求，并根據(jù)所述初始查詢請(qǐng)求創(chuàng)建同步等待結(jié)構(gòu)，所述同步等待結(jié)構(gòu)用于阻塞所述相同查詢請(qǐng)求；

若不是，則將所述并發(fā)查詢請(qǐng)求確定為相同查詢請(qǐng)求，并將所述相同查詢請(qǐng)求加入對(duì)應(yīng)的同步等待結(jié)構(gòu)中，阻塞所述相同查詢請(qǐng)求。

優(yōu)選的，將所述查詢結(jié)果確定為所述相同查詢請(qǐng)求對(duì)應(yīng)的查詢結(jié)果返回給對(duì)應(yīng)的查詢用戶包括：

當(dāng)接收到所述查詢完成消息時(shí)，喚醒所述同步等待結(jié)構(gòu)阻塞的相同查詢請(qǐng)求；

將在本地節(jié)點(diǎn)的分布式緩存中獲取的所述查詢結(jié)果確定為所述相同查詢請(qǐng)求對(duì)應(yīng)的查詢結(jié)果；