[發(fā)明專利]用于車輛數(shù)據(jù)接收和實時分析的集群分布式系統(tǒng)及方法

有效

• 申請?zhí)枺?/td>: 201110361534.3
• 申請日: 2011-11-15
• 公開（公告）號: CN102510403A
• 公開（公告）日: 2012-06-20
• 發(fā)明（設(shè)計）人: 包可為
• 申請（專利權(quán)）人: 江蘇大為科技股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/12
• 代理公司: 北京中恒高博知識產(chǎn)權(quán)代理有限公司 11249
• 代理人: 夏晏平

1.一種用于車輛數(shù)據(jù)接收和實時分析的集群分布式系統(tǒng)，包括前端設(shè)備、通信服務(wù)器和分析服務(wù)器，其特征在于，

所述前端設(shè)備：收集車輛數(shù)據(jù)；

所述通信服務(wù)器：接收上述前端設(shè)備采集的車輛數(shù)據(jù)；

所述分析服務(wù)器：接收上述由通信服務(wù)器傳輸?shù)那岸嗽O(shè)備采集的車輛數(shù)據(jù)并進行數(shù)據(jù)處理；

所述多個通信服務(wù)器組合為一個接收集群；

所述多個分析服務(wù)器組合為一個分析集群；

上述接收集群和分析集群中設(shè)置有集群管理器和集群服務(wù)器狀態(tài)列表；

上述集群管理器：根據(jù)服務(wù)器的工作負(fù)載性能數(shù)值，動態(tài)的分配連接地址，在上述通信服務(wù)器和前端設(shè)備間及分析服務(wù)器和通信服務(wù)器間建立通信，并負(fù)責(zé)整個集群中服務(wù)器的運行和對外的服務(wù)響應(yīng)；

上述集群服務(wù)器狀態(tài)列表：保存上述通信服務(wù)器和分析服務(wù)器自身的實時運行狀態(tài)和性能數(shù)值。

2.一種利用權(quán)利要求1所述的用于車輛數(shù)據(jù)接收和實時分析的集群分布式系統(tǒng)的方法，其特征在于，包括以下步驟：

前端設(shè)備向接收集群提出連接請求；

上述接收集群中的集群管理器接收到上述請求并根據(jù)接收集群內(nèi)集群服務(wù)器狀態(tài)列表中的通信服務(wù)器的實時運行狀態(tài)和性能數(shù)值計算通信服務(wù)器的工作負(fù)載性能數(shù)值；

上述接收集群中的集群管理器根據(jù)上述計算的工作負(fù)載性能數(shù)值分配連接地址；

上述接收集群中的集群管理器根據(jù)上述分配的連接地址在通信服務(wù)器與前端設(shè)備間建立通信；

上述接收集群中的集群管理器向分析集群提出連接請求；

上述分析集群中的集群管理器接收上述請求，并根據(jù)分析集群內(nèi)集群服務(wù)器狀態(tài)列表中的分析服務(wù)器的實時運行狀態(tài)和性能數(shù)值計算分析服務(wù)器的工作負(fù)載性能數(shù)值；

上述分析集群中的集群管理器根據(jù)上述工作負(fù)載性能數(shù)值分配連接地址；

上述分析集群中的集群管理器根據(jù)上述分配的連接地址在分析服務(wù)器和通信服務(wù)器間建立通信。

3.根據(jù)權(quán)利要求2所述的用于車輛數(shù)據(jù)接收和實時分析的集群分布式的方法，其特征在于，所述接收集群中的集群管理器接收到上述請求并根據(jù)接收集群內(nèi)集群服務(wù)器狀態(tài)列表中的通信服務(wù)器的實時運行狀態(tài)和性能數(shù)值計算通信服務(wù)器的工作負(fù)載性能數(shù)值，包括以下步驟：

上述集群管理器從集群服務(wù)器狀態(tài)列表中讀取通信服務(wù)器的實時運行狀態(tài)和性能數(shù)值；

上述集群管理器分析上述通信服務(wù)器的實時運行狀態(tài)和性能數(shù)值判斷上述集群服務(wù)器狀態(tài)列表中通信服務(wù)器的信息是否及時更新；

如通信服務(wù)器的信息沒有及時更新則從新讀取通信服務(wù)器的實時運行狀態(tài)和性能數(shù)值；

如通信服務(wù)器的信息得到及時更新集群管理器則根據(jù)上述通信服務(wù)器的信息計算通信服務(wù)器的工作負(fù)載性能數(shù)值。

4.根據(jù)權(quán)利要求2所述的用于車輛數(shù)據(jù)接收和實時分析的集群分布式的方法，其特征在于，所述分析集群中的集群管理器接收上述請求，并根據(jù)分析集群內(nèi)集群服務(wù)器狀態(tài)列表中的分析服務(wù)器的實時運行狀態(tài)和性能數(shù)值計算分析服務(wù)器的工作負(fù)載性能數(shù)值，包括以下步驟：

上述集群管理器從集群服務(wù)器狀態(tài)列表中讀取分析服務(wù)器的實時運行狀態(tài)和性能數(shù)值；

上述集群管理器分析上述分析服務(wù)器的實時運行狀態(tài)和性能數(shù)值判斷上述集群服務(wù)器狀態(tài)列表中分析服務(wù)器的信息是否及時更新；

如分析服務(wù)器的信息沒有及時更新則從新讀取分析服務(wù)器的實時運行狀態(tài)和性能數(shù)值；

如分析服務(wù)器的信息得到及時更新集群管理器則根據(jù)上述分析服務(wù)器的信息計算分析服務(wù)器的工作負(fù)載性能數(shù)值。

5.根據(jù)權(quán)利要求2、3或4所述的用于車輛數(shù)據(jù)接收和實時分析的集群分布式的方法，其特征在于，所述服務(wù)器的工作負(fù)載性能數(shù)值的計算公式如下：

F(C,M,N,H,L)?=?(p1*C?+?p2*M?+?p3*N?+?p4*H?+?p5*L?)/(?p1?+?p2?+?p3?+?p4?+?p5);

其中F值越高，表示該服務(wù)器的工作負(fù)載越重；

C表示：?CPU使用率，M?表示：內(nèi)存使用率，N表示：網(wǎng)絡(luò)帶寬使用率，H表示：硬盤緩存使用率，L表示：外部設(shè)備的連接比例，F(xiàn)?表示：工作負(fù)載量，Px表示：權(quán)重參數(shù)。