[發(fā)明專利]數(shù)據(jù)實(shí)時(shí)同步系統(tǒng)及方法

在審

• 申請(qǐng)?zhí)枺?/td>: 201410176486.4
• 申請(qǐng)日: 2014-04-29
• 公開（公告）號(hào): CN103942324A
• 公開（公告）日: 2014-07-23
• 發(fā)明（設(shè)計(jì)）人: 王堃;莫增文;韓亞榮;史麗坤;孫浩宇;王強(qiáng)
• 申請(qǐng)（專利權(quán)）人: 北京中科啟信軟件技術(shù)有限公司
• 主分類號(hào): G06F17/30
• 分類號(hào): G06F17/30;H04L29/08
• 代理公司: 北京匯澤知識(shí)產(chǎn)權(quán)代理有限公司 11228
• 代理人: 朱振德

1.一種數(shù)據(jù)實(shí)時(shí)同步系統(tǒng)，其特征在于，包括：

同步內(nèi)容管理器，用于根據(jù)用戶配置的數(shù)據(jù)庫標(biāo)簽點(diǎn)之間的映射關(guān)系獲取同步配置信息；

數(shù)據(jù)訂閱管理器，用于根據(jù)所述同步配置信息生成訂閱請(qǐng)求并發(fā)送到源端數(shù)據(jù)庫，還用于接收源端數(shù)據(jù)庫根據(jù)所述訂閱請(qǐng)求生成的訂閱結(jié)果，并將訂閱結(jié)果發(fā)送給所述同步內(nèi)容管理器；

多路任務(wù)調(diào)度器，用于接收所述同步內(nèi)容管理器接收到的訂閱結(jié)果，并對(duì)其中的數(shù)據(jù)進(jìn)行整理和調(diào)度處理；

數(shù)據(jù)篩選器，用于對(duì)所述多路任務(wù)調(diào)度器整理和調(diào)度處理后的數(shù)據(jù)進(jìn)行壓縮處理、濾波處理或條件篩選處理；

實(shí)時(shí)通信中間件，用于將所述數(shù)據(jù)篩選器處理后的數(shù)據(jù)發(fā)送到相應(yīng)的目的端數(shù)據(jù)庫，完成同步。

2.根據(jù)權(quán)利要求1所述的數(shù)據(jù)實(shí)時(shí)同步系統(tǒng)，其特征在于，還包括：

通用文件緩存器，用于在無法與目的端數(shù)據(jù)庫建立連接時(shí)，對(duì)需要同步的數(shù)據(jù)進(jìn)行緩存；并在與目的端數(shù)據(jù)庫建立連接后，將緩存的數(shù)據(jù)發(fā)送到目的端數(shù)據(jù)庫。

3.根據(jù)權(quán)利要求2所述的數(shù)據(jù)實(shí)時(shí)同步系統(tǒng)，其特征在于，所述實(shí)時(shí)通信中間件在將高頻的小包數(shù)據(jù)發(fā)送到目的端數(shù)據(jù)庫之前，先將高頻的小包數(shù)據(jù)緩存到內(nèi)存，待緩存的數(shù)據(jù)達(dá)到一定閾值或緩存時(shí)間超出設(shè)定的時(shí)間時(shí)，再將緩存的數(shù)據(jù)發(fā)送到對(duì)應(yīng)目的端數(shù)據(jù)庫。

4.根據(jù)權(quán)利要求1所述的數(shù)據(jù)實(shí)時(shí)同步系統(tǒng)，其特征在于，所述數(shù)據(jù)篩選器對(duì)數(shù)據(jù)進(jìn)行條件篩選所依據(jù)的條件由用戶配置或預(yù)先設(shè)置。

5.根據(jù)權(quán)利要求1所述的數(shù)據(jù)實(shí)時(shí)同步系統(tǒng)，其特征在于，所述實(shí)時(shí)通信中間件根據(jù)所述多路任務(wù)調(diào)度器的調(diào)度也采用多個(gè)通路將同步數(shù)據(jù)發(fā)送到對(duì)應(yīng)的目的端數(shù)據(jù)庫。

6.一種數(shù)據(jù)實(shí)時(shí)同步方法，其特征在于，包括：

A、根據(jù)用戶配置的數(shù)據(jù)庫標(biāo)簽點(diǎn)之間的映射關(guān)系獲取同步配置信息；

B、根據(jù)所述同步配置信息生成訂閱請(qǐng)求并發(fā)送到源端數(shù)據(jù)庫，所述源端數(shù)據(jù)庫根據(jù)所述訂閱請(qǐng)求生成訂閱結(jié)果；

C、根據(jù)訂閱結(jié)果，對(duì)其中的數(shù)據(jù)進(jìn)行整理和調(diào)度處理；

D、對(duì)整理和調(diào)度處理后的數(shù)據(jù)進(jìn)行壓縮處理、濾波處理或條件篩選處理；

E、將所述壓縮處理、濾波處理或條件篩選處理后的數(shù)據(jù)發(fā)送到相應(yīng)的目的端數(shù)據(jù)庫，完成同步。

7.根據(jù)權(quán)利要求6所述的數(shù)據(jù)實(shí)時(shí)同步方法，其特征在于，所述步驟E中，在無法與目的端數(shù)據(jù)庫建立連接時(shí)，對(duì)需要同步的數(shù)據(jù)進(jìn)行緩存；并在與目的端數(shù)據(jù)庫建立連接后，將緩存的數(shù)據(jù)發(fā)送到目的端數(shù)據(jù)庫。

8.根據(jù)權(quán)利要求6所述的數(shù)據(jù)實(shí)時(shí)同步方法，其特征在于，所述步驟E中，在將所述壓縮處理、濾波處理或條件篩選處理后的數(shù)據(jù)發(fā)送到相應(yīng)的目的端數(shù)據(jù)庫前，先緩存高頻的小包數(shù)據(jù)，待緩存的數(shù)據(jù)達(dá)到一定閾值或緩存時(shí)間超出設(shè)定的時(shí)間時(shí)，將緩存的數(shù)據(jù)發(fā)送到對(duì)應(yīng)目的端數(shù)據(jù)庫。

9.根據(jù)權(quán)利要求6所述的數(shù)據(jù)實(shí)時(shí)同步方法，其特征在于，所述步驟E中，對(duì)數(shù)據(jù)進(jìn)行條件篩選所依據(jù)的條件由用戶配置或預(yù)先設(shè)置。

10.根據(jù)權(quán)利要求6所述的數(shù)據(jù)實(shí)時(shí)同步方法，其特征在于，所述步驟E中，根據(jù)所述多路任務(wù)調(diào)度器的調(diào)度采用多個(gè)通路將同步數(shù)據(jù)發(fā)送到對(duì)應(yīng)的目的端數(shù)據(jù)庫。