[發(fā)明專利]一種基于物聯(lián)網(wǎng)大數(shù)據(jù)處理方法、系統(tǒng)及服務(wù)處理端

有效

• 申請?zhí)枺?/td>: 201610839421.2
• 申請日: 2016-09-21
• 公開（公告）號: CN106230985B
• 公開（公告）日: 2017-11-17
• 發(fā)明（設(shè)計(jì)）人: 李志;劉國
• 申請（專利權(quán)）人: 廣東工業(yè)大學(xué)
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/24
• 代理公司: 廣州勝沃園專利代理有限公司44416
• 代理人: 張帥

1.一種基于物聯(lián)網(wǎng)大數(shù)據(jù)處理方法，其特征在于，包括以下步驟：

服務(wù)請求發(fā)送端向服務(wù)處理端發(fā)送服務(wù)請求消息；其中，所述服務(wù)請求消息攜帶請求業(yè)務(wù)類型信息、集群標(biāo)識信息；

所述服務(wù)處理端根據(jù)獲取的集群標(biāo)識信息，從匹配的目標(biāo)集群中調(diào)用對應(yīng)的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理，包括：

所述服務(wù)處理端根據(jù)獲取的集群標(biāo)識信息，從匹配的目標(biāo)集群中調(diào)用主集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理；其中，根據(jù)業(yè)務(wù)類型預(yù)先對目標(biāo)集群中的各個(gè)集群處理節(jié)點(diǎn)進(jìn)行分別配置，配置為主集群處理節(jié)點(diǎn)為一個(gè)，從集群處理節(jié)點(diǎn)為一個(gè)或多個(gè)；處理服務(wù)請求消息的主集群處理節(jié)點(diǎn)根據(jù)業(yè)務(wù)關(guān)聯(lián)關(guān)系，調(diào)用對應(yīng)的從集群處理節(jié)點(diǎn)協(xié)助共同對所述服務(wù)請求消息進(jìn)行處理；

所述服務(wù)處理端根據(jù)獲取的集群標(biāo)識信息，從匹配的目標(biāo)集群中調(diào)用對應(yīng)的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理的具體過程為：

所述服務(wù)處理端根據(jù)獲取的集群標(biāo)識信息，向匹配出的目標(biāo)集群的主集群處理節(jié)點(diǎn)發(fā)送所述服務(wù)請求消息；

所述目標(biāo)集群中的主集群處理節(jié)點(diǎn)接收到所述服務(wù)請求消息后，向所述目標(biāo)集群內(nèi)的各個(gè)集群處理節(jié)點(diǎn)發(fā)送推選請求；

所述各個(gè)集群處理節(jié)點(diǎn)接收到所述推選請求后，將對應(yīng)的推選結(jié)果發(fā)送至所述主集群處理節(jié)點(diǎn)；

所述主集群處理節(jié)點(diǎn)根據(jù)接收的推選結(jié)果，選擇對應(yīng)的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理：

所述推選結(jié)果分為同意、不同意，若反饋同意的集群處理節(jié)點(diǎn)為多個(gè)，則所述主集群處理節(jié)點(diǎn)從反饋同意的集群處理節(jié)點(diǎn)中選擇一個(gè)級別最高的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理；集群處理節(jié)點(diǎn)劃分為三類：高級別集群處理節(jié)點(diǎn)、中級別集群處理節(jié)點(diǎn)、低級別集群處理節(jié)點(diǎn)；級別的劃分參考銷售額、人數(shù)與資質(zhì)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，服務(wù)請求發(fā)送端向服務(wù)處理端發(fā)送服務(wù)請求消息之前，還包括：

服務(wù)處理端從各個(gè)信息承載主體獲取對應(yīng)的數(shù)據(jù)信息，并存儲對所述數(shù)據(jù)信息的處理結(jié)果；其中，所述數(shù)據(jù)信息包括：結(jié)構(gòu)化數(shù)據(jù)信息、非結(jié)構(gòu)化數(shù)據(jù)信息。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，通過采集工具將所述結(jié)構(gòu)化數(shù)據(jù)信息、非結(jié)構(gòu)化數(shù)據(jù)信息轉(zhuǎn)換為記錄、消息、日志、文件。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述信息承載主體包括：消費(fèi)者連接平臺、企業(yè)業(yè)務(wù)平臺；其中，所述消費(fèi)者連接平臺包括：京東商城、微信、淘寶；所述企業(yè)業(yè)務(wù)平臺包括：快遞100、云之家。

5.一種數(shù)據(jù)處理系統(tǒng)，其特征在于，包括服務(wù)請求發(fā)送端、服務(wù)處理端；其中，所述服務(wù)請求發(fā)送端與所述服務(wù)處理端相連；

所述服務(wù)請求發(fā)送端，用于向所述服務(wù)處理端發(fā)送服務(wù)請求消息；其中，所述服務(wù)請求消息攜帶請求業(yè)務(wù)類型信息、集群標(biāo)識信息；

所述服務(wù)處理端，用于根據(jù)獲取的集群標(biāo)識信息，從匹配的目標(biāo)集群中調(diào)用對應(yīng)的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理，包括：

