[發明專利]一種IPTV系統模塊間數據同步的方法及系統

有效

• 申請號: 200910081760.9
• 申請日: 2009-04-09
• 公開（公告）號: CN101526958A
• 公開（公告）日: 2009-09-09
• 發明（設計）人: 雷愛民;丁毅;朱紅軍
• 申請（專利權）人: 中興通訊股份有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30;H04N7/173
• 代理公司: 北京派特恩知識產權代理事務所（普通合伙）
• 代理人: 張穎玲;王黎延

技術領域

本發明涉及內存數據庫的數據同步技術，尤其涉及一種IPTV(交互式網絡電視)系統模塊間數據同步的方法及系統。?

背景技術

IPTV系統的相關數據分為靜態數據和動態數據兩類，其中，靜態數據指在系統運行過程中不發生變化的數據；動態數據指在系統運行過程中會發生變化的數據。IPTV系統中后臺、主控模塊、業務處理模塊的拓撲關系如圖1所示，其中，后臺一般為PC機，用于所述靜態數據的配置、更改，并將配置的或更改了的靜態數據同步至主控模塊；主控模塊，用于將接收到的靜態數據同步至各業務處理模塊，并用于將系統運行中發生變化的動態數據實時同步至各業務處理模塊，以便控制各業務處理模塊同步對外提供業務處理；業務處理模塊，負責處理業務，業務處理模塊的靜態數據和動態數據均由主控模塊同步獲得。?

這里，靜態數據和動態數據均存儲于主控模塊或各業務處理模塊的內存數據庫，即：所述主控模塊與各業務處理模塊間的數據同步為其上內存數據庫之間的數據同步。?

目前，常用的內存數據庫的數據同步方法是失步映像同步方法，具體為：預先設置失步隊列及定時器；當有記錄發生變化時，將該記錄的記錄號放入失步隊列，到達定時器的時長時檢查失步隊列中是否有記錄，如果有記錄，則將該記錄同步到對端；否則，不執行同步處理。此方法所需同步的數據量較大，且如果采用此方法實現主控模塊和多個業務處理模塊同步，則需要在主控模塊中為每個業務處理模塊分配一個失步隊列，以便標記是否需要將數據同步至該業務處理模塊、以及是否將數據成功同步至該業務處理模塊，即：系統中有幾?個業務處理模塊，就需要分配幾個失步隊列，這樣，會占用較大的內存空間，可見，此方法不適用于主控模塊和多個業務處理模塊同步。?

發明內容

有鑒于此，本發明的主要目的在于提供一種IPTV系統模塊間數據同步的方法及系統，能夠提高同步的實時性，并降低所需同步的數據量。?

為達到上述目的，本發明的技術方案是這樣實現的：?

一種IPTV系統模塊間數據同步的方法，該方法包括：?

主控模塊預先分配全局數據區，設置全局數組，所述全局數組包括：表名、記錄的關鍵字、操作類型、字段變化標記、變化的記錄內容、由模塊號組成的數組和由模塊號、同步標記和重發次數的對應關系；?

當主控模塊的內存數據庫中存在接收到的更新請求消息所攜帶表名和記錄的關鍵字對應的記錄時，主控模塊的更新進程根據所確定的記錄、所述更新請求消息攜帶的表名、記錄的關鍵字、操作類型、字段變化標記、以及在線的業務處理模塊的模塊號為所設置的全局數組中的相應成員賦值，并分別設置所述同步標記、重發次數的初始值，得到所確定的記錄對應的全局數組，并存儲在所述全局數據區；?

主控模塊根據發生變化的動態數據更新自身內存數據庫中動態表的記錄，并發送同步消息；?

收到同步消息的業務處理模塊，根據同步消息中所攜帶的操作類型，更新同步消息中攜帶的表名和記錄號所對應的自身內存數據庫中的記錄，并回復主控模塊應答同步消息；?

主控模塊的更新進程查詢全局數據區中下標與接收到的應答同步消息所攜帶數組下標一致的全局數組，將所述全局數組中接收到的應答同步消息所攜帶模塊號對應的同步標記的值改為TRUE；確定所述全局數組中所有同步標記的值均為TRUE時，清除所述全局數組；?

主控模塊定時遍歷全局數據區，如果存在業務處理模塊對變化內容的同步狀態為失敗，則重新同步該變化內容。?

進一步地，所述主控模塊更新動態表中的記錄并發送同步消息具體為：?

動態數據發生變化后，主控模塊的業務進程根據發生變化的動態數據對動態表中的記錄進行刪除、插入或修改，更新動態表中的記錄，并發送攜帶所述動態表的表名、記錄號、所述記錄的關鍵字、對所述記錄進行操作的操作類型?和所述記錄的字段變化標記的更新請求消息至主控模塊的更新進程；?

主控模塊的更新進程確定收到的更新請求消息所攜帶操作類型是插入、修改還是刪除，如果是插入或修改，則主控模塊的更新進程判斷主控模塊的內存數據庫中是否存在收到的更新請求消息所攜帶表名和記錄的關鍵字對應的記錄，如果存在，則將該記錄中字段變化標記所對應元素作為該記錄的變化內容，并發送攜帶所述表名、記錄號、操作類型、字段變化標記和變化內容的同步消息至在線的業務處理模塊；如果不存在，則結束本次同步流程；如果是刪除，主控模塊的更新進程發送同步消息至在線的業務處理模塊。?