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

有效

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

1.一種IPTV系統模塊間數據同步的方法，其特征在于，該方法包括：

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

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

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

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

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

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

2.根據權利要求1所述的IPTV系統模塊間數據同步的方法，其特征在于，所述主控模塊更新動態表中的記錄并發送同步消息具體為：

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

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

3.根據權利要求1所述的IPTV系統模塊間數據同步的方法，其特征在于，主控模塊在發送同步消息至業務處理模塊時，設置同步定時器；同步定時器超時時，所述定時遍歷全局數據區時，如果存在的業務處理模塊對變化內容的同步狀態為失敗，則重新同步該變化內容為：

A、主控模塊的更新進程遍歷全局數據區，確定全局數據區中全局數組中是否存在值為FALSE的同步標記，如果不存在，則清除該全局數組，結束本次超時同步操作；如果存在，則執行步驟B；

B、確定所述同步標記對應的重發次數的值小于預先設定的重發次數的閾值，則判斷主控模塊的內存數據庫中是否存在該全局數組所包括的表名和記錄的關鍵字對應的記錄，如果存在，則將該記錄中字段變化標記所對應元素作為該記錄的變化內容，并發送同步消息至在線的各業務處理模塊，將所述同步標記對應的重發次數的值加1，并重置所述同步定時器，結束本次超時同步操作；如果不存在，則清除該全局數組，結束本次超時同步操作。

4.根據權利要求3所述的IPTV系統模塊間數據同步的方法，其特征在于，該方法進一步包括定時同步，具體為：

每隔設定時間，確定主控模塊向業務處理模塊同步的變化內容中存在還未同步成功的變化內容，業務處理模塊向主控模塊發送同步請求消息；

主控模塊接收到同步請求消息后，將主控模塊內存數據庫中存在未同步成功的變化內容的動態表回復至業務處理模塊。