[發明專利]多機房數據同步方法、計算設備及存儲介質

在審

• 申請號: 202010912032.4
• 申請日: 2020-09-02
• 公開（公告）號: CN112052230A
• 公開（公告）日: 2020-12-08
• 發明（設計）人: 譚帥
• 申請（專利權）人: 掌閱科技股份有限公司
• 主分類號: G06F16/178
• 分類號: G06F16/178;G06F16/18;G06F16/182
• 代理公司: 北京市浩天知識產權代理事務所(普通合伙) 11276
• 代理人: 梁倩

1.一種多機房數據同步方法，所述方法適用于基于Redis集群的機房之間的同步，Redis集群中包含有多個Redis組，每個Redis組包括一個主節點和所述主節點的所有從節點；所述方法包括：

接收客戶端發送的數據寫入請求，并對所述數據寫入請求進行封裝處理，將封裝后的數據寫入請求發送至本機房對應的Redis組中的主節點，以供所述主節點執行所述封裝后的數據寫入請求，并將數據操作記錄至所述主節點的日志文件中；

讀取本機房的每個Redis組中的主節點的日志文件中的數據操作，利用同步鏈路將讀取到的待同步的數據操作發送至對端機房，以供對端機房根據實時記錄的已同步的數據操作對應的第一文件偏移量對待同步的數據操作進行去重處理。

2.根據權利要求1所述的方法，所述方法還包括：若所述同步鏈路斷開導致同步失敗，則從斷點位置再次執行同步操作直至同步成功。

3.根據權利要求1或2所述的方法，所述讀取本機房的每個Redis組中的主節點的日志文件中的數據操作，利用同步鏈路將讀取到的待同步的數據操作發送至對端機房進一步包括：

針對每個Redis組，讀取所述主節點的日志文件中的數據操作，并為所述Redis組分配對應的同步線程，調用所述同步線程根據讀取到的待同步的數據操作構造同步命令，并利用所述同步鏈路將所述同步命令發送至對端機房，以供將所述同步命令分配至對端機房的對端主節點；

所述對端機房根據實時記錄的已同步的數據操作對應的第一文件偏移量對待同步的數據操作進行去重處理具體為：對端機房的對端主節點根據所記錄的第一文件偏移量對所述同步命令進行去重處理；執行去重后的同步命令，并在所述對端主節點中更新所述第一文件偏移量。

4.根據權利要求3所述的方法，所述同步命令包含有待同步的數據操作對應的第二文件偏移量和日志源標識；

所述對端機房的對端主節點根據所記錄的第一文件偏移量對所述同步命令進行去重處理進一步包括：

根據所述日志源標識獲取對應的第一文件偏移量；

判斷所述第二文件偏移量是否大于所述第一文件偏移量；若否，則丟棄所述同步命令。

5.根據權利要求3或4所述的方法，在將所述同步命令分配至對端機房的對端主節點之后，所述方法還包括：

向所述對端主節點發送等待命令，以供所述對端主節點根據所述等待命令在對端從節點完成對所述同步命令對應的數據操作的主從同步之后返回執行成功信息。

6.根據權利要求3-5任一項所述的方法，所述方法還包括：

接收對端機房在成功執行同步命令之后返回的執行成功信息，每隔預設時間間隔調用對應的同步線程根據所述執行成功信息構造攜帶有已同步的數據操作對應的文件偏移量的同步確認命令，并將所述同步確認命令發送至對應的主節點，以供所述主節點根據所述同步確認命令，記錄第三文件偏移量。

7.根據權利要求1-6任一項所述的方法，所述方法還包括：

若本機房的任一Redis組中的從節點變更為新主節點，則讀取所述新主節點中記錄的第三文件偏移量，根據所述第三文件偏移量確定斷點位置，從斷點位置再次執行同步操作直至同步成功。

8.根據權利要求1-7任一項所述的方法，在讀取本機房的每個Redis組中的主節點的日志文件中的數據操作之后，所述方法還包括：

檢測主節點與從節點之間已主從同步的數據操作對應的第四文件偏移量；

判斷本機房與對端機房之間待同步的數據操作對應的第二文件偏移量是否小于所述第四文件偏移量；

若是，則將所述待同步的數據操作發送至對端機房；若否，則等待預設時間，而后跳轉執行所述判斷本機房與對端機房之間待同步的數據操作對應的第二文件偏移量是否小于所述第四文件偏移量的步驟。