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

在審

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

1.一種處理高并發(fā)查詢請求的方法，其特征在于，所述方法包括：

接收多個并發(fā)查詢請求，所述并發(fā)查詢請求中包括初始查詢請求以及與所述初始查詢請求對應的相同查詢請求；

提取所述初始查詢請求；

阻塞所述相同查詢請求；

確定所述初始查詢請求對應的查詢結(jié)果；

將所述查詢結(jié)果確定為所述相同查詢請求對應的查詢結(jié)果返回給對應的查詢用戶。

2.根據(jù)權利要求1所述的方法，其特征在于，所述確定所述初始查詢請求對應的查詢結(jié)果包括：

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

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

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

3.根據(jù)權利要求2所述的方法，其特征在于，在所述接收多個并發(fā)查詢請求之后，所述方法還包括：

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

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

若不是，則將所述并發(fā)查詢請求確定為相同查詢請求，并將所述相同查詢請求加入對應的同步等待結(jié)構中，阻塞所述相同查詢請求。

4.根據(jù)權利要求3所述的方法，其特征在于，將所述查詢結(jié)果確定為所述相同查詢請求對應的查詢結(jié)果返回給對應的查詢用戶包括：

當接收到所述查詢完成消息時，喚醒所述同步等待結(jié)構阻塞的相同查詢請求；

將在本地節(jié)點的分布式緩存中獲取的所述查詢結(jié)果確定為所述相同查詢請求對應的查詢結(jié)果；

注銷所述初始查詢請求對應的同步等待結(jié)構。

5.根據(jù)權利要求3所述的方法，其特征在于，在判斷所述并發(fā)查詢請求是否為初始查詢請求之前，所述方法還包括：

查詢本地節(jié)點的分布式緩存中是否存在所述并發(fā)查詢請求對應的查詢結(jié)果；

若存在，則將所述查詢結(jié)果發(fā)送給所述查詢用戶。

6.根據(jù)權利要求1-5中任一項所述的方法，其特征在于，所述方法還包括：

根據(jù)接收的并發(fā)查詢請求，在第一線程池中創(chuàng)建對應所述并發(fā)查詢請求的處理線程；

在確定所述查詢結(jié)果時，在第二線程池中創(chuàng)建用于獲取所述查詢結(jié)果的處理線程，其中，所述第一線程池與所述第二線程池是根據(jù)預置規(guī)則劃分對應處理資源得到的線程池。

7.一種處理高并發(fā)查詢請求的裝置，其特征在于，所述裝置包括：

接收單元，用于接收多個并發(fā)查詢請求，所述并發(fā)查詢請求中包括初始查詢請求以及與所述初始查詢請求對應的相同查詢請求；

提取單元，用于提取所述接收單元接收的初始查詢請求；

阻塞單元，用于阻塞所述接收單元接收的相同查詢請求；

確定單元，用于確定所述提取單元提取的初始查詢請求對應的查詢結(jié)果；

所述確定單元，還用于將所述查詢結(jié)果確定為所述阻塞單元阻塞的相同查詢請求對應的查詢結(jié)果返回給對應的查詢用戶。

8.根據(jù)權利要求7所述的裝置，其特征在于，所述確定單元包括：

發(fā)送模塊，用于將所述提取單元提取的初始查詢請求發(fā)送至分布式集群中的異地節(jié)點，由所述異地節(jié)點執(zhí)行查詢操作，獲取所述初始查詢請求對應的查詢結(jié)果，將所述查詢結(jié)果寫入所述異地節(jié)點的分布式緩存；

接收模塊，用于接收所述異地節(jié)點返回的查詢完成消息；

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