[發(fā)明專利]數(shù)據(jù)集群化處理的方法、裝置及設(shè)備

有效

• 申請?zhí)枺?/td>: 201710263207.1
• 申請日: 2017-04-20
• 公開（公告）號: CN108733477B
• 公開（公告）日: 2021-04-23
• 發(fā)明（設(shè)計(jì)）人: 王卉;雷中杰;樊煉;林潔;胡莉;李林;許佳;徐慶;張欣;黃璐;薛超
• 申請（專利權(quán)）人: 中國移動通信集團(tuán)湖北有限公司;中國移動通信集團(tuán)公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06Q40/00;H04L29/08
• 代理公司: 北京東方億思知識產(chǎn)權(quán)代理有限責(zé)任公司 11258
• 代理人: 彭瓊

1.一種數(shù)據(jù)集群化處理的方法，其特征在于，包括：

接收到數(shù)據(jù)源的訪問請求，基于所述數(shù)據(jù)源的數(shù)據(jù)特性確定所述數(shù)據(jù)源對應(yīng)的加鎖類型；

所述加鎖類型為分布式鎖，根據(jù)所述數(shù)據(jù)源的存儲信息分配處理所述數(shù)據(jù)源的分布式服務(wù)器和處理所述數(shù)據(jù)源的應(yīng)用進(jìn)程；

依據(jù)所述分布式服務(wù)器的加鎖目錄檢測所述應(yīng)用進(jìn)程當(dāng)前是否空閑；

所述應(yīng)用進(jìn)程當(dāng)前空閑，通過所述應(yīng)用進(jìn)程對所述數(shù)據(jù)源進(jìn)行處理；

所述應(yīng)用進(jìn)程對所述數(shù)據(jù)源進(jìn)行處理，包括：在所述分布式服務(wù)器上創(chuàng)建所述數(shù)據(jù)源對應(yīng)的加鎖目錄；

所述依據(jù)所述分布式服務(wù)器的加鎖目錄檢測所述應(yīng)用進(jìn)程當(dāng)前是否空閑，包括：

所述分布式服務(wù)器的加鎖目錄包括子節(jié)點(diǎn)，確定所述應(yīng)用進(jìn)程當(dāng)前不空閑；

所述分布式服務(wù)器的加鎖目錄不包括子節(jié)點(diǎn)，在所述加鎖目錄下創(chuàng)建臨時子節(jié)點(diǎn)，所述臨時子節(jié)點(diǎn)不是所述加鎖目錄下序號最小的子節(jié)點(diǎn)，確定所述應(yīng)用進(jìn)程當(dāng)前不空閑，并刪除所述臨時子節(jié)點(diǎn)；

所述分布式服務(wù)器的加鎖目錄不包括子節(jié)點(diǎn)，在所述加鎖目錄下創(chuàng)建臨時子節(jié)點(diǎn)，所述臨時子節(jié)點(diǎn)為所述加鎖目錄下序號最小的子節(jié)點(diǎn)，確定所述應(yīng)用進(jìn)程當(dāng)前空閑。

2.根據(jù)權(quán)利要求1所述數(shù)據(jù)集群化處理的方法，其特征在于，所述在所述分布式服務(wù)器上創(chuàng)建所述數(shù)據(jù)源對應(yīng)的加鎖目錄之后，還包括：

檢測所述應(yīng)用進(jìn)程是否出現(xiàn)異常；

所述應(yīng)用進(jìn)程出現(xiàn)異常，對所述數(shù)據(jù)源進(jìn)行解鎖。

3.根據(jù)權(quán)利要求1所述數(shù)據(jù)集群化處理的方法，其特征在于，所述根據(jù)所述數(shù)據(jù)源的存儲信息分配處理所述數(shù)據(jù)源的分布式服務(wù)器和處理所述數(shù)據(jù)源的應(yīng)用進(jìn)程，包括：

根據(jù)存儲所述數(shù)據(jù)源的存儲節(jié)點(diǎn)查詢所述存儲節(jié)點(diǎn)對應(yīng)的任務(wù)標(biāo)識；

