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

有效

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

本申請公開了用于數據系統的數據同步方法和裝置。所述方法的一具體實施方式包括：通過應用服務器集群中的各個應用服務器向所述緩存服務器申請更新鎖；使用申請到更新鎖的應用服務器查詢所述數據庫服務器中的數據；將所述應用服務器從所述數據庫服務器中查詢到的數據同步至所述緩存服務器。該實施方式避免數據庫服務器同時被多個設備訪問而造成峰值壓力等問題，并且也不會引入新的系統。

技術領域

本申請涉及計算機技術領域，具體涉及網絡技術領域，尤其涉及用于數據系統的數據同步方法和裝置。

背景技術

隨著互聯網技術的快速發展，越來越多的數據系統采用分布式集群系統部署方式。然而在分布式集群式系統中，如何將數據庫系統中的數據同步到集群中的各個應用實例內存中以實現數據的定時屬性功能，是一個需要解決的重要技術問題。

現有技術中，一種數據同步方法是使各個應用系統直接從數據庫系統讀取數據以實現數據更新，另一種是通過數據更新系統將數據庫系統的數據先同步至緩存系統而各個應用系統從緩存系統讀取數據。前者使得多個應用系統可能同時訪問數據庫系統，導致數據庫系統訪問壓力增大；后者則需要引入新的數據更新系統，需要維護多個系統，增加系統故障的概率。

發明內容

本申請的目的在于提出一種用于數據系統的數據同步方法和裝置，來解決以上背景技術部分提到的技術問題。

第一方面，本申請提供了一種用于數據系統的數據同步方法，所述數據系統包括數據庫服務器、緩存服務器以及應用服務器集群，所述方法包括：通過應用服務器集群中的各個應用服務器向所述緩存服務器申請更新鎖；使用申請到更新鎖的應用服務器查詢所述數據庫服務器中的數據；將所述應用服務器從所述數據庫服務器中查詢到的數據同步至所述緩存服務器。

在一些實施例中，在將從所述數據庫服務器中查詢的數據同步至所述緩存服務器之后，所述方法還包括：釋放所述應用服務器申請到的更新鎖。

在一些實施例中，在所述使用申請到鎖的應用服務器查詢所述數據庫服務器中的數據之后，所述方法還包括：將所述應用服務器從所述數據庫服務器中查詢的數據同步至運行于所述應用服務器中的應用中。

在一些實施例中，在所述通過應用服務器集群中的各個服務器向所述緩存服務器申請更新鎖之后，所述方法還包括：將所述緩存服務器中的數據同步至所述應用服務器集群中未申請到所述更新鎖的應用服務器。

在一些實施例中，所述通過應用服務器集群中的各個服務器向所述緩存服務器申請更新鎖，包括：獲取所述緩存服務器中預先存儲的更新時間，所述更新時間是所述緩存服務器上次從所述數據庫服務器進行數據同步的時間；在當前時間與所述更新時間之差達到預設時長時，通過所述應用服務器集群中的各個服務器向所述緩存服務器申請更新鎖；以及在所述將從所述數據庫服務器中查詢的數據同步至所述緩存服務器之后，所述方法還包括：將所述更新時間設置為當前時間。

在一些實施例中，所述方法還包括：在當前時間與所述更新時間之差未達到預設時長時，將所述緩存服務器中的數據同步至所述應用服務器集群中的各個應用服務器。

在一些實施例中，所述更新鎖設置有失效時間。

在一些實施例中，所述失效時間設置為所述預設時長的一半。

第二方面，本申請提供了一種用于數據系統的數據同步裝置，所述數據系統包括數據庫服務器、緩存服務器以及應用服務器集群，所述裝置包括：申請單元，用于通過應用服務器集群中的各個應用服務器向所述緩存服務器申請更新鎖；查詢單元，用于使用申請到更新鎖的應用服務器查詢所述數據庫服務器中的數據；第一同步單元，用于將所述應用服務器從所述數據庫服務器中查詢到的數據同步至所述緩存服務器。

在一些實施例中，所述裝置還包括：釋放單元，用于釋放所述應用服務器申請到的更新鎖。