[發(fā)明專利]支持多協(xié)議多類型的實(shí)時數(shù)據(jù)同步的系統(tǒng)和方法

有效

• 申請?zhí)枺?/td>: 201210372287.1
• 申請日: 2012-09-28
• 公開（公告）號: CN102868760A
• 公開（公告）日: 2013-01-09
• 發(fā)明（設(shè)計）人: 龔云;曹東;李建濤
• 申請（專利權(quán)）人: 南京奇幻通信科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L29/06
• 代理公司: 北京萬慧達(dá)知識產(chǎn)權(quán)代理有限公司 11111
• 代理人: 于淼;楊穎

技術(shù)領(lǐng)域

本發(fā)明涉及數(shù)據(jù)傳輸領(lǐng)域，尤其是一種支持多協(xié)議多類型的實(shí)時數(shù)據(jù)同步的系統(tǒng)和方法。

背景技術(shù)

全球經(jīng)濟(jì)的繁榮大大得益于信息技術(shù)的蓬勃發(fā)展，正因?yàn)槿绱耍畔τ诋?dāng)今所有企業(yè)來說都至關(guān)重要，數(shù)據(jù)正日漸成為企業(yè)的戰(zhàn)略資產(chǎn)，隨著數(shù)據(jù)對企業(yè)決策的重要性的提升，其準(zhǔn)確性、及時性和安全性也得到世人前所未有的重視。

以往，企業(yè)數(shù)據(jù)基礎(chǔ)架構(gòu)面臨的問題并不十分復(fù)雜，比如企業(yè)信息通常保存在一個數(shù)據(jù)中心、數(shù)據(jù)一般以KB字節(jié)計量僅最大和最復(fù)雜的數(shù)據(jù)以MB字節(jié)計量、報表以批處理方式運(yùn)行但統(tǒng)計結(jié)果經(jīng)常延遲，企業(yè)內(nèi)普遍為單一供應(yīng)商環(huán)境等等。但是，隨著全球經(jīng)濟(jì)一體化程度的逐漸加深，企業(yè)組織面臨的狀況極盡復(fù)雜——大部分企業(yè)在某領(lǐng)域甚至是全領(lǐng)域的業(yè)務(wù)中展開合作，互相共享數(shù)據(jù)，但是由于各合作企業(yè)的地理位置差異，致使與企業(yè)業(yè)務(wù)相關(guān)的數(shù)據(jù)信息零散地存儲于各地的服務(wù)器中，頻繁交易使得數(shù)據(jù)分布的速率日益加快，數(shù)據(jù)量的激增及數(shù)據(jù)分散狀況的加劇給數(shù)據(jù)管理帶來更大的難度。

目前，合作企業(yè)間的數(shù)據(jù)同步技術(shù)都是針對特定的數(shù)據(jù)類型，進(jìn)行單一的傳輸協(xié)議以實(shí)現(xiàn)同步。但是，各企業(yè)保存的數(shù)據(jù)在格式上不同，使用的傳輸協(xié)議也不相同，從而造成數(shù)據(jù)傳輸緩慢甚至停滯。

發(fā)明內(nèi)容

本發(fā)明所要解決的技術(shù)問題是提供一種支持多協(xié)議多類型的實(shí)時數(shù)據(jù)同步的系統(tǒng)和方法，以解決合作企業(yè)間的數(shù)據(jù)同步只能針對特定數(shù)據(jù)類型、單一傳輸協(xié)議的問題。

為了解決上述問題，本發(fā)明提供了一種支持多協(xié)議多類型的實(shí)時數(shù)據(jù)同步的系統(tǒng)，其特征在于，包括：后臺同步管理模塊、數(shù)據(jù)采集模塊、數(shù)據(jù)同步模塊；其中，

所述后臺同步管理模塊，與數(shù)據(jù)同步模塊相耦接，用于接收并存儲支持?jǐn)?shù)據(jù)同步的定制內(nèi)容；

所述數(shù)據(jù)采集模塊，與所述數(shù)據(jù)同步模塊相耦接，用于對采集到的需要進(jìn)行同步的信息掃描并提取數(shù)據(jù)，然后對相同類型和相同傳輸協(xié)議的數(shù)據(jù)進(jìn)行組裝后發(fā)送給所述數(shù)據(jù)同步模塊；