所述服務(wù)處理端根據(jù)獲取的集群標(biāo)識信息，從匹配的目標(biāo)集群中調(diào)用主集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理；其中，根據(jù)業(yè)務(wù)類型預(yù)先對目標(biāo)集群中的各個(gè)集群處理節(jié)點(diǎn)進(jìn)行分別配置，配置為主集群處理節(jié)點(diǎn)為一個(gè)，從集群處理節(jié)點(diǎn)為一個(gè)或多個(gè)；處理服務(wù)請求消息的主集群處理節(jié)點(diǎn)根據(jù)業(yè)務(wù)關(guān)聯(lián)關(guān)系，調(diào)用對應(yīng)的從集群處理節(jié)點(diǎn)協(xié)助共同對所述服務(wù)請求消息進(jìn)行處理；

所述服務(wù)處理端根據(jù)獲取的集群標(biāo)識信息，從匹配的目標(biāo)集群中調(diào)用對應(yīng)的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理的具體過程為：

所述服務(wù)處理端根據(jù)獲取的集群標(biāo)識信息，向匹配出的目標(biāo)集群的主集群處理節(jié)點(diǎn)發(fā)送所述服務(wù)請求消息；

所述目標(biāo)集群中的主集群處理節(jié)點(diǎn)接收到所述服務(wù)請求消息后，向所述目標(biāo)集群內(nèi)的各個(gè)集群處理節(jié)點(diǎn)發(fā)送推選請求；

所述各個(gè)集群處理節(jié)點(diǎn)接收到所述推選請求后，將對應(yīng)的推選結(jié)果發(fā)送至所述主集群處理節(jié)點(diǎn)；

所述主集群處理節(jié)點(diǎn)根據(jù)接收的推選結(jié)果，選擇對應(yīng)的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理：

所述推選結(jié)果分為同意、不同意，若反饋同意的集群處理節(jié)點(diǎn)為多個(gè)，則所述主集群處理節(jié)點(diǎn)從反饋同意的集群處理節(jié)點(diǎn)中選擇一個(gè)級別最高的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理；集群處理節(jié)點(diǎn)劃分為三類：高級別集群處理節(jié)點(diǎn)、中級別集群處理節(jié)點(diǎn)、低級別集群處理節(jié)點(diǎn)；級別的劃分參考銷售額、人數(shù)與資質(zhì)。

6.一種服務(wù)處理端，其特征在于，包括接收模塊、處理模塊；其中，所述接收模塊與所述處理模塊相連；

所述接收模塊，用于接收服務(wù)請求消息并將所述服務(wù)請求消息發(fā)送至所述處理模塊；

所述處理模塊，用于根據(jù)獲取的集群標(biāo)識信息，從匹配的目標(biāo)集群中調(diào)用對應(yīng)的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理，包括：

根據(jù)獲取的集群標(biāo)識信息，從匹配的目標(biāo)集群中調(diào)用主集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理；其中，根據(jù)業(yè)務(wù)類型預(yù)先對目標(biāo)集群中的各個(gè)集群處理節(jié)點(diǎn)進(jìn)行分別配置，配置為主集群處理節(jié)點(diǎn)為一個(gè)，從集群處理節(jié)點(diǎn)為一個(gè)或多個(gè)；處理服務(wù)請求消息的主集群處理節(jié)點(diǎn)根據(jù)業(yè)務(wù)關(guān)聯(lián)關(guān)系，調(diào)用對應(yīng)的從集群處理節(jié)點(diǎn)協(xié)助共同對所述服務(wù)請求消息進(jìn)行處理；

所述服務(wù)處理端根據(jù)獲取的集群標(biāo)識信息，從匹配的目標(biāo)集群中調(diào)用對應(yīng)的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理的具體過程為：

所述服務(wù)處理端根據(jù)獲取的集群標(biāo)識信息，向匹配出的目標(biāo)集群的主集群處理節(jié)點(diǎn)發(fā)送所述服務(wù)請求消息；

所述目標(biāo)集群中的主集群處理節(jié)點(diǎn)接收到所述服務(wù)請求消息后，向所述目標(biāo)集群內(nèi)的各個(gè)集群處理節(jié)點(diǎn)發(fā)送推選請求；

所述各個(gè)集群處理節(jié)點(diǎn)接收到所述推選請求后，將對應(yīng)的推選結(jié)果發(fā)送至所述主集群處理節(jié)點(diǎn)；

所述主集群處理節(jié)點(diǎn)根據(jù)接收的推選結(jié)果，選擇對應(yīng)的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理：

所述推選結(jié)果分為同意、不同意，若反饋同意的集群處理節(jié)點(diǎn)為多個(gè)，則所述主集群處理節(jié)點(diǎn)從反饋同意的集群處理節(jié)點(diǎn)中選擇一個(gè)級別最高的集群處理節(jié)點(diǎn)對所述服務(wù)請求消息進(jìn)行處理；集群處理節(jié)點(diǎn)劃分為三類：高級別集群處理節(jié)點(diǎn)、中級別集群處理節(jié)點(diǎn)、低級別集群處理節(jié)點(diǎn)；級別的劃分參考銷售額、人數(shù)與資質(zhì)。