[發明專利]一種分布式系統及其數據同步方法

有效

• 申請號: 201010131403.1
• 申請日: 2010-03-24
• 公開（公告）號: CN102202073A
• 公開（公告）日: 2011-09-28
• 發明（設計）人: 鐘果;朱海濤
• 申請（專利權）人: 杭州華三通信技術有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京鑫媛睿博知識產權代理有限公司 11297
• 代理人: 龔家驊

技術領域

本發明涉及通信技術領域，特別是涉及一種分布式系統及其數據同步方法。

背景技術

隨著企業信息及業務的越來越龐大，在企業信息化的過程中，對于企業信息系統來說，業務分布式安裝部署已經成為了最好的選擇，而在分布式系統中，信息的存儲方式是通過數據庫進行存儲的。其中，主數據庫用于保存用戶的配置信息或者業務匯總信息，并由用戶進行業務配置信息及匯總信息的展示；而業務數據庫用于存儲業務數據，當用戶界面需要展示具體的業務信息時，則需要到對應的業務數據庫中進行查詢。

如圖1所示，為一種分布式系統的結構示意圖，其中，主數據庫為業務配置數據庫Master，與分布式主服務器相對應，而各個業務數據庫(例如，業務數據庫slave1和業務數據庫slave2)與分布式業務服務器相對應。當用戶對業務進行配置，并存儲到主數據庫時，則需要將相應的配置信息從主數據庫中同步到相關的業務數據庫中，以保持主數據庫和業務數據庫中配置信息的一致性。

在現有技術中，主數據庫和業務數據庫需要同步的配置信息均在系統開發時就確定了，例如，當該配置信息中包括相應的表、字段、唯一標識等信息時，則在系統開發時需要確定同步哪些表，哪些字段，以及表的唯一標識等配置信息。

但是，本申請發明人在實現過程中發現，在現有技術實際應用中存在以下問題：在分布式系統上線之后，需要新增一些配置信息的同步需求時，這些配置信息無法從主數據庫中自動同步到相應的業務數據庫中，因而需要對現有的分布式系統進行重新開發，而且新增分布式服務器之間需要同步數據時，也需要對原有分布式系統重新進行適配開發，從而導致缺乏通用性和擴展性。例如，分布式系統開發時確定需要同步表A的A字段，如果新增同步需求為同步表A的B字段，則需要對現有的分布式系統進行重新開發，重新開發后的分布式系統確定需要同步表A的A字段和B字段。

發明內容

本發明提供一種分布式系統及其數據同步方法，以實現數據表的自動同步，簡化開化的復雜度。

為了達到上述目的，本發明提出了一種分布式系統的數據同步方法，該方法應用于包括主服務器和至少一個業務服務器的分布式系統中，所述方法包括以下步驟：

當監控到所述主服務器所存儲的數據表的數據被更新時，確定是否需要將被更新的所述數據表的數據同步到對應的業務服務器；

如果需要將被更新的所述數據表的數據同步到對應的所述業務服務器時，則獲取被更新的所述數據表的配置信息以及對應的所述業務服務器的地址信息；

根據獲取的所述配置信息生成同步通知報文，并將生成的所述同步通知報文通過獲取的所述地址信息發送給所述業務服務器；

所述業務服務器根據接收的所述同步通知報文中的所述配置信息，對被更新的所述數據表的數據進行同步。

確定是否需要將被更新的所述數據表的數據同步到對應的業務服務器，具體包括：

判斷被更新的所述數據表的表名是否記錄在預先維護的業務列表中，若被更新的所述數據表的所述表名記錄在所述業務列表中，則確定需要將被更新的所述數據表的數據同步到對應的所述業務服務器；

其中，所述業務列表中記錄了需要同步到所述業務服務器的數據表的表名以及該表名對應的業務標識。

所述方法還包括：

當在所述業務服務器中新增所述需要同步的數據表時，將所述需要同步的數據表的表名以及該表名對應的業務標識添加到所述業務列表。

獲取被更新的所述數據表的配置信息以及對應的所述業務服務器的地址信息，具體包括：

根據被更新的所述數據表的表名，從所述系統數據庫的系統表中獲取被更新的數據表的所述配置信息；以及

在所述業務列表中查找被更新的所述數據表的表名對應的所述業務標識；并根據查找到的所述業務標識，從所述主服務器上預先存儲的業務服務地址表中獲取與查找到的所述業務標識對應的所述地址信息。

所述數據表的所述配置信息至少包括：表名、字段名信息、字段類型信息、唯一性標識信息；

根據獲取的所述配置信息生成同步通知報文，具體包括：

根據所述表名、所述字段名信息、所述字段類型信息以及所述唯一性標識信息生成所述同步通知報文。

所述業務服務器根據接收的所述同步通知報文中的所述配置信息，對被更新的所述數據表的數據進行同步，具體包括：

所述業務服務器解析接收的所述同步通知報文，以獲取所述表名、所述字段名信息、所述字段類型信息以及所述唯一性標識信息；