[發明專利]一種利用數據服務中心來保證數據一致性的方法及其系統

在審

• 申請號: 202110046354.X
• 申請日: 2021-01-14
• 公開（公告）號: CN112699139A
• 公開（公告）日: 2021-04-23
• 發明（設計）人: 劉德建;葉偉;陳宏展
• 申請（專利權）人: 福建天晴在線互動科技有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/27;G06F16/2455;G06F12/0877
• 代理公司: 福州旭辰知識產權代理事務所(普通合伙) 35233
• 代理人: 程勇

本發明提供了一種利用數據服務中心來保證數據一致性的方法，該方法為：步驟S1、設置主數據庫和從數據庫進行數據同步的最大延遲時間，并將最大延遲時間存入redis緩存；步驟S2、寫請求訪問數據服務中心，訪問主數據庫修改數據，存儲修改時間至redis緩存；步驟S3、獲取redis緩存中國最大延遲時間，并將最大延遲時間*2作為數據不一致的時間窗口；步驟S4、讀請求訪問數據服務中心，根據修改時間判斷數據是否在時間窗口期內被修改，是，則訪問主數據庫讀取數據；否，則訪問從數據庫讀取數據；以此來維持數據一致性。

技術領域

本發明涉及計算機通訊技術領域，特別是一種利用數據服務中心來保證數據一致性的方法及其系統。

背景技術

Mysql數據庫為了提供更高的性能，可以做讀寫分離，一臺數據庫做寫庫，一臺數據庫做從庫，Mysql通過主數據庫和從數據庫同步來維持數據一致。但是數據同步是有延遲的，根據數據量和數據結構的不同可能有長有短，可能50毫秒，也可能500毫秒。那分布式系統在高并發的場景下，在這幾百毫秒的窗口期間就可能存在數據不一致的情況。現有維持數據強一致性的手段有Mysql配置的全同步復制、使用分布式事務等等，但是這些方案都會降低接口的響應時間，降低系統的吞吐量，以此來提供完全的強一致性。但互聯網高并發的業務場景，更多的是使用最終一致性來維持多數據副本的一致性問題。

發明內容

為克服上述問題，本發明的目的是提供一種利用數據服務中心來保證數據一致性的方法，無需降低接口的響應時間，能保持數據最終一致性。

本發明采用以下方案實現：一種利用數據服務中心來保證數據一致性的方法，所述方法包括如下步驟：

步驟S1、設置主數據庫和從數據庫進行數據同步的最大延遲時間，并將最大延遲時間存入redis緩存；

步驟S2、寫請求訪問數據服務中心，訪問主數據庫修改數據，存儲修改時間至redis緩存；

步驟S3、獲取redis緩存中國最大延遲時間，并將最大延遲時間*2作為數據不一致的時間窗口；

步驟S4、讀請求訪問數據服務中心，根據修改時間判斷數據是否在時間窗口期內被修改，是，則訪問主數據庫讀取數據；否，則訪問從數據庫讀取數據；以此來維持數據一致性。

進一步的，所述步驟S1進一步具體為：設置一定時任務，該定時任務為選取主數據庫和從數據庫中一張表，目的是為了預估主數據庫和從數據庫進行數據同步的延遲上限，設置一預設時間對比一次延遲，從多次對比中存儲最大的延遲上限作為最大延遲時間存入redis緩存。

進一步的，所述步驟S2進一步具體為：數據服務中心接收到增加、刪除、修改請求，增加、刪除、修改都是更改數據的寫請求，寫請求一律鏈接主數據庫進行操作；訪問主數據庫修改數據，保存被更改的表名到redis緩存中，同時存儲修改時間至redis緩存；

進一步的，所述步驟S4進一步具體為：讀請求訪問數據服務中心，數據服務中心收到查詢修改表的請求后；根據查詢語句獲得修改表的數據，判斷修改時間是否小于時間窗口，是，則表明數據在不一致的時間窗口內更改過數據，則訪問主數據庫讀取數據；否，則訪問從數據庫讀取數據；以此來維持數據一致性。

本發明還提供了一種利用數據服務中心來保證數據一致性的系統，所述系統包括設置延遲時間模塊、寫請求操作模塊、時間窗口設置模塊、以及讀請求操作模塊；

所述設置延遲時間模塊，用于設置主數據庫和從數據庫進行數據同步的最大延遲時間，并將最大延遲時間存入redis緩存；

所述寫請求操作模塊，用于寫請求訪問數據服務中心，訪問主數據庫修改數據，存儲修改時間至redis緩存；

所述時間窗口設置模塊，用于獲取redis緩存中國最大延遲時間，并將最大延遲時間*2作為數據不一致的時間窗口；

所述讀請求操作模塊，用于讀請求訪問數據服務中心，根據修改時間判斷數據是否在時間窗口期內被修改，是，則訪問主數據庫讀取數據；否，則訪問從數據庫讀取數據；以此來維持數據一致性。