[發明專利]用于數據系統的數據同步方法和裝置

有效

• 申請號: 201610080311.2
• 申請日: 2016-02-04
• 公開（公告）號: CN107038174B
• 公開（公告）日: 2020-11-24
• 發明（設計）人: 溫圣堂
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27
• 代理公司: 北京英賽嘉華知識產權代理有限責任公司 11204
• 代理人: 王達佐;馬曉亞

1.一種用于數據系統的數據同步方法，其特征在于，所述數據系統包括數據庫服務器、緩存服務器以及應用服務器集群，所述方法包括：

通過應用服務器集群中的各個應用服務器向所述緩存服務器申請更新鎖；

使用申請到更新鎖的應用服務器查詢所述數據庫服務器中的數據；

將所述應用服務器從所述數據庫服務器中查詢到的數據同步至所述緩存服務器。

2.根據權利要求1所述的方法，其特征在于，在將從所述數據庫服務器中查詢的數據同步至所述緩存服務器之后，所述方法還包括：

釋放所述應用服務器申請到的更新鎖。

3.根據權利要求2所述的方法，其特征在于，在所述使用申請到鎖的應用服務器查詢所述數據庫服務器中的數據之后，所述方法還包括：

將所述應用服務器從所述數據庫服務器中查詢的數據同步至運行于所述應用服務器中的應用中。

4.根據權利要求2所述的方法，其特征在于，在所述通過應用服務器集群中的各個服務器向所述緩存服務器申請更新鎖之后，所述方法還包括：

將所述緩存服務器中的數據同步至所述應用服務器集群中未申請到所述更新鎖的應用服務器。

5.根據權利要求2所述的方法，其特征在于，所述通過應用服務器集群中的各個服務器向所述緩存服務器申請更新鎖，包括：

獲取所述緩存服務器中預先存儲的更新時間，所述更新時間是所述緩存服務器上次從所述數據庫服務器進行數據同步的時間；

在當前時間與所述更新時間之差達到預設時長時，通過所述應用服務器集群中的各個服務器向所述緩存服務器申請更新鎖；以及

在所述將從所述數據庫服務器中查詢的數據同步至所述緩存服務器之后，所述方法還包括：

將所述更新時間設置為當前時間。

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

在當前時間與所述更新時間之差未達到預設時長時，將所述緩存服務器中的數據同步至所述應用服務器集群中的各個應用服務器。

7.根據權利要求5或6所述的方法，其特征在于，所述更新鎖設置有失效時間。

8.根據權利要求7所述的方法，其特征在于，所述失效時間設置為所述預設時長的一半。

9.一種用于數據系統的數據同步裝置，其特征在于，所述數據系統包括數據庫服務器、緩存服務器以及應用服務器集群，所述裝置包括：

申請單元，用于通過應用服務器集群中的各個應用服務器向所述緩存服務器申請更新鎖；

查詢單元，用于使用申請到更新鎖的應用服務器查詢所述數據庫服務器中的數據；

第一同步單元，用于將所述應用服務器從所述數據庫服務器中查詢到的數據同步至所述緩存服務器。

10.根據權利要求9所述的裝置，其特征在于，所述裝置還包括：

釋放單元，用于釋放所述應用服務器申請到的更新鎖。

11.根據權利要求10所述的裝置，其特征在于，所述裝置還包括：

第二同步單元，用于將所述應用服務器從所述數據庫服務器中查詢的數據同步至運行于所述應用服務器中的應用中。

12.根據權利要求10所述的裝置，其特征在于，所述申請單元，包括：

獲取子單元，用于獲取所述緩存服務器中預先存儲的更新時間，所述更新時間是所述緩存服務器上次從所述數據庫服務器進行數據同步的時間；

申請子單元，用于在當前時間與所述更新時間之差達到預設時長時，通過所述應用服務器集群中的各個服務器向所述緩存服務器申請更新鎖；以及

所述裝置還包括時間設置單元，用于在將從所述數據庫服務器中查詢的數據同步至所述緩存服務器之后，將所述更新時間設置為當前時間。