[發明專利]一種數據同步方法、裝置和系統

在審

• 申請號: 201710967306.8
• 申請日: 2017-10-17
• 公開（公告）號: CN107908481A
• 公開（公告）日: 2018-04-13
• 發明（設計）人: 衛海波
• 申請（專利權）人: 鏈家網（北京）科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京路浩知識產權代理有限公司11002
• 代理人: 王瑩,李相雨

1.一種數據同步方法，其特征在于，包括：

實時獲取各數據提供方在發生數據變更時生成的對應的事件通知；

將獲取的事件通知添加到事件任務表中；

啟動事件消費進程讀取所述事件任務表中的事件通知，并將讀取的事件通知發送給數據需求方，以供數據需求方根據所述事件通知從所述數據提供方獲取變更后的數據。

2.根據權利要求1所述的方法，其特征在于，實時獲取各數據提供方在發生數據變更時生成的對應的事件通知，包括：

針對每個數據提供方，啟動事件拉取進程實時從該數據提供方提供的輸出接口，拉取數據提供方在發生數據變更時生成的對應的事件通知；和/或

針對每個數據提供方，通過預設的接收接口實時接收該數據提供方推送的該數據提供方在發生數據變更時生成的對應的事件通知。

3.根據權利要求1所述的方法，其特征在于，所述啟動事件消費進程讀取所述事件任務表中的事件通知，包括：

根據所述事件任務表中的事件通知數量，啟動一個或多個事件消費進程讀取所述事件任務表中的事件通知；

其中，對于事件任務表中的每個事件通知，該事件通知被一個事件消費進程讀取后，將從所述事件任務表中剔除。

4.根據權利要求3所述的方法，其特征在于，所述事件通知包括：發生數據變更的數據的數據類型；

所述啟動事件消費進程讀取所述事件任務表中的事件通知，包括：

啟動事件消費進程讀取所述事件任務表中具有預設的待同步的數據類型的事件通知。

5.根據權利要求2所述的方法，其特征在于，還包括：

在所述數據需求方未成功獲取變更后的數據時，接收所述數據需求方返回的消費失敗信息；

將接收的消費失敗信息所針對的事件通知添加到預設的事件消費失敗表中；

啟動失敗任務處理進程將所述事件消費失敗表中的事件通知重新添加到所述事件任務表中。

6.根據權利要求5所述的方法，其特征在于，還包括：

通過預設的管理進程對啟動的數據同步進程進行監控；監控到異常的數據同步進程時，停止異常的數據同步進程，并啟動新的數據同步進程；

其中，所述數據同步進程包括；事件消費進程、事件拉取進程和失敗任務處理進程。

7.一種數據同步裝置，其特征在于，包括：

事件通知獲取模塊，用于實時獲取各數據提供方在發生數據變更時生成的對應的事件通知；

事件通知添加模塊，用于將獲取的事件通知添加到事件任務表中；

數據同步模塊，用于啟動事件消費進程讀取所述事件任務表中的事件通知，并將讀取的事件通知發送給數據需求方，以供數據需求方根據所述事件通知從所述數據提供方獲取變更后的數據。

8.一種數據同步系統，其特征在于，包括：如權利要求7所述的數據同步裝置，以及與所述數據同步裝置連接的數據提供方和數據需求方。

9.一種電子設備，其特征在于，包括處理器、存儲器和總線，其中：

所述處理器，所述存儲器通過總線完成相互間的通信；

所述處理器可以調用存儲器中的計算機程序，以執行如權利要求1-7任意一項所述的方法的步驟。

10.一種計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，該程序被處理器執行時實現如權利要求1-7任意一項所述方法的步驟。