所述數(shù)據(jù)同步模塊，分別與所述后臺同步管理模塊和數(shù)據(jù)采集模塊相耦接，用于對接收的組裝后的數(shù)據(jù)根據(jù)所述后臺同步管理模塊中所述定制內(nèi)容進(jìn)行同步操作，然后輸出同步后的數(shù)據(jù)。

進(jìn)一步，其中，所述后臺同步管理模塊接收并存儲支持?jǐn)?shù)據(jù)同步的定制內(nèi)容包括：數(shù)據(jù)類型、傳輸協(xié)議、參數(shù)設(shè)定、掃描周期、傳輸編碼以及失敗處理方案。

進(jìn)一步，其中，所述數(shù)據(jù)采集模塊包括：采集處理單元、掃描提取單元和數(shù)據(jù)組裝單元；其中，

所述采集處理單元，與所述掃描提取單元相耦接，用于采集不同通道發(fā)送的需要進(jìn)行同步的信息，并判斷處理通道上是否出現(xiàn)數(shù)據(jù)處理阻塞，如出現(xiàn)數(shù)據(jù)處理阻塞，則進(jìn)入等待，根據(jù)設(shè)定的固定時間再進(jìn)行判斷處理通道上是否出現(xiàn)數(shù)據(jù)處理阻塞；如未出現(xiàn)數(shù)據(jù)處理阻塞，則將所述需要進(jìn)行同步的信息發(fā)送給所述掃描提取單元；

所述掃描提取單元，與所述采集處理單元和數(shù)據(jù)組裝單元相耦接，用于接收所述采集處理單元發(fā)送的所述需要進(jìn)行同步的信息進(jìn)行掃描并提取數(shù)據(jù)，將提取出的數(shù)據(jù)發(fā)送給所述數(shù)據(jù)組裝單元；

所述數(shù)據(jù)組裝單元，與所述掃描提取單元相耦接，用于對相同類型和相同傳輸協(xié)議的數(shù)據(jù)進(jìn)行組裝后發(fā)送給所述數(shù)據(jù)同步模塊。

進(jìn)一步，其中，所述數(shù)據(jù)同步模塊，進(jìn)一步為：用于對組裝后的相同類型和相同傳輸協(xié)議的數(shù)據(jù)，根據(jù)從所述后臺同步管理模塊中所述定制內(nèi)容進(jìn)行同步操作，如同步成功，則將同步后的數(shù)據(jù)輸出；如同步不成功，則繼續(xù)根據(jù)所述定制內(nèi)容進(jìn)行同步操作。

為了解決上述問題，本發(fā)明還提供了一種支持多協(xié)議多類型的實(shí)時數(shù)據(jù)同步的方法，其特征在于，包括：

接收并存儲支持?jǐn)?shù)據(jù)同步的定制內(nèi)容；

對采集到的需要進(jìn)行同步的信息掃描并提取數(shù)據(jù)，然后對相同類型和相同傳輸協(xié)議的數(shù)據(jù)進(jìn)行組裝；

對所述組裝后的數(shù)據(jù)根據(jù)所述定制內(nèi)容進(jìn)行同步操作，然后輸出同步后的數(shù)據(jù)。

進(jìn)一步，其中，所述接收并存儲支持?jǐn)?shù)據(jù)同步的定制內(nèi)容包括：數(shù)據(jù)類型、傳輸協(xié)議、參數(shù)設(shè)定、掃描周期、傳輸編碼以及失敗處理方案。

進(jìn)一步，其中，所述對采集到的需要進(jìn)行同步的信息掃描并提取數(shù)據(jù)，然后對相同類型和相同傳輸協(xié)議的數(shù)據(jù)進(jìn)行組裝，進(jìn)一步為：

用于采集不同通道發(fā)送的需要進(jìn)行同步的信息，并判斷處理通道上是否出現(xiàn)數(shù)據(jù)處理阻塞，如出現(xiàn)數(shù)據(jù)處理阻塞，則進(jìn)入等待，根據(jù)設(shè)定的固定時間再進(jìn)行判斷處理通道上是否出現(xiàn)數(shù)據(jù)處理阻塞；如未出現(xiàn)數(shù)據(jù)處理阻塞，則執(zhí)行下一步；

將所述需要進(jìn)行同步的信息進(jìn)行掃描并提取數(shù)據(jù)；

對于所述提取數(shù)據(jù)，將相同類型和相同傳輸協(xié)議的數(shù)據(jù)進(jìn)行組裝。