基于所述任務(wù)標(biāo)識和預(yù)設(shè)屬性標(biāo)識確定所述分布式服務(wù)器；

根據(jù)進(jìn)程標(biāo)識從所述分布式服務(wù)器的進(jìn)程列表中確定處理所述數(shù)據(jù)源的應(yīng)用進(jìn)程。

4.根據(jù)權(quán)利要求1所述數(shù)據(jù)集群化處理的方法，其特征在于，所述數(shù)據(jù)特性包括數(shù)據(jù)特性開關(guān)值；

所述數(shù)據(jù)特性開關(guān)值為預(yù)設(shè)值，所述加鎖類型為分布式鎖。

5.一種數(shù)據(jù)集群化處理的裝置，其特征在于，包括：

確定單元，用于接收到數(shù)據(jù)源的訪問請求，基于所述數(shù)據(jù)源的數(shù)據(jù)特性確定所述數(shù)據(jù)源對應(yīng)的加鎖類型；

分配單元，用于所述加鎖類型為分布式鎖，根據(jù)所述數(shù)據(jù)源的存儲信息分配處理所述數(shù)據(jù)源的分布式服務(wù)器和處理所述數(shù)據(jù)源的應(yīng)用進(jìn)程；

進(jìn)程檢測單元，用于依據(jù)所述分布式服務(wù)器的加鎖目錄檢測所述應(yīng)用進(jìn)程當(dāng)前是否空閑；

處理單元，用于所述應(yīng)用進(jìn)程當(dāng)前空閑，通過所述應(yīng)用進(jìn)程對所述數(shù)據(jù)源進(jìn)行處理；

所述處理單元，具體用于在所述分布式服務(wù)器上創(chuàng)建所述數(shù)據(jù)源對應(yīng)的加鎖目錄；

所述進(jìn)程檢測單元具體用于：

所述分布式服務(wù)器的加鎖目錄包括子節(jié)點(diǎn)，確定所述應(yīng)用進(jìn)程當(dāng)前不空閑；

所述分布式服務(wù)器的加鎖目錄不包括子節(jié)點(diǎn)，在所述加鎖目錄下創(chuàng)建臨時子節(jié)點(diǎn)，所述臨時子節(jié)點(diǎn)不是所述加鎖目錄下序號最小的子節(jié)點(diǎn)，確定所述應(yīng)用進(jìn)程當(dāng)前不空閑，并刪除所述臨時子節(jié)點(diǎn)；

所述分布式服務(wù)器的加鎖目錄不包括子節(jié)點(diǎn)，在所述加鎖目錄下創(chuàng)建臨時子節(jié)點(diǎn)，所述臨時子節(jié)點(diǎn)為所述加鎖目錄下序號最小的子節(jié)點(diǎn)，確定所述應(yīng)用進(jìn)程當(dāng)前空閑。

6.根據(jù)權(quán)利要求5所述數(shù)據(jù)集群化處理的裝置，其特征在于，還包括：

異常檢測單元，用于檢測所述應(yīng)用進(jìn)程是否出現(xiàn)異常；

解鎖單元，用于所述應(yīng)用進(jìn)程出現(xiàn)異常，對所述數(shù)據(jù)源進(jìn)行解鎖。

7.根據(jù)權(quán)利要求5所述數(shù)據(jù)集群化處理的裝置，其特征在于，所述分配單元具體用于：

根據(jù)存儲所述數(shù)據(jù)源的存儲節(jié)點(diǎn)查詢所述節(jié)點(diǎn)對應(yīng)的任務(wù)標(biāo)識；

基于所述任務(wù)標(biāo)識和預(yù)設(shè)屬性標(biāo)識確定所述分布式服務(wù)器；

根據(jù)進(jìn)程標(biāo)識從所述分布式服務(wù)器的進(jìn)程列表中確定處理所述數(shù)據(jù)源的應(yīng)用進(jìn)程。