[發明專利]一種數據同步方法及裝置

在審

• 申請號: 201610195298.5
• 申請日: 2016-03-30
• 公開（公告）號: CN107295031A
• 公開（公告）日: 2017-10-24
• 發明（設計）人: 賈新禹;馬華標
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/24
• 代理公司: 北京國昊天誠知識產權代理有限公司11315
• 代理人: 黃熊

1.一種數據同步方法，其特征在于，所述方法用于實現不同業務服務器之間的數據同步，所述業務服務器與分布式集群連接，所述業務服務器預先在所述分布式集群中注冊為監聽對象，所述方法包括：

當所述分布式集群監聽到作為監聽對象的一個業務服務器上的數據發生變化后，向作為監聽對象的各個業務服務器發送數據同步請求，以便各個業務服務器在接收所述數據同步請求后，通過所述分布式集群進行數據同步。

2.如權利要求1所述的方法，其特征在于，所述分布式集群具體為Zookeeper分布式集群；則，

在所述Zookeeper分布式集群中，通過下述方法將所述業務服務器注冊為監聽對象：

所述Zookeeper分布式集群接收業務服務器發送的注冊成為監聽對象的業務請求；

所述Zookeeper分布式集群通過所述業務請求生成用于監聽所述業務服務器的監聽節點。

3.如權利要求2所述的方法，其特征在于，所述Zookeeper分布式集群通過下述方法監聽到作為監聽對象的業務服務器上的數據發生變化：

當所述Zookeeper分布式集群監聽到作為監聽對象的業務服務器對監聽節點進行數據操作時，確定所述業務服務器上的數據發生變化，所述數據操作具體為所述業務服務器根據所述業務服務器上的數據變化的結果，對所述Zookeeper分布式集群上的監聽節點進行的數據操作。

4.如權利要求3所述的方法，其特征在于，所述數據操作具體包括：數據寫入和/或數據刪除。

5.如權利要求4所述的方法，其特征在于，所述作為監聽對象的業務服務器對監聽節點進行數據寫入具體包括：

所述業務服務器向所述Zookeeper分布式集群發送加分布式鎖的業務請 求，以便所述Zookeeper分布式集群根據所述分布式鎖的使用狀態判斷是否能夠向所述業務服務器加分布式鎖；

當所述業務服務器加分布式鎖后，對所述監聽節點進行數據寫入。

6.如權利要求4所述的方法，其特征在于，所述作為監聽對象的業務服務器對監聽節點進行數據刪除具體包括：所述業務服務器刪除所述監聽節點中所述數據的存儲路徑。

7.如權利要求1所述的方法，其特征在于，所述分布式集群包括至少兩個同步服務器，所述同步服務器與業務服務器連接并且各個同步服務器之間的數據能夠同步；則，

所述通過所述分布式集群進行數據同步具體包括：通過所述分布式集群中與各所述業務服務器連接的同步服務器進行數據同步。

8.一種數據同步方法，其特征在于，所述方法用于實現不同業務服務器之間的數據同步，所述業務服務器與分布式集群連接，所述業務服務器預先在所述分布式集群中注冊為監聽對象，所述方法包括：

作為監聽對象的各個業務服務器接收數據同步請求，所述數據同步請求為所述分布式集群在監聽到作為監聽對象的一個業務服務器上的數據發生變化后，向作為監聽對象的各個業務服務器發送的數據同步請求；

作為監聽對象的各個業務服務器在接收數據同步請求后，通過所述分布式集群進行數據同步。

9.一種數據同步裝置，其特征在于，所述裝置用于實現不同業務服務器之間的數據同步，所述業務服務器與分布式集群連接，所述業務服務器預先在所述分布式集群中注冊為監聽對象，所述裝置包括：監聽單元和發送單元，其中：

監聽單元，用于所述分布式集群監聽作為監聽對象的各個業務服務器上的數據是否發生變化；

發送單元，用于當所述分布式集群監聽到作為監聽對象的一個業務服務器 上的數據發生變化后，向作為監聽對象的各個業務服務器發送數據同步請求，以便各個業務服務器在接收所述數據同步請求后，通過所述分布式集群進行數據同步。

10.一種數據同步裝置，其特征在于，所述裝置用于實現不同業務服務器之間的數據同步，所述業務服務器與分布式集群連接，所述業務服務器預先在所述分布式集群中注冊為監聽對象，所述裝置包括：接收單元和同步單元，其中：

接收單元，用于作為監聽對象的各個業務服務器接收數據同步請求，所述數據同步請求為所述分布式集群在監聽到作為監聽對象的一個業務服務器上的數據發生變化后，向作為監聽對象的各個業務服務器發送的數據同步請求；

同步單元，用于作為監聽對象的各個業務服務器在接收數據同步請求后，通過所述分布式集群進行數據同步。