[發明專利]用于車輛數據接收和實時分析的集群分布式系統及方法

有效

• 申請號: 201110361534.3
• 申請日: 2011-11-15
• 公開（公告）號: CN102510403A
• 公開（公告）日: 2012-06-20
• 發明（設計）人: 包可為
• 申請（專利權）人: 江蘇大為科技股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/12
• 代理公司: 北京中恒高博知識產權代理有限公司 11249
• 代理人: 夏晏平

技術領域

本發明涉及車輛數據接收和實時分析領域，具體地，涉及一種用于車輛數據接收和實時分析的集群分布式系統及方法。

背景技術

隨著我國汽車數量的不斷增加，需要對大量采集的車輛數據進行處理，而現有技術對車輛數據的接受和實時分析時仍采用如圖1所示的方法，在每個匯聚點上進行車輛數據的各種分析運算。而采用這樣的方式，在數據接收和數據分析上都是會有很大的延時，而且當一個匯聚點上的接收或者分析模塊宕機后，在匯聚點修復之前，整個匯聚點下的所有設備數據接受和分析都會中斷，造成數據的丟失或者成批量的數據長時間無法分析。

發明內容

本發明的目的在于，針對上述問題，提出一種用于車輛數據接收和實時分析的集群分布式系統及方法，以實現防止因一個匯聚點上的接收或者分析模塊宕機后造成的數據傳輸中斷，及因中斷造成的數據的丟失或者成批量的數據長時間無法分析的優點。

為實現上述目的，本發明采用的技術方案是：

一種用于車輛數據接收和實時分析的集群分布式系統，包括前端設備、通信服務器和分析服務器，

所述前端設備：收集車輛數據；

所述通信服務器：接收上述前端設備采集的車輛數據；

所述分析服務器：接收上述由通信服務器傳輸的前端設備采集的車輛數據并進行數據處理；

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

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

上述接收集群和分析集群中設置有集群管理器和集群服務器狀態列表；

上述集群管理器：根據服務器的工作負載性能數值，動態的分配連接地址，在上述通信服務器和前端設備間及分析服務器和通信服務器間建立通信，并負責整個集群中服務器的運行和對外的服務響應；

上述集群服務器狀態列表：保存上述通信服務器和分析服務器自身的實時運行狀態和性能數值。

一種用于車輛數據接收和實時分析的集群分布式的方法，包括以下步驟：

前端設備向接收集群提出連接請求；

上述接收集群中的集群管理器接收到上述請求并根據接收集群內集群服務器狀態列表中的通信服務器的實時運行狀態和性能數值計算通信服務器的工作負載性能數值；

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

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

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

上述分析集群中的集群管理器接收上述請求，并根據分析集群內集群服務器狀態列表中的分析服務器的實時運行狀態和性能數值計算分析服務器的工作負載性能數值；

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

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

根據本發明的優選實施例，所述接收集群中的集群管理器接收到上述請求并根據接收集群內集群服務器狀態列表中的通信服務器的實時運行狀態和性能數值計算通信服務器的工作負載性能數值，包括以下步驟：

上述集群管理器從集群服務器狀態列表中讀取通信服務器的實時運行狀態和性能數值；

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

如通信服務器的信息沒有及時更新則從新讀取通信服務器的實時運行狀態和性能數值；

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

根據本發明的優選實施例，所述分析集群中的集群管理器接收上述請求，并根據分析集群內集群服務器狀態列表中的分析服務器的實時運行狀態和性能數值計算分析服務器的工作負載性能數值，包括以下步驟：

上述集群管理器從集群服務器狀態列表中讀取分析服務器的實時運行狀態和性能數值；

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

如分析服務器的信息沒有及時更新則從新讀取分析服務器的實時運行狀態和性能數值；

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

根據本發明的優選實施例，所述服務器的工作負載性能數值的計算公式如